You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2020/03/24 14:43:10 UTC
[flink-web] branch asf-site updated (5541234 -> 0980cd6)
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a change to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git.
from 5541234 rebuild site
new 7d74677 [hotfix] fix patterns blog vol.2 date
new 0980cd6 Regenerate page
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
...n-2.md => 2020-03-24-demo-fraud-detection-2.md} | 2 +-
content/blog/feed.xml | 209 +++++++++++++++++++--
content/blog/index.html | 8 +-
content/blog/page10/index.html | 2 +-
content/blog/page11/index.html | 2 +-
content/blog/page2/index.html | 2 +-
content/blog/page3/index.html | 2 +-
content/blog/page4/index.html | 2 +-
content/blog/page5/index.html | 2 +-
content/blog/page6/index.html | 2 +-
content/blog/page7/index.html | 2 +-
content/blog/page8/index.html | 2 +-
content/blog/page9/index.html | 2 +-
content/index.html | 2 +-
.../{02/26 => 03/24}/demo-fraud-detection-2.html | 2 +-
content/zh/index.html | 2 +-
16 files changed, 213 insertions(+), 32 deletions(-)
rename _posts/{2020-02-26-demo-fraud-detection-2.md => 2020-03-24-demo-fraud-detection-2.md} (99%)
rename content/news/2020/{02/26 => 03/24}/demo-fraud-detection-2.html (99%)
[flink-web] 02/02: Regenerate page
Posted by rm...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 0980cd665712bbe6d28e8ecdaabe543855904a6c
Author: Robert Metzger <rm...@apache.org>
AuthorDate: Tue Mar 24 15:42:37 2020 +0100
Regenerate page
this closes #315
---
content/blog/feed.xml | 209 +++++++++++++++++++--
content/blog/index.html | 8 +-
content/blog/page10/index.html | 2 +-
content/blog/page11/index.html | 2 +-
content/blog/page2/index.html | 2 +-
content/blog/page3/index.html | 2 +-
content/blog/page4/index.html | 2 +-
content/blog/page5/index.html | 2 +-
content/blog/page6/index.html | 2 +-
content/blog/page7/index.html | 2 +-
content/blog/page8/index.html | 2 +-
content/blog/page9/index.html | 2 +-
content/index.html | 2 +-
.../{02/26 => 03/24}/demo-fraud-detection-2.html | 2 +-
content/zh/index.html | 2 +-
15 files changed, 212 insertions(+), 31 deletions(-)
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 2ae389a..803c8fb 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,201 @@
<atom:link href="https://flink.apache.org/blog/feed.xml" rel="self" type="application/rss+xml" />
<item>
+<title>Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</title>
+<description><p>In the <a href="https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html">first article</a> of the series, we gave a high-level description of the objectives and required functionality of a Fraud Detection engine. We also described how to make data partitioning in Apache Flink customizable based on modifiable rules instead of using a hardcoded <code>KeysExtractor</code> implementation.</p>
+
+<p>We intentionally omitted details of how the applied rules are initialized and what possibilities exist for updating them at runtime. In this post, we will address exactly these details. You will learn how the approach to data partitioning described in <a href="https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html">Part 1</a> can be applied in combination with a dynamic configuration. These two patterns, when used together, can eliminate the nee [...]
+
+<h2 id="rules-broadcasting">Rules Broadcasting</h2>
+
+<p>Let’s first have a look at the <a href="https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html#dynamic-data-partitioning">previously-defined</a> data-processing pipeline:</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="n">DataStream</span><span class="o">&lt;</span><span class="n">Alert</span><span class="o">&gt;</span> <span class="n">alerts</span> <span class="o">=</span>
+ <span class="n">transactions</span>
+ <span class="o">.</span><span class="na">process</span><span class="o">(</span><span class="k">new</span> <span class="nf">DynamicKeyFunction</span><span class="o">())</span>
+ <span class="o">.</span><span class="na">keyBy</span><span class="o">((</span><span class="n">keyed</span><span class="o">)</span> <span class="o">-&gt;</span> <span class="n">keyed</span><span class="o">.</span><span class="na">getKey</span><span class="o">());< [...]
+ <span class="o">.</span><span class="na">process</span><span class="o">(</span><span class="k">new</span> <span class="nf">DynamicAlertFunction</span><span class="o">())</span></code></pre></div>
+
+<p><code>DynamicKeyFunction</code> provides dynamic data partitioning while <code>DynamicAlertFunction</code> is responsible for executing the main logic of processing transactions and sending alert messages according to defined rules.</p>
+
+<p>Vol.1 of this series simplified the use case and assumed that the applied set of rules is pre-initialized and accessible via the <code>List&lt;Rules&gt;</code> within <code>DynamicKeyFunction</code>.</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="kd">public</span> <span class="kd">class</span> <span class="nc">DynamicKeyFunction</span>
+ <span class="kd">extends</span> <span class="n">ProcessFunction</span><span class="o">&lt;</span><span class="n">Transaction</span><span class="o">,</span> <span class="n">Keyed</span><span class="o">&lt;</span><span class="n">Transaction</span><span class="o">,</span> <span cla [...]
+
+ <span class="cm">/* Simplified */</span>
+ <span class="n">List</span><span class="o">&lt;</span><span class="n">Rule</span><span class="o">&gt;</span> <span class="n">rules</span> <span class="o">=</span> <span class="cm">/* Rules that are initialized somehow.*/</span><span class="o">;</span>
+ <span class="o">...</span>
+<span class="o">}</span></code></pre></div>
+
+<p>Adding rules to this list is obviously possible directly inside the code of the Flink Job at the stage of its initialization (Create a <code>List</code> object; use it’s <code>add</code> method). A major drawback of doing so is that it will require recompilation of the job with each rule modification. In a real Fraud Detection system, rules are expected to change on a frequent basis, making this approach unacceptable from the point of view of business and [...]
+
+<p>Next, let’s take a look at a sample rule definition that we introduced in the previous post of the series:</p>
+
+<center>
+<img src="/img/blog/patterns-blog-2/rule-dsl.png" width="800px" alt="Figure 1: Rule definition" />
+<br />
+<i><small>Figure 1: Rule definition</small></i>
+</center>
+<p><br /></p>
+
+<p>The previous post covered use of <code>groupingKeyNames</code> by <code>DynamicKeyFunction</code> to extract message keys. Parameters from the second part of this rule are used by <code>DynamicAlertFunction</code>: they define the actual logic of the performed operations and their parameters (such as the alert-triggering limit). This means that the same rule must be present in both <code>DynamicKeyFunction</code> and <code>Dy [...]
+
+<p>Figure 2 presents the final job graph of the system that we are building:</p>
+
+<center>
+<img src="/img/blog/patterns-blog-2/job-graph.png" width="800px" alt="Figure 2: Job Graph of the Fraud Detection Flink Job" />
+<br />
+<i><small>Figure 2: Job Graph of the Fraud Detection Flink Job</small></i>
+</center>
+<p><br /></p>
+
+<p>The main blocks of the Transactions processing pipeline are:<br /></p>
+
+<ul>
+ <li>
+ <p><strong>Transaction Source</strong> that consumes transaction messages from Kafka partitions in parallel. <br /></p>
+ </li>
+ <li>
+ <p><strong>Dynamic Key Function</strong> that performs data enrichment with a dynamic key. The subsequent <code>keyBy</code> hashes this dynamic key and partitions the data accordingly among all parallel instances of the following operator.</p>
+ </li>
+ <li>
+ <p><strong>Dynamic Alert Function</strong> that accumulates a data window and creates Alerts based on it.</p>
+ </li>
+</ul>
+
+<h2 id="data-exchange-inside-apache-flink">Data Exchange inside Apache Flink</h2>
+
+<p>The job graph above also indicates various data exchange patterns between the operators. In order to understand how the broadcast pattern works, let’s take a short detour and discuss what methods of message propagation exist in Apache Flink’s distributed runtime.</p>
+
+<ul>
+ <li>The <strong>FORWARD</strong> connection after the Transaction Source means that all data consumed by one of the parallel instances of the Transaction Source operator is transferred to exactly one instance of the subsequent <code>DynamicKeyFunction</code> operator. It also indicates the same level of parallelism of the two connected operators (12 in the above case). This communication pattern is illustrated in Figure 3. Orange circles represent transact [...]
+</ul>
+
+<center>
+<img src="/img/blog/patterns-blog-2/forward.png" width="800px" alt="Figure 3: FORWARD message passing across operator instances" />
+<br />
+<i><small>Figure 3: FORWARD message passing across operator instances</small></i>
+</center>
+<p><br /></p>
+
+<ul>
+ <li>The <strong>HASH</strong> connection between <code>DynamicKeyFunction</code> and <code>DynamicAlertFunction</code> means that for each message a hash code is calculated and messages are evenly distributed among available parallel instances of the next operator. Such a connection needs to be explicitly “requested” from Flink by using <code>keyBy</code>.</li>
+</ul>
+
+<center>
+<img src="/img/blog/patterns-blog-2/hash.png" width="800px" alt="Figure 4: HASHED message passing across operator instances (via `keyBy`)" />
+<br />
+<i><small>Figure 4: HASHED message passing across operator instances (via `keyBy`)</small></i>
+</center>
+<p><br /></p>
+
+<ul>
+ <li>A <strong>REBALANCE</strong> distribution is either caused by an explicit call to <code>rebalance()</code> or by a change of parallelism (12 -&gt; 1 in the case of the job graph from Figure 2). Calling <code>rebalance()</code> causes data to be repartitioned in a round-robin fashion and can help to mitigate data skew in certain scenarios.</li>
+</ul>
+
+<center>
+<img src="/img/blog/patterns-blog-2/rebalance.png" width="800px" alt="Figure 5: REBALANCE message passing across operator instances" />
+<br />
+<i><small>Figure 5: REBALANCE message passing across operator instances</small></i>
+</center>
+<p><br /></p>
+
+<p>The Fraud Detection job graph in Figure 2 contains an additional data source: <em>Rules Source</em>. It also consumes from Kafka. Rules are “mixed into” the main processing data flow through the <strong>BROADCAST</strong> channel. Unlike other methods of transmitting data between operators, such as <code>forward</code>, <code>hash</code> or <code>rebalance</code> that make each message available for processing in only o [...]
+
+<center>
+ <img src="/img/blog/patterns-blog-2/broadcast.png" width="800px" alt="Figure 6: BROADCAST message passing across operator instances" />
+ <br />
+ <i><small>Figure 6: BROADCAST message passing across operator instances</small></i>
+ </center>
+<p><br /></p>
+
+<div class="alert alert-info">
+ <p><span class="label label-info" style="display: inline-block"><span class="glyphicon glyphicon-info-sign" aria-hidden="true"></span> Note</span>
+There are actually a few more specialized data partitioning schemes in Flink which we did not mention here. If you want to find out more, please refer to Flink’s documentation on <strong><a href="https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/#physical-partitioning">stream partitioning</a></strong>.</p>
+</div>
+
+<h2 id="broadcast-state-pattern">Broadcast State Pattern</h2>
+
+<p>In order to make use of the Rules Source, we need to “connect” it to the main data stream:</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="c1">// Streams setup</span>
+<span class="n">DataStream</span><span class="o">&lt;</span><span class="n">Transaction</span><span class="o">&gt;</span> <span class="n">transactions</span> <span class="o">=</span> <span class="o">[...]</span>
+<span class="n">DataStream</span><span class="o">&lt;</span><span class="n">Rule</span><span class="o">&gt;</span> <span class="n">rulesUpdateStream</span> <span class="o">=</span> <span class="o">[...]</span>
+
+<span class="n">BroadcastStream</span><span class="o">&lt;</span><span class="n">Rule</span><span class="o">&gt;</span> <span class="n">rulesStream</span> <span class="o">=</span> <span class="n">rulesUpdateStream</span><span class="o">.</span><span class="na">broadcast</span><span [...]
+
+<span class="c1">// Processing pipeline setup</span>
+ <span class="n">DataStream</span><span class="o">&lt;</span><span class="n">Alert</span><span class="o">&gt;</span> <span class="n">alerts</span> <span class="o">=</span>
+ <span class="n">transactions</span>
+ <span class="o">.</span><span class="na">connect</span><span class="o">(</span><span class="n">rulesStream</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">process</span><span class="o">(</span><span class="k">new</span> <span class="nf">DynamicKeyFunction</span><span class="o">())</span>
+ <span class="o">.</span><span class="na">keyBy</span><span class="o">((</span><span class="n">keyed</span><span class="o">)</span> <span class="o">-&gt;</span> <span class="n">keyed</span><span class="o">.</span><span class="na">getKey</span><span class="o">())< [...]
+ <span class="o">.</span><span class="na">connect</span><span class="o">(</span><span class="n">rulesStream</span><span class="o">)</span>
+ <span class="o">.</span><span class="na">process</span><span class="o">(</span><span class="k">new</span> <span class="nf">DynamicAlertFunction</span><span class="o">())</span></code></pre></div>
+
+<p>As you can see, the broadcast stream can be created from any regular stream by calling the <code>broadcast</code> method and specifying a state descriptor. Flink assumes that broadcasted data needs to be stored and retrieved while processing events of the main data flow and, therefore, always automatically creates a corresponding <em>broadcast state</em> from this state descriptor. This is different from any other Apache Flink state type in which you need [...]
+
+<div class="highlight"><pre><code class="language-java"><span class="kd">public</span> <span class="kd">static</span> <span class="kd">final</span> <span class="n">MapStateDescriptor</span><span class="o">&lt;</span><span class="n">Integer</span><span class="o">,</span> <span class="n&qu [...]
+ <span class="k">new</span> <span class="n">MapStateDescriptor</span><span class="o">&lt;&gt;(</span><span class="s">&quot;rules&quot;</span><span class="o">,</span> <span class="n">Integer</span><span class="o">.</span><span class="na">class</span><span class="o">,</span&g [...]
+
+<p>Connecting to <code>rulesStream</code> causes some changes in the signature of the processing functions. The previous article presented it in a slightly simplified way as a <code>ProcessFunction</code>. However, <code>DynamicKeyFunction</code> is actually a <code>BroadcastProcessFunction</code>.</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="kd">public</span> <span class="kd">abstract</span> <span class="kd">class</span> <span class="nc">BroadcastProcessFunction</span><span class="o">&lt;</span><span class="n">IN1</span><span class="o">,</span> <span class=" [...]
+
+ <span class="kd">public</span> <span class="kd">abstract</span> <span class="kt">void</span> <span class="nf">processElement</span><span class="o">(</span><span class="n">IN1</span> <span class="n">value</span><span class="o">,</span>
+ <span class="n">ReadOnlyContext</span> <span class="n">ctx</span><span class="o">,</span>
+ <span class="n">Collector</span><span class="o">&lt;</span><span class="n">OUT</span><span class="o">&gt;</span> <span class="n">out</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span><span class="o">;</span>
+
+ <span class="kd">public</span> <span class="kd">abstract</span> <span class="kt">void</span> <span class="nf">processBroadcastElement</span><span class="o">(</span><span class="n">IN2</span> <span class="n">value</span><span class="o">,</span>
+ <span class="n">Context</span> <span class="n">ctx</span><span class="o">,</span>
+ <span class="n">Collector</span><span class="o">&lt;</span><span class="n">OUT</span><span class="o">&gt;</span> <span class="n">out</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span><span class="o"> [...]
+
+<span class="o">}</span></code></pre></div>
+
+<p>The difference is the addition of the <code>processBroadcastElement</code> method through which messages of the rules stream will arrive. The following new version of <code>DynamicKeyFunction</code> allows modifying the list of data-distribution keys at runtime through this stream:</p>
+
+<div class="highlight"><pre><code class="language-java"><span class="kd">public</span> <span class="kd">class</span> <span class="nc">DynamicKeyFunction</span>
+ <span class="kd">extends</span> <span class="n">BroadcastProcessFunction</span><span class="o">&lt;</span><span class="n">Transaction</span><span class="o">,</span> <span class="n">Rule</span><span class="o">,</span> <span class="n">Keyed</span><span class="o">&lt;</span><span c [...]
+
+
+ <span class="nd">@Override</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">processBroadcastElement</span><span class="o">(</span><span class="n">Rule</span> <span class="n">rule</span><span class="o">,</span>
+ <span class="n">Context</span> <span class="n">ctx</span><span class="o">,</span>
+ <span class="n">Collector</span><span class="o">&lt;</span><span class="n">Keyed</span><span class="o">&lt;</span><span class="n">Transaction</span><span class="o">,</span> <span class="n">String</span><span class="o">,</span> <span class="n">Integer</ [...]
+ <span class="n">BroadcastState</span><span class="o">&lt;</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Rule</span><span class="o">&gt;</span> <span class="n">broadcastState</span> <span class="o">=</span> <span class="n">ctx</span><span class=&quo [...]
+ <span class="n">broadcastState</span><span class="o">.</span><span class="na">put</span><span class="o">(</span><span class="n">rule</span><span class="o">.</span><span class="na">getRuleId</span><span class="o">(),</span> <span class="n">rule</span><span class="o">);</span>
+ <span class="o">}</span>
+
+ <span class="nd">@Override</span>
+ <span class="kd">public</span> <span class="kt">void</span> <span class="nf">processElement</span><span class="o">(</span><span class="n">Transaction</span> <span class="n">event</span><span class="o">,</span>
+ <span class="n">ReadOnlyContext</span> <span class="n">ctx</span><span class="o">,</span>
+ <span class="n">Collector</span><span class="o">&lt;</span><span class="n">Keyed</span><span class="o">&lt;</span><span class="n">Transaction</span><span class="o">,</span> <span class="n">String</span><span class="o">,</span> <span class="n">Integer</span>&l [...]
+ <span class="n">ReadOnlyBroadcastState</span><span class="o">&lt;</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Rule</span><span class="o">&gt;</span> <span class="n">rulesState</span> <span class="o">=</span>
+ <span class="n">ctx</span><span class="o">.</span><span class="na">getBroadcastState</span><span class="o">(</span><span class="n">RULES_STATE_DESCRIPTOR</span><span class="o">);</span>
+ <span class="k">for</span> <span class="o">(</span><span class="n">Map</span><span class="o">.</span><span class="na">Entry</span><span class="o">&lt;</span><span class="n">Integer</span><span class="o">,</span> <span class="n">Rule</span><span class="o">&gt;</sp [...]
+ <span class="kd">final</span> <span class="n">Rule</span> <span class="n">rule</span> <span class="o">=</span> <span class="n">entry</span><span class="o">.</span><span class="na">getValue</span><span class="o">();</span>
+ <span class="n">out</span><span class="o">.</span><span class="na">collect</span><span class="o">(</span>
+ <span class="k">new</span> <span class="n">Keyed</span><span class="o">&lt;&gt;(</span>
+ <span class="n">event</span><span class="o">,</span> <span class="n">KeysExtractor</span><span class="o">.</span><span class="na">getKey</span><span class="o">(</span><span class="n">rule</span><span class="o">.</span><span class="na">getGroupingKeyNames</span><span class=" [...]
+ <span class="o">}</span>
+ <span class="o">}</span>
+<span class="o">}</span></code></pre></div>
+
+<p>In the above code, <code>processElement()</code> receives Transactions, and <code>processBroadcastElement()</code> receives Rule updates. When a new rule is created, it is distributed as depicted in Figure 6 and saved in all parallel instances of the operator using <code>processBroadcastState</code>. We use a Rule’s ID as the key to store and reference individual rules. Instead of iterating over a hardcoded <code>List&lt;Rules&gt [...]
+
+<p><code>DynamicAlertFunction</code> follows the same logic with respect to storing the rules in the broadcast <code>MapState</code>. As described in <a href="https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html">Part 1</a>, each message in the <code>processElement</code> input is intended to be processed by one specific rule and comes “pre-marked” with a corresponding ID by <code>DynamicKeyFunction</ [...]
+
+<h1 id="summary">Summary</h1>
+
+<p>In this blog post, we continued our investigation of the use case of a Fraud Detection System built with Apache Flink. We looked into different ways in which data can be distributed between parallel operator instances and, most importantly, examined broadcast state. We demonstrated how dynamic partitioning — a pattern described in the <a href="https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html">first part</a> of the series — can be combined [...]
+</description>
+<pubDate>Tue, 24 Mar 2020 13:00:00 +0100</pubDate>
+<link>https://flink.apache.org/news/2020/03/24/demo-fraud-detection-2.html</link>
+<guid isPermaLink="true">/news/2020/03/24/demo-fraud-detection-2.html</guid>
+</item>
+
+<item>
<title>Apache Beam: How Beam Runs on Top of Flink</title>
<description><p>Note: This blog post is based on the talk <a href="https://www.youtube.com/watch?v=hxHGLrshnCY">“Beam on Flink: How Does It Actually Work?”</a>.</p>
@@ -16508,19 +16703,5 @@ properties, some algorithms)</p>
<guid isPermaLink="true">/news/2014/10/03/upcoming_events.html</guid>
</item>
-<item>
-<title>Apache Flink 0.6.1 available</title>
-<description><p>We are happy to announce the availability of Flink 0.6.1.</p>
-
-<p>0.6.1 is a maintenance release, which includes minor fixes across several parts
-of the system. We suggest all users of Flink to work with this newest version.</p>
-
-<p><a href="/downloads.html">Download</a> the release today.</p>
-</description>
-<pubDate>Fri, 26 Sep 2014 12:00:00 +0200</pubDate>
-<link>https://flink.apache.org/news/2014/09/26/release-0.6.1.html</link>
-<guid isPermaLink="true">/news/2014/09/26/release-0.6.1.html</guid>
-</item>
-
</channel>
</rss>
diff --git a/content/blog/index.html b/content/blog/index.html
index 83f8232..76feea3 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -185,14 +185,14 @@
<!-- Blog posts -->
<article>
- <h2 class="blog-title"><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></h2>
+ <h2 class="blog-title"><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></h2>
- <p>26 Feb 2020
+ <p>24 Mar 2020
Alexander Fedulov (<a href="https://twitter.com/alex_fedulov">@alex_fedulov</a>)</p>
<p>In this series of blog posts you will learn about powerful Flink patterns for building streaming applications.</p>
- <p><a href="/news/2020/02/26/demo-fraud-detection-2.html">Continue reading »</a></p>
+ <p><a href="/news/2020/03/24/demo-fraud-detection-2.html">Continue reading »</a></p>
</article>
<hr>
@@ -352,7 +352,7 @@
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page10/index.html b/content/blog/page10/index.html
index be5f2ff..906757c 100644
--- a/content/blog/page10/index.html
+++ b/content/blog/page10/index.html
@@ -371,7 +371,7 @@ and offers a new API including definition of flexible windows.</p>
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page11/index.html b/content/blog/page11/index.html
index 08e9918..c022062 100644
--- a/content/blog/page11/index.html
+++ b/content/blog/page11/index.html
@@ -249,7 +249,7 @@ academic and open source project that Flink originates from.</p>
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index 7735782..3dd4a60 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -355,7 +355,7 @@
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index 7ecead4..6cbe424 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -358,7 +358,7 @@ for more details.</p>
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index 62c1a3e..22faf1d 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -366,7 +366,7 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html
index 6288910..6e969e6 100644
--- a/content/blog/page5/index.html
+++ b/content/blog/page5/index.html
@@ -360,7 +360,7 @@
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page6/index.html b/content/blog/page6/index.html
index 4e02b6a..d2fad84 100644
--- a/content/blog/page6/index.html
+++ b/content/blog/page6/index.html
@@ -366,7 +366,7 @@ what’s coming in Flink 1.4.0 as well as a preview of what the Flink community
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page7/index.html b/content/blog/page7/index.html
index b07af4e..2c50ecc 100644
--- a/content/blog/page7/index.html
+++ b/content/blog/page7/index.html
@@ -361,7 +361,7 @@
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page8/index.html b/content/blog/page8/index.html
index 2707cf4..87415c5 100644
--- a/content/blog/page8/index.html
+++ b/content/blog/page8/index.html
@@ -359,7 +359,7 @@
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/blog/page9/index.html b/content/blog/page9/index.html
index d3e4763..ba1abcd 100644
--- a/content/blog/page9/index.html
+++ b/content/blog/page9/index.html
@@ -374,7 +374,7 @@ release is a preview release that contains known issues.</p>
<ul id="markdown-toc">
- <li><a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
+ <li><a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></li>
diff --git a/content/index.html b/content/index.html
index 99c2cdb..d994ff4 100644
--- a/content/index.html
+++ b/content/index.html
@@ -557,7 +557,7 @@
<dl>
- <dt> <a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></dt>
+ <dt> <a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></dt>
<dd>In this series of blog posts you will learn about powerful Flink patterns for building streaming applications.</dd>
<dt> <a href="/ecosystem/2020/02/22/apache-beam-how-beam-runs-on-top-of-flink.html">Apache Beam: How Beam Runs on Top of Flink</a></dt>
diff --git a/content/news/2020/02/26/demo-fraud-detection-2.html b/content/news/2020/03/24/demo-fraud-detection-2.html
similarity index 99%
rename from content/news/2020/02/26/demo-fraud-detection-2.html
rename to content/news/2020/03/24/demo-fraud-detection-2.html
index bc98c28..de23201 100644
--- a/content/news/2020/02/26/demo-fraud-detection-2.html
+++ b/content/news/2020/03/24/demo-fraud-detection-2.html
@@ -183,7 +183,7 @@
<h1>Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</h1>
<article>
- <p>26 Feb 2020 Alexander Fedulov (<a href="https://twitter.com/alex_fedulov">@alex_fedulov</a>)</p>
+ <p>24 Mar 2020 Alexander Fedulov (<a href="https://twitter.com/alex_fedulov">@alex_fedulov</a>)</p>
<p>In the <a href="https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html">first article</a> of the series, we gave a high-level description of the objectives and required functionality of a Fraud Detection engine. We also described how to make data partitioning in Apache Flink customizable based on modifiable rules instead of using a hardcoded <code>KeysExtractor</code> implementation.</p>
diff --git a/content/zh/index.html b/content/zh/index.html
index 4955950..0a209bf 100644
--- a/content/zh/index.html
+++ b/content/zh/index.html
@@ -554,7 +554,7 @@
<dl>
- <dt> <a href="/news/2020/02/26/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></dt>
+ <dt> <a href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application Patterns Vol.2: Dynamic Updates of Application Logic</a></dt>
<dd>In this series of blog posts you will learn about powerful Flink patterns for building streaming applications.</dd>
<dt> <a href="/ecosystem/2020/02/22/apache-beam-how-beam-runs-on-top-of-flink.html">Apache Beam: How Beam Runs on Top of Flink</a></dt>
[flink-web] 01/02: [hotfix] fix patterns blog vol.2 date
Posted by rm...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 7d746773f0a00ee11ff89d346b33ff15401589e9
Author: Alexander Fedulov <14...@users.noreply.github.com>
AuthorDate: Tue Mar 24 15:28:53 2020 +0100
[hotfix] fix patterns blog vol.2 date
---
...6-demo-fraud-detection-2.md => 2020-03-24-demo-fraud-detection-2.md} | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/_posts/2020-02-26-demo-fraud-detection-2.md b/_posts/2020-03-24-demo-fraud-detection-2.md
similarity index 99%
rename from _posts/2020-02-26-demo-fraud-detection-2.md
rename to _posts/2020-03-24-demo-fraud-detection-2.md
index c941b9f..8a2db4e 100644
--- a/_posts/2020-02-26-demo-fraud-detection-2.md
+++ b/_posts/2020-03-24-demo-fraud-detection-2.md
@@ -2,7 +2,7 @@
layout: post
title: "Advanced Flink Application Patterns Vol.2:
Dynamic Updates of Application Logic"
-date: 2020-02-26T12:00:00.000Z
+date: 2020-03-24T12:00:00.000Z
authors:
- alex:
name: "Alexander Fedulov"