This is an automated email from the ASF dual-hosted git repository.
knaufk pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/flink-web.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 387bf1f Rebuild Website
387bf1f is described below
commit 387bf1f3cfbfac4a11f913dc37d43fb44acd1511
Author: Konstantin Knauf <knauf.konstan...@gmail.com>
AuthorDate: Tue Mar 15 12:40:47 2022 +0100
Rebuild Website
---
content/blog/feed.xml | 451 ++++++++-------------
content/blog/index.html | 46 ++-
content/blog/page10/index.html | 44 +-
content/blog/page11/index.html | 48 ++-
content/blog/page12/index.html | 44 +-
content/blog/page13/index.html | 42 +-
content/blog/page14/index.html | 42 +-
content/blog/page15/index.html | 42 +-
content/blog/page16/index.html | 42 +-
content/blog/page17/index.html | 42 +-
content/blog/page18/index.html | 27 +-
content/blog/page2/index.html | 49 +--
content/blog/page3/index.html | 51 ++-
content/blog/page4/index.html | 44 +-
content/blog/page5/index.html | 42 +-
content/blog/page6/index.html | 47 ++-
content/blog/page7/index.html | 45 +-
content/blog/page8/index.html | 38 +-
content/blog/page9/index.html | 38 +-
content/downloads.html | 33 +-
content/index.html | 8 +-
.../news/2022/02/{09 => 18}/release-1.13.6.html | 2 +-
.../11/release-1.14.4.html} | 164 +++-----
content/q/gradle-quickstart.sh | 2 +-
content/q/quickstart-scala.sh | 2 +-
content/q/quickstart.sh | 2 +-
content/q/sbt-quickstart.sh | 2 +-
content/zh/downloads.html | 37 +-
content/zh/index.html | 8 +-
29 files changed, 776 insertions(+), 708 deletions(-)
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 6e7ccc6..c8b120f 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,171 @@
<atom:link href="https://flink.apache.org/blog/feed.xml"; rel="self"
type="application/rss+xml" />
<item>
+<title>Apache Flink 1.14.4 Release Announcement</title>
+<description><p>The Apache Flink Community is pleased to announce
another bug fix release for Flink 1.14.</p>
+
+<p>This release includes 51 bug and vulnerability fixes and minor
improvements for Flink 1.14.
+Below you will find a list of all bugfixes and improvements (excluding
improvements to the build infrastructure and build stability). For a complete
list of all changes see:
+<a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&amp;version=12351074">JIRA</a>.</p>
+
+<p>We highly recommend all users to upgrade to Flink 1.14.4.</p>
+
+<h1 id="release-artifacts">Release Artifacts</h1>
+
+<h2 id="maven-dependencies">Maven Dependencies</h2>
+
+<div class="highlight"><pre><code
class="language-xml"><span
class="nt">&lt;dependency&gt;</span>
+ <span
class="nt">&lt;groupId&gt;</span>org.apache.flink<span
class="nt">&lt;/groupId&gt;</span>
+ <span
class="nt">&lt;artifactId&gt;</span>flink-java<span
class="nt">&lt;/artifactId&gt;</span>
+ <span
class="nt">&lt;version&gt;</span>1.14.4<span
class="nt">&lt;/version&gt;</span>
+<span class="nt">&lt;/dependency&gt;</span>
+<span class="nt">&lt;dependency&gt;</span>
+ <span
class="nt">&lt;groupId&gt;</span>org.apache.flink<span
class="nt">&lt;/groupId&gt;</span>
+ <span
class="nt">&lt;artifactId&gt;</span>flink-streaming-java_2.11<span
class="nt">&lt;/artifactId&gt;</span>
+ <span
class="nt">&lt;version&gt;</span>1.14.4<span
class="nt">&lt;/version&gt;</span>
+<span class="nt">&lt;/dependency&gt;</span>
+<span class="nt">&lt;dependency&gt;</span>
+ <span
class="nt">&lt;groupId&gt;</span>org.apache.flink<span
class="nt">&lt;/groupId&gt;</span>
+ <span
class="nt">&lt;artifactId&gt;</span>flink-clients_2.11<span
class="nt">&lt;/artifactId&gt;</span>
+ <span
class="nt">&lt;version&gt;</span>1.14.4<span
class="nt">&lt;/version&gt;</span>
+<span
class="nt">&lt;/dependency&gt;</span></code></pre></div>
+
+<h2 id="binaries">Binaries</h2>
+
+<p>You can find the binaries on the updated <a
href="/downloads.html">Downloads page</a>.</p>
+
+<h2 id="docker-images">Docker Images</h2>
+
+<ul>
+ <li><a
href="https://hub.docker.com/_/flink?tab=tags&amp;page=1&amp;name=1.14.4">library/flink</a>
(official images)</li>
+ <li><a
href="https://hub.docker.com/r/apache/flink/tags?page=1&amp;name=1.14.4">apache/flink</a>
(ASF repository)</li>
+</ul>
+
+<h2 id="pypi">PyPi</h2>
+
+<ul>
+ <li><a
href="https://pypi.org/project/apache-flink/1.14.4/">apache-flink==1.14.4</a></li>
+</ul>
+
+<h1 id="release-notes">Release Notes</h1>
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21788">FLINK-21788</a>]
- Throw PartitionNotFoundException if the partition file has been lost
for blocking shuffle
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24954">FLINK-24954</a>]
- Reset read buffer request timeout on buffer recycling for
sort-shuffle
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25653">FLINK-25653</a>]
- Move buffer recycle in SortMergeSubpartitionReader out of lock to
avoid deadlock
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25654">FLINK-25654</a>]
- Remove the redundant lock in SortMergeResultPartition
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25879">FLINK-25879</a>]
- Track used search terms in Matomo
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25880">FLINK-25880</a>]
- Implement Matomo in Flink documentation
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21752">FLINK-21752</a>]
- NullPointerException on restore in PojoSerializer
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23946">FLINK-23946</a>]
- Application mode fails fatally when being shut down
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24334">FLINK-24334</a>]
- Configuration kubernetes.flink.log.dir not working
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24407">FLINK-24407</a>]
- Pulsar connector chinese document link to Pulsar document location
incorrectly.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24607">FLINK-24607</a>]
- SourceCoordinator may miss to close SplitEnumerator when failover
frequently
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25171">FLINK-25171</a>]
- When the DDL statement was executed, the column names of the Derived
Columns were not validated
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25199">FLINK-25199</a>]
- StreamEdges are not unique in self-union, which blocks propagation
of watermarks
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25362">FLINK-25362</a>]
- Incorrect dependencies in Table Confluent/Avro docs
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25407">FLINK-25407</a>]
- Network stack deadlock when cancellation happens during
initialisation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25466">FLINK-25466</a>]
- TTL configuration could parse in StateTtlConfig#DISABLED
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25486">FLINK-25486</a>]
- Perjob can not recover from checkpoint when zookeeper leader changes
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25494">FLINK-25494</a>]
- Duplicate element serializer during
DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25678">FLINK-25678</a>]
- TaskExecutorStateChangelogStoragesManager.shutdown is not thread-safe
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25683">FLINK-25683</a>]
- wrong result if table transfrom to DataStream then window process in
batch mode
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25728">FLINK-25728</a>]
- Potential memory leaks in StreamMultipleInputProcessor
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25732">FLINK-25732</a>]
- Dispatcher#requestMultipleJobDetails returns non-serialiable
collection
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25827">FLINK-25827</a>]
- Potential memory leaks in SourceOperator
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25856">FLINK-25856</a>]
- Fix use of UserDefinedType in from_elements
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25883">FLINK-25883</a>]
- The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is
too large
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25893">FLINK-25893</a>]
- ResourceManagerServiceImpl&#39;s lifecycle can lead to exceptions
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25952">FLINK-25952</a>]
- Savepoint on S3 are not relocatable even if entropy injection is not
enabled
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26039">FLINK-26039</a>]
- Incorrect value getter in map unnest table function
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26159">FLINK-26159</a>]
- Pulsar Connector: should add description MAX_FETCH_RECORD in doc to
explain slow consumption
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26160">FLINK-26160</a>]
- Pulsar Connector: stopCursor description should be changed.
Connector only stop when auto discovery is disabled.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26187">FLINK-26187</a>]
- Chinese docs override english aliases
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26304">FLINK-26304</a>]
- GlobalCommitter can receive failed committables
+</li>
+</ul>
+
+<h2> New Feature
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20188">FLINK-20188</a>]
- Add Documentation for new File Source
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21407">FLINK-21407</a>]
- Clarify which sources and APIs support which formats
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20830">FLINK-20830</a>]
- Add a type of HEADLESS_CLUSTER_IP for rest service type
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24880">FLINK-24880</a>]
- Error messages &quot;OverflowError: timeout value is too
large&quot; shown when executing PyFlink jobs
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25160">FLINK-25160</a>]
- Make doc clear: tolerable-failed-checkpoints counts consecutive
failures
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25611">FLINK-25611</a>]
- Remove CoordinatorExecutorThreadFactory thread creation guards
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25650">FLINK-25650</a>]
- Document unaligned checkpoints performance limitations (larger
records/flat map/timers/...)
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25767">FLINK-25767</a>]
- Translation of page &#39;Working with State&#39; is
incomplete
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25818">FLINK-25818</a>]
- Add explanation how Kafka Source deals with idleness when
parallelism is higher then the number of partitions
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25576">FLINK-25576</a>]
- Update com.h2database:h2 to 2.0.206
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25785">FLINK-25785</a>]
- Update com.h2database:h2 to 2.0.210
+</li>
+</ul>
+</description>
+<pubDate>Fri, 11 Mar 2022 09:00:00 +0100</pubDate>
+<link>https://flink.apache.org/news/2022/03/11/release-1.14.4.html</link>
+<guid isPermaLink="true">/news/2022/03/11/release-1.14.4.html</guid>
+</item>
+
+<item>
<title>Scala Free in One Fifteen</title>
<description><p>Flink 1.15 is right around the corner, and among the
many improvements is a Scala free classpath.
Users can now leverage the Java API from any Scala version, including Scala
3!</p>
@@ -305,9 +470,9 @@ Below you will find a list of all bugfixes and improvements
(excluding improveme
</li>
</ul>
</description>
-<pubDate>Wed, 09 Feb 2022 09:00:00 +0100</pubDate>
-<link>https://flink.apache.org/news/2022/02/09/release-1.13.6.html</link>
-<guid isPermaLink="true">/news/2022/02/09/release-1.13.6.html</guid>
+<pubDate>Fri, 18 Feb 2022 09:00:00 +0100</pubDate>
+<link>https://flink.apache.org/news/2022/02/18/release-1.13.6.html</link>
+<guid isPermaLink="true">/news/2022/02/18/release-1.13.6.html</guid>
</item>
<item>
@@ -19648,285 +19813,5 @@ The documentation of Flink’s relational APIs has
organically grown and can be
<guid isPermaLink="true">/news/2019/04/17/sod.html</guid>
</item>
-<item>
-<title>Apache Flink 1.8.0 Release Announcement</title>
-<description><p>The Apache Flink community is pleased to announce Apache
Flink 1.8.0. The
-latest release includes more than 420 resolved issues and some exciting
-additions to Flink that we describe in the following sections of this post.
-Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&amp;version=12344274">complete
changelog</a>
-for more details.</p>
-
-<p>Flink 1.8.0 is API-compatible with previous 1.x.y releases for APIs
annotated
-with the <code>@Public</code> annotation. The release is
available now and we encourage
-everyone to <a href="/downloads.html">download the
release</a> and
-check out the updated
-<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.8/">documentation</a>.
-Feedback through the Flink <a
href="/community.html#mailing-lists">mailing
-lists</a> or
-<a
href="https://issues.apache.org/jira/projects/FLINK/summary">JIRA</a>
is, as always,
-very much appreciated!</p>
-
-<p>You can find the binaries on the updated <a
href="/downloads.html">Downloads page</a> on the Flink
project site.</p>
-
-<div class="page-toc">
-<ul id="markdown-toc">
- <li><a href="#new-features-and-improvements"
id="markdown-toc-new-features-and-improvements">New Features and
Improvements</a></li>
- <li><a href="#important-changes"
id="markdown-toc-important-changes">Important
Changes</a></li>
- <li><a href="#known-issues"
id="markdown-toc-known-issues">Known Issues</a></li>
- <li><a href="#release-notes"
id="markdown-toc-release-notes">Release Notes</a></li>
- <li><a href="#list-of-contributors"
id="markdown-toc-list-of-contributors">List of
Contributors</a></li>
-</ul>
-
-</div>
-
-<p>With Flink 1.8.0 we come closer to our goals of enabling fast data
processing
-and building data-intensive applications for the Flink community in a seamless
-way. We do this by cleaning up and refactoring Flink under the hood to allow
-more efficient feature development in the future. This includes removal of the
-legacy runtime components that were subsumed in the major rework of Flink’s
-underlying distributed system architecture
-(<a
href="https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65147077">FLIP-6</a>)
-as well as refactorings on the Table API that prepare it for the future
-addition of the Blink enhancements
-(<a
href="https://issues.apache.org/jira/browse/FLINK-11439">FLINK-11439</a>).</p>
-
-<p>Nevertheless, this release includes some important new features and
bug fixes.
-The most interesting of those are highlighted below. Please consult the
-<a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&amp;version=12344274">complete
changelog</a>
-and the <a
href="https://nightlies.apache.org/flink/flink-docs-release-1.8/release-notes/flink-1.8.html">release
notes</a>
-for more details.</p>
-
-<h2 id="new-features-and-improvements">New Features and
Improvements</h2>
-
-<ul>
- <li>
- <p><strong>Finalized State Schema Evolution
Story</strong>: This release completes
-the community driven effort to provide a schema evolution story for
-user state managed by Flink. This has been an effort that spanned 2
-releases, starting from 1.7.0 with the introduction of support for
-Avro state schema evolution as well as a revamped serialization
-compatibility abstraction.</p>
-
- <p>Flink 1.8.0 finalizes this effort by extending support for schema
-evolution to POJOs, upgrading all Flink built-in serializers to use
-the new serialization compatibility abstractions, as well as making it
-easier for advanced users who use custom state serializers to
-implement the abstractions. These different aspects for a complete
-out-of-the-box schema evolution story are explained in detail below:</p>
-
- <ol>
- <li>
- <p>Support for POJO state schema evolution: The pool of data
types
-that support state schema evolution has been expanded to include
-POJOs. For state types that use POJOs, you can now add or remove
-fields from your POJO while retaining backwards
-compatibility. For a full overview of the list of data types that
-now support schema evolution as well as their evolution
-specifications and limitations, please refer to the State Schema
-Evolution documentation page.</p>
- </li>
- <li>
- <p>Upgrade all Flink serializers to use new serialization
-compatibility asbtractions: Back in 1.7.0, we introduced the new
-serialization compatibility abstractions
<code>TypeSerializerSnapshot</code>
-and <code>TypeSerializerSchemaCompatibility</code>. Besides
providing a more
-expressible API to reflect schema compatibility between the data
-stored in savepoints and the data registered at runtime, another
-important aspect about the new abstraction is that it avoids the
-need for Flink to Java-serialize the state serializer as state
-metadata in savepoints.</p>
-
- <p>In 1.8.0, all of Flink’s built-in serializers have been
upgraded to
-use the new abstractions, and therefore the serializers
-themselves are no longer Java-serialized into savepoints. This
-greatly improves interoperability of Flink savepoints, in terms
-of state schema evolvability. For example, one outcome was the
-support for POJO schema evolution, as previously mentioned
-above. Another outcome is that all composite data types supported
-by Flink (such as <code>Either</code>, Scala case classes, Flink
Java
-<code>Tuple</code>s, etc.) are generally evolve-able as well when
they have
-a nested evolvable type, such as a POJO. For example, the
<code>MyPojo</code>
-type in <code>ValueState&lt;Tuple2&lt;Integer,
MyPojo&gt;&gt;</code> or
-<code>ListState&lt;Either&lt;Integer,
MyPojo&gt;&gt;</code>, which is a POJO, is allowed
-to evolve its schema.</p>
-
- <p>For users who are using custom
<code>TypeSerializer</code> implementations
-for their state serializer and are still using the outdated
-abstractions (i.e. <code>TypeSerializerConfigSnapshot</code> and
-<code>CompatiblityResult</code>), we highly recommend upgrading to
the new
-abstractions to be future proof. Please refer to the Custom State
-Serialization documentation page for a detailed description on
-the new abstractions.</p>
- </li>
- <li>
- <p>Provide pre-defined snapshot implementations for common
-serializers: For convenience, Flink 1.8.0 comes with two
-predefined implementations for the
<code>TypeSerializerSnapshot</code> that
-make the task of implementing these new abstractions easier
-for most implementations of <code>TypeSerializer</code>s -
-<code>SimpleTypeSerializerSnapshot</code> and
-<code>CompositeTypeSerializerSnapshot</code>. This section in the
-documentation provides information on how to use these classes.</p>
- </li>
- </ol>
- </li>
- <li>
- <p><strong>Continuous cleanup of old state based on TTL
-(<a
href="https://issues.apache.org/jira/browse/FLINK-7811">FLINK-7811</a>)</strong>:
We
-introduced TTL (time-to-live) for Keyed state in Flink 1.6
-(<a
href="https://issues.apache.org/jira/browse/FLINK-9510">FLINK-9510</a>).
This
-feature enabled cleanup and made keyed state entries inaccessible after a
-defined timeout. In addition state would now also be cleaned up when
-writing a savepoint/checkpoint.</p>
-
- <p>Flink 1.8 introduces continuous cleanup of old entries for both
the RocksDB
-state backend
-(<a
href="https://issues.apache.org/jira/browse/FLINK-10471">FLINK-10471</a>)
and the heap
-state backend
-(<a
href="https://issues.apache.org/jira/browse/FLINK-10473">FLINK-10473</a>).
This means
-that old entries (according to the TTL setting) are continuously cleaned
up.</p>
- </li>
- <li>
- <p><strong>SQL pattern detection with user-defined functions
and
-aggregations</strong>: The support of the MATCH_RECOGNIZE clause has been
-extended by multiple features. The addition of user-defined
-functions allows for custom logic during pattern detection
-(<a
href="https://issues.apache.org/jira/browse/FLINK-10597">FLINK-10597</a>),
-while adding aggregations allows for more complex CEP definitions,
-such as the following
-(<a
href="https://issues.apache.org/jira/browse/FLINK-7599">FLINK-7599</a>).</p>
-
- <div class="highlight"><pre><code>SELECT *
-FROM Ticker
- MATCH_RECOGNIZE (
- ORDER BY rowtime
- MEASURES
- AVG(A.price) AS avgPrice
- ONE ROW PER MATCH
- AFTER MATCH SKIP TO FIRST B
- PATTERN (A+ B)
- DEFINE
- A AS AVG(A.price) &lt; 15
- ) MR;
-</code></pre></div>
- </li>
- <li>
- <p><strong>RFC-compliant CSV format (<a
href="https://issues.apache.org/jira/browse/FLINK-9964">FLINK-9964</a>)</strong>:
The SQL tables can now be read and written in
-an RFC-4180 standard compliant CSV table format. The format might also be
-useful for general DataStream API users.</p>
- </li>
- <li>
- <p><strong>New KafkaDeserializationSchema that gives direct
access to ConsumerRecord
-(<a
href="https://issues.apache.org/jira/browse/FLINK-8354">FLINK-8354</a>)</strong>:
For the
-Flink <code>KafkaConsumers</code>, we introduced a new
<code>KafkaDeserializationSchema</code> that
-gives direct access to the Kafka <code>ConsumerRecord</code>. This
now allows access to
-all data that Kafka provides for a record, including the headers. This
-subsumes the <code>KeyedSerializationSchema</code> functionality,
which is deprecated but
-still available for now.</p>
- </li>
- <li>
- <p><strong>Per-shard watermarking option in
FlinkKinesisConsumer
-(<a
href="https://issues.apache.org/jira/browse/FLINK-5697">FLINK-5697</a>)</strong>:
The Kinesis
-Consumer can now emit periodic watermarks that are derived from per-shard
watermarks,
-for correct event time processing with subtasks that consume multiple Kinesis
shards.</p>
- </li>
- <li>
- <p><strong>New consumer for DynamoDB Streams to capture table
changes
-(<a
href="https://issues.apache.org/jira/browse/FLINK-4582">FLINK-4582</a>)</strong>:
<code>FlinkDynamoDBStreamsConsumer</code>
-is a variant of the Kinesis consumer that supports retrieval of CDC-like
streams from DynamoDB tables.</p>
- </li>
- <li>
- <p><strong>Support for global aggregates for subtask
coordination
-(<a
href="https://issues.apache.org/jira/browse/FLINK-10887">FLINK-10887</a>)</strong>:
-Designed as a solution for global source watermark tracking,
<code>GlobalAggregateManager</code>
-allows sharing of information between parallel subtasks. This feature will
-be integrated into streaming connectors for watermark synchronization and
-can be used for other purposes with a user defined aggregator.</p>
- </li>
-</ul>
-
-<h2 id="important-changes">Important Changes</h2>
-
-<ul>
- <li>
- <p><strong>Changes to bundling of Hadoop libraries with Flink
-(<a
href="https://issues.apache.org/jira/browse/FLINK-11266">FLINK-11266</a>)</strong>:
-Convenience binaries that include hadoop are no longer released.</p>
-
- <p>If a deployment relies on
<code>flink-shaded-hadoop2</code> being included in
-<code>flink-dist</code>, then you must manually download a
pre-packaged Hadoop
-jar from the optional components section of the <a
href="/downloads.html">download
-page</a> and copy it into the
-<code>/lib</code> directory. Alternatively, a Flink distribution
that includes
-hadoop can be built by packaging <code>flink-dist</code> and
activating the
-<code>include-hadoop</code> maven profile.</p>
-
- <p>As hadoop is no longer included in
<code>flink-dist</code> by default, specifying
-<code>-DwithoutHadoop</code> when packaging
<code>flink-dist</code> no longer impacts the build.</p>
- </li>
- <li>
- <p><strong>FlinkKafkaConsumer will now filter restored
partitions based on topic
-specification
-(<a
href="https://issues.apache.org/jira/browse/FLINK-10342">FLINK-10342</a>)</strong>:
-Starting from Flink 1.8.0, the <code>FlinkKafkaConsumer</code> now
always filters out
-restored partitions that are no longer associated with a specified topic to
-subscribe to in the restored execution. This behaviour did not exist in
-previous versions of the <code>FlinkKafkaConsumer</code>. If you
wish to retain the
-previous behaviour, please use the
-<code>disableFilterRestoredPartitionsWithSubscribedTopics()</code>
configuration method
-on the <code>FlinkKafkaConsumer</code>.</p>
-
- <p>Consider this example: if you had a Kafka Consumer that was
consuming from
-topic <code>A</code>, you did a savepoint, then changed your Kafka
consumer to instead
-consume from topic <code>B</code>, and then restarted your job
from the savepoint.
-Before this change, your consumer would now consume from both topic
<code>A</code> and
-<code>B</code> because it was stored in state that the consumer
was consuming from topic
-<code>A</code>. With the change, your consumer would only consume
from topic <code>B</code> after
-restore because it now filters the topics that are stored in state using the
-configured topics.</p>
- </li>
- <li>
- <p><strong>Change in the Maven modules of Table API
-(<a
href="https://issues.apache.org/jira/browse/FLINK-11064">FLINK-11064</a>)</strong>:
Users
-that had a <code>flink-table</code> dependency before, need to
update their
-dependencies to <code>flink-table-planner</code> and the correct
dependency of
-<code>flink-table-api-*</code>, depending on whether Java or Scala
is used: one of
-<code>flink-table-api-java-bridge</code> or
<code>flink-table-api-scala-bridge</code>.</p>
- </li>
-</ul>
-
-<h2 id="known-issues">Known Issues</h2>
-
-<ul>
- <li><strong>Discarded checkpoint can cause Tasks to fail
-(<a
href="https://issues.apache.org/jira/browse/FLINK-11662">FLINK-11662</a>)</strong>:
There is
-a race condition that can lead to erroneous checkpoint failures. This mostly
-occurs when restarting from a savepoint or checkpoint takes a long time at the
-sources of a job. If you see random checkpointing failures that don’t seem to
-have a good explanation you might be affected. Please see the Jira issue for
-more details and a workaround for the problem.</li>
-</ul>
-
-<h2 id="release-notes">Release Notes</h2>
-
-<p>Please review the <a
href="https://nightlies.apache.org/flink/flink-docs-release-1.8/release-notes/flink-1.8.html">release
-notes</a>
-for a more detailed list of changes and new features if you plan to upgrade
-your Flink setup to Flink 1.8.</p>
-
-<h2 id="list-of-contributors">List of Contributors</h2>
-
-<p>We would like to acknowledge all community members for contributing
to this
-release. Special credits go to the following members for contributing to the
-1.8.0 release (according to <code>git log --pretty="%an"
release-1.7.0..release-1.8.0 | sort | uniq</code> without manual
deduplication):</p>
-
-<p>Addison Higham, Aitozi, Aleksey Pak, Alexander Fedulov, Alexey
Trenikhin, Aljoscha Krettek, Andrey Zagrebin, Artsem Semianenka, Asura7969,
Avi, Barisa Obradovic, Benchao Li, Bo WANG, Chesnay Schepler, Congxian Qiu,
Cristian, David Anderson, Dawid Wysakowicz, Dian Fu, DuBin, EAlexRojas,
EronWright, Eugen Yushin, Fabian Hueske, Fokko Driesprong, Gary Yao, Hequn
Cheng, Igal Shilman, Jamie Grier, JaryZhen, Jeff Zhang, Jihyun Cho, Jinhu Wu,
Joerg Schad, KarmaGYZ, Kezhu Wang, Konstant [...]
-
-</description>
-<pubDate>Tue, 09 Apr 2019 14:00:00 +0200</pubDate>
-<link>https://flink.apache.org/news/2019/04/09/release-1.8.0.html</link>
-<guid isPermaLink="true">/news/2019/04/09/release-1.8.0.html</guid>
-</item>
-
</channel>
</rss>
diff --git a/content/blog/index.html b/content/blog/index.html
index 95f43a3..5175567 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -227,6 +227,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4 Release
Announcement</a></h2>
+
+ <p>11 Mar 2022
+ Konstantin Knauf (<a
href="https://twitter.com/snntrable";>@snntrable</a>)</p>
+
+ <p>The Apache Flink Community is please to announce another bug fix
release for Flink 1.14.</p>
+
+ <p><a href="/news/2022/03/11/release-1.14.4.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/2022/02/22/scala-free.html">Scala Free
in One Fifteen</a></h2>
<p>22 Feb 2022
@@ -240,14 +253,14 @@
<hr>
<article>
- <h2 class="blog-title"><a
href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6 Release
Announcement</a></h2>
+ <h2 class="blog-title"><a
href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6 Release
Announcement</a></h2>
- <p>09 Feb 2022
+ <p>18 Feb 2022
Konstantin Knauf (<a
href="https://twitter.com/snntrable";>@snntrable</a>)</p>
<p>The Apache Flink Community is please to announce another bug fix
release for Flink 1.13.</p>
- <p><a href="/news/2022/02/09/release-1.13.6.html">Continue reading
»</a></p>
+ <p><a href="/news/2022/02/18/release-1.13.6.html">Continue reading
»</a></p>
</article>
<hr>
@@ -348,21 +361,6 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2021/12/16/log4j-patch-releases.html">Apache Flink Log4j emergency
releases</a></h2>
-
- <p>16 Dec 2021
- Chesnay Schepler </p>
-
- <p><p>The Apache Flink community has released emergency bugfix versions
of Apache Flink for the 1.11, 1.12, 1.13 and 1.14 series.</p>
-
-</p>
-
- <p><a href="/news/2021/12/16/log4j-patch-releases.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -395,6 +393,16 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -405,7 +413,7 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page10/index.html b/content/blog/page10/index.html
index 93c044d..fbb392e 100644
--- a/content/blog/page10/index.html
+++ b/content/blog/page10/index.html
@@ -227,6 +227,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2019/09/10/community-update.html">Flink Community Update -
September'19</a></h2>
+
+ <p>10 Sep 2019
+ Marta Paes (<a href="https://twitter.com/morsapaes";>@morsapaes</a>)</p>
+
+ <p>This has been an exciting, fast-paced year for the Apache Flink
community. But with over 10k messages across the mailing lists, 3k Jira tickets
and 2k pull requests, it is not easy to keep up with the latest state of the
project. Plus everything happening around it. With that in mind, we want to
bring back regular community updates to the Flink blog.</p>
+
+ <p><a href="/news/2019/09/10/community-update.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2019/08/22/release-1.9.0.html">Apache Flink 1.9.0 Release
Announcement</a></h2>
<p>22 Aug 2019
@@ -350,25 +363,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release
Announcement</a></h2>
-
- <p>09 Apr 2019
- Aljoscha Krettek (<a
href="https://twitter.com/aljoscha";>@aljoscha</a>)</p>
-
- <p><p>The Apache Flink community is pleased to announce Apache Flink
1.8.0. The
-latest release includes more than 420 resolved issues and some exciting
-additions to Flink that we describe in the following sections of this post.
-Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274";>complete
changelog</a>
-for more details.</p>
-
-</p>
-
- <p><a href="/news/2019/04/09/release-1.8.0.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -401,6 +395,16 @@ for more details.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -411,7 +415,7 @@ for more details.</p>
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page11/index.html b/content/blog/page11/index.html
index 6b9ac4d..d75f849 100644
--- a/content/blog/page11/index.html
+++ b/content/blog/page11/index.html
@@ -227,6 +227,25 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release
Announcement</a></h2>
+
+ <p>09 Apr 2019
+ Aljoscha Krettek (<a
href="https://twitter.com/aljoscha";>@aljoscha</a>)</p>
+
+ <p><p>The Apache Flink community is pleased to announce Apache Flink
1.8.0. The
+latest release includes more than 420 resolved issues and some exciting
+additions to Flink that we describe in the following sections of this post.
+Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274";>complete
changelog</a>
+for more details.</p>
+
+</p>
+
+ <p><a href="/news/2019/04/09/release-1.8.0.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus:
Cloud-native monitoring of streaming applications</a></h2>
<p>11 Mar 2019
@@ -353,23 +372,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2018/11/30/release-1.7.0.html">Apache Flink 1.7.0 Release
Announcement</a></h2>
-
- <p>30 Nov 2018
- Till Rohrmann (<a href="https://twitter.com/stsffap";>@stsffap</a>)</p>
-
- <p><p>The Apache Flink community is pleased to announce Apache Flink
1.7.0.
-The latest release includes more than 420 resolved issues and some exciting
additions to Flink that we describe in the following sections of this post.
-Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12343585";>complete
changelog</a> for more details.</p>
-
-</p>
-
- <p><a href="/news/2018/11/30/release-1.7.0.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -402,6 +404,16 @@ Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -412,7 +424,7 @@ Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page12/index.html b/content/blog/page12/index.html
index 48ef50b..d2ba4d3 100644
--- a/content/blog/page12/index.html
+++ b/content/blog/page12/index.html
@@ -227,6 +227,23 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2018/11/30/release-1.7.0.html">Apache Flink 1.7.0 Release
Announcement</a></h2>
+
+ <p>30 Nov 2018
+ Till Rohrmann (<a href="https://twitter.com/stsffap";>@stsffap</a>)</p>
+
+ <p><p>The Apache Flink community is pleased to announce Apache Flink
1.7.0.
+The latest release includes more than 420 resolved issues and some exciting
additions to Flink that we describe in the following sections of this post.
+Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12343585";>complete
changelog</a> for more details.</p>
+
+</p>
+
+ <p><a href="/news/2018/11/30/release-1.7.0.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2018/10/29/release-1.6.2.html">Apache Flink 1.6.2 Released</a></h2>
<p>29 Oct 2018
@@ -361,21 +378,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2018/03/15/release-1.3.3.html">Apache Flink 1.3.3 Released</a></h2>
-
- <p>15 Mar 2018
- </p>
-
- <p><p>The Apache Flink community released the third bugfix version of
the Apache Flink 1.3 series.</p>
-
-</p>
-
- <p><a href="/news/2018/03/15/release-1.3.3.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -408,6 +410,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -418,7 +430,7 @@
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page13/index.html b/content/blog/page13/index.html
index cb31c65..c7f151f 100644
--- a/content/blog/page13/index.html
+++ b/content/blog/page13/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2018/03/15/release-1.3.3.html">Apache Flink 1.3.3 Released</a></h2>
+
+ <p>15 Mar 2018
+ </p>
+
+ <p><p>The Apache Flink community released the third bugfix version of
the Apache Flink 1.3 series.</p>
+
+</p>
+
+ <p><a href="/news/2018/03/15/release-1.3.3.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2018/03/08/release-1.4.2.html">Apache Flink 1.4.2 Released</a></h2>
<p>08 Mar 2018
@@ -358,21 +373,6 @@ what’s coming in Flink 1.4.0 as well as a preview of what
the Flink community
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2017/06/23/release-1.3.1.html">Apache Flink 1.3.1 Released</a></h2>
-
- <p>23 Jun 2017
- </p>
-
- <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.3 series.</p>
-
-</p>
-
- <p><a href="/news/2017/06/23/release-1.3.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -405,6 +405,16 @@ 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/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -415,7 +425,7 @@ what’s coming in Flink 1.4.0 as well as a preview of what
the Flink community
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page14/index.html b/content/blog/page14/index.html
index 982770e..d5ce516 100644
--- a/content/blog/page14/index.html
+++ b/content/blog/page14/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2017/06/23/release-1.3.1.html">Apache Flink 1.3.1 Released</a></h2>
+
+ <p>23 Jun 2017
+ </p>
+
+ <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.3 series.</p>
+
+</p>
+
+ <p><a href="/news/2017/06/23/release-1.3.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2017/06/01/release-1.3.0.html">Apache Flink 1.3.0 Release
Announcement</a></h2>
<p>01 Jun 2017 by Robert Metzger (<a
href="https://twitter.com/";>@rmetzger_</a>)
@@ -354,21 +369,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2016/10/12/release-1.1.3.html">Apache Flink 1.1.3 Released</a></h2>
-
- <p>12 Oct 2016
- </p>
-
- <p><p>The Apache Flink community released the next bugfix version of the
Apache Flink 1.1. series.</p>
-
-</p>
-
- <p><a href="/news/2016/10/12/release-1.1.3.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -401,6 +401,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -411,7 +421,7 @@
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page15/index.html b/content/blog/page15/index.html
index c2efe24..4c2021a 100644
--- a/content/blog/page15/index.html
+++ b/content/blog/page15/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2016/10/12/release-1.1.3.html">Apache Flink 1.1.3 Released</a></h2>
+
+ <p>12 Oct 2016
+ </p>
+
+ <p><p>The Apache Flink community released the next bugfix version of the
Apache Flink 1.1. series.</p>
+
+</p>
+
+ <p><a href="/news/2016/10/12/release-1.1.3.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2016/09/05/release-1.1.2.html">Apache Flink 1.1.2 Released</a></h2>
<p>05 Sep 2016
@@ -358,21 +373,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2016/04/06/release-1.0.1.html">Flink 1.0.1 Released</a></h2>
-
- <p>06 Apr 2016
- </p>
-
- <p><p>Today, the Flink community released Flink version
<strong>1.0.1</strong>, the first bugfix release of the 1.0 series.</p>
-
-</p>
-
- <p><a href="/news/2016/04/06/release-1.0.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -405,6 +405,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -415,7 +425,7 @@
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page16/index.html b/content/blog/page16/index.html
index 501531c..908a360 100644
--- a/content/blog/page16/index.html
+++ b/content/blog/page16/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2016/04/06/release-1.0.1.html">Flink 1.0.1 Released</a></h2>
+
+ <p>06 Apr 2016
+ </p>
+
+ <p><p>Today, the Flink community released Flink version
<strong>1.0.1</strong>, the first bugfix release of the 1.0 series.</p>
+
+</p>
+
+ <p><a href="/news/2016/04/06/release-1.0.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2016/03/08/release-1.0.0.html">Announcing Apache Flink
1.0.0</a></h2>
<p>08 Mar 2016
@@ -359,21 +374,6 @@ Apache Flink started.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2015/09/01/release-0.9.1.html">Apache Flink 0.9.1 available</a></h2>
-
- <p>01 Sep 2015
- </p>
-
- <p><p>The Flink community is happy to announce that Flink 0.9.1 is now
available.</p>
-
-</p>
-
- <p><a href="/news/2015/09/01/release-0.9.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -406,6 +406,16 @@ Apache Flink started.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -416,7 +426,7 @@ Apache Flink started.</p>
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page17/index.html b/content/blog/page17/index.html
index e302786..cee69c4 100644
--- a/content/blog/page17/index.html
+++ b/content/blog/page17/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2015/09/01/release-0.9.1.html">Apache Flink 0.9.1 available</a></h2>
+
+ <p>01 Sep 2015
+ </p>
+
+ <p><p>The Flink community is happy to announce that Flink 0.9.1 is now
available.</p>
+
+</p>
+
+ <p><a href="/news/2015/09/01/release-0.9.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2015/08/24/introducing-flink-gelly.html">Introducing Gelly: Graph
Processing with Apache Flink</a></h2>
<p>24 Aug 2015
@@ -371,21 +386,6 @@ and offers a new API including definition of flexible
windows.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2015/02/04/january-in-flink.html">January 2015 in the Flink
community</a></h2>
-
- <p>04 Feb 2015
- </p>
-
- <p><p>Happy 2015! Here is a (hopefully digestible) summary of what
happened last month in the Flink community.</p>
-
-</p>
-
- <p><a href="/news/2015/02/04/january-in-flink.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -418,6 +418,16 @@ and offers a new API including definition of flexible
windows.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -428,7 +438,7 @@ and offers a new API including definition of flexible
windows.</p>
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page18/index.html b/content/blog/page18/index.html
index befe500..af6ef16 100644
--- a/content/blog/page18/index.html
+++ b/content/blog/page18/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2015/02/04/january-in-flink.html">January 2015 in the Flink
community</a></h2>
+
+ <p>04 Feb 2015
+ </p>
+
+ <p><p>Happy 2015! Here is a (hopefully digestible) summary of what
happened last month in the Flink community.</p>
+
+</p>
+
+ <p><a href="/news/2015/02/04/january-in-flink.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2015/01/21/release-0.8.html">Apache Flink 0.8.0 available</a></h2>
<p>21 Jan 2015
@@ -366,6 +381,16 @@ academic and open source project that Flink originates
from.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -376,7 +401,7 @@ academic and open source project that Flink originates
from.</p>
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index e1e7c31..b236081 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2021/12/16/log4j-patch-releases.html">Apache Flink Log4j emergency
releases</a></h2>
+
+ <p>16 Dec 2021
+ Chesnay Schepler </p>
+
+ <p><p>The Apache Flink community has released emergency bugfix versions
of Apache Flink for the 1.11, 1.12, 1.13 and 1.14 series.</p>
+
+</p>
+
+ <p><a href="/news/2021/12/16/log4j-patch-releases.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/2021/12/10/log4j-cve.html">Advise on
Apache Log4j Zero Day (CVE-2021-44228)</a></h2>
<p>10 Dec 2021
@@ -352,28 +367,6 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2021/08/31/release-1.14.0-rc0.html">Help us stabilize Apache Flink
1.14.0 RC0</a></h2>
-
- <p>31 Aug 2021
- Johannes Moser </p>
-
- <p><div class="note">
- <h5>Hint</h5>
- <p>
- Update 29th of September: Today
- <a
href="https://flink.apache.org/news/2021/09/29/release-1.14.0.html";>Apache
Flink 1.14</a>
- has been released. For sure we'd still like to hear your feedback.
- </p>
-</div>
-
-</p>
-
- <p><a href="/news/2021/08/31/release-1.14.0-rc0.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -406,6 +399,16 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -416,7 +419,7 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index f64dd11..c63f931 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -227,6 +227,28 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2021/08/31/release-1.14.0-rc0.html">Help us stabilize Apache Flink
1.14.0 RC0</a></h2>
+
+ <p>31 Aug 2021
+ Johannes Moser </p>
+
+ <p><div class="note">
+ <h5>Hint</h5>
+ <p>
+ Update 29th of September: Today
+ <a
href="https://flink.apache.org/news/2021/09/29/release-1.14.0.html";>Apache
Flink 1.14</a>
+ has been released. For sure we'd still like to hear your feedback.
+ </p>
+</div>
+
+</p>
+
+ <p><a href="/news/2021/08/31/release-1.14.0-rc0.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2021/08/09/release-1.11.4.html">Apache Flink 1.11.4
Released</a></h2>
<p>09 Aug 2021
@@ -355,23 +377,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2021/04/15/release-statefun-3.0.0.html">Stateful Functions 3.0.0:
Remote Functions Front and Center</a></h2>
-
- <p>15 Apr 2021
- Igal Shilman (<a
href="https://twitter.com/IgalShilman";>@IgalShilman</a>) & Tzu-Li (Gordon)
Tai (<a href="https://twitter.com/tzulitai";>@tzulitai</a>)</p>
-
- <p><p>The Apache Flink community is happy to announce the release of
Stateful Functions (StateFun) 3.0.0!
-Stateful Functions is a cross-platform stack for building Stateful Serverless
applications, making it radically simpler
-to develop scalable, consistent, and elastic distributed applications.</p>
-
-</p>
-
- <p><a href="/news/2021/04/15/release-statefun-3.0.0.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -404,6 +409,16 @@ to develop scalable, consistent, and elastic distributed
applications.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -414,7 +429,7 @@ to develop scalable, consistent, and elastic distributed
applications.</p>
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index a9e0d42..a9ca204 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -227,6 +227,23 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2021/04/15/release-statefun-3.0.0.html">Stateful Functions 3.0.0:
Remote Functions Front and Center</a></h2>
+
+ <p>15 Apr 2021
+ Igal Shilman (<a
href="https://twitter.com/IgalShilman";>@IgalShilman</a>) & Tzu-Li (Gordon)
Tai (<a href="https://twitter.com/tzulitai";>@tzulitai</a>)</p>
+
+ <p><p>The Apache Flink community is happy to announce the release of
Stateful Functions (StateFun) 3.0.0!
+Stateful Functions is a cross-platform stack for building Stateful Serverless
applications, making it radically simpler
+to develop scalable, consistent, and elastic distributed applications.</p>
+
+</p>
+
+ <p><a href="/news/2021/04/15/release-statefun-3.0.0.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/2021/03/11/batch-execution-mode.html">A
Rundown of Batch Execution Mode in the DataStream API</a></h2>
<p>11 Mar 2021
@@ -351,21 +368,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3
Released</a></h2>
-
- <p>18 Dec 2020
- Xintong Song </p>
-
- <p><p>The Apache Flink community released the third bugfix version of
the Apache Flink 1.11 series.</p>
-
-</p>
-
- <p><a href="/news/2020/12/18/release-1.11.3.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -398,6 +400,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -408,7 +420,7 @@
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html
index 50e2528..be0368a 100644
--- a/content/blog/page5/index.html
+++ b/content/blog/page5/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3
Released</a></h2>
+
+ <p>18 Dec 2020
+ Xintong Song </p>
+
+ <p><p>The Apache Flink community released the third bugfix version of
the Apache Flink 1.11 series.</p>
+
+</p>
+
+ <p><a href="/news/2020/12/18/release-1.11.3.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task
scheduling for batch workloads in Apache Flink 1.12</a></h2>
<p>15 Dec 2020
@@ -353,21 +368,6 @@ as well as increased observability for operational
purposes.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/08/25/release-1.10.2.html">Apache Flink 1.10.2
Released</a></h2>
-
- <p>25 Aug 2020
- Zhu Zhu (<a href="https://twitter.com/zhuzhv";>@zhuzhv</a>)</p>
-
- <p><p>The Apache Flink community released the second bugfix version of
the Apache Flink 1.10 series.</p>
-
-</p>
-
- <p><a href="/news/2020/08/25/release-1.10.2.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -400,6 +400,16 @@ as well as increased observability for operational
purposes.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -410,7 +420,7 @@ as well as increased observability for operational
purposes.</p>
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page6/index.html b/content/blog/page6/index.html
index ed2743e..81f1ef1 100644
--- a/content/blog/page6/index.html
+++ b/content/blog/page6/index.html
@@ -227,6 +227,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/08/25/release-1.10.2.html">Apache Flink 1.10.2
Released</a></h2>
+
+ <p>25 Aug 2020
+ Zhu Zhu (<a href="https://twitter.com/zhuzhv";>@zhuzhv</a>)</p>
+
+ <p><p>The Apache Flink community released the second bugfix version of
the Apache Flink 1.10 series.</p>
+
+</p>
+
+ <p><a href="/news/2020/08/25/release-1.10.2.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/news/2020/08/20/flink-docker.html">The
State of Flink on Docker</a></h2>
<p>20 Aug 2020
@@ -349,26 +364,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/07/14/application-mode.html">Application Deployment in Flink:
Current State and the new Application Mode</a></h2>
-
- <p>14 Jul 2020
- Kostas Kloudas (<a
href="https://twitter.com/kkloudas";>@kkloudas</a>)</p>
-
- <p><p>With the rise of stream processing and real-time analytics as a
critical tool for modern
-businesses, an increasing number of organizations build platforms with Apache
Flink at their
-core and offer it internally as a service. Many talks with related topics from
companies
-like <a href="https://www.youtube.com/watch?v=VX3S9POGAdU";>Uber</a>, <a
href="https://www.youtube.com/watch?v=VX3S9POGAdU";>Netflix</a>
-and <a href="https://www.youtube.com/watch?v=cH9UdK0yYjc";>Alibaba</a> in the
latest editions of Flink Forward further
-illustrate this trend.</p>
-
-</p>
-
- <p><a href="/news/2020/07/14/application-mode.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -401,6 +396,16 @@ illustrate this trend.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -411,7 +416,7 @@ illustrate this trend.</p>
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page7/index.html b/content/blog/page7/index.html
index e491862..9a71d79 100644
--- a/content/blog/page7/index.html
+++ b/content/blog/page7/index.html
@@ -227,6 +227,26 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/07/14/application-mode.html">Application Deployment in Flink:
Current State and the new Application Mode</a></h2>
+
+ <p>14 Jul 2020
+ Kostas Kloudas (<a
href="https://twitter.com/kkloudas";>@kkloudas</a>)</p>
+
+ <p><p>With the rise of stream processing and real-time analytics as a
critical tool for modern
+businesses, an increasing number of organizations build platforms with Apache
Flink at their
+core and offer it internally as a service. Many talks with related topics from
companies
+like <a href="https://www.youtube.com/watch?v=VX3S9POGAdU";>Uber</a>, <a
href="https://www.youtube.com/watch?v=VX3S9POGAdU";>Netflix</a>
+and <a href="https://www.youtube.com/watch?v=cH9UdK0yYjc";>Alibaba</a> in the
latest editions of Flink Forward further
+illustrate this trend.</p>
+
+</p>
+
+ <p><a href="/news/2020/07/14/application-mode.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2020/07/06/release-1.11.0.html">Apache Flink 1.11.0 Release
Announcement</a></h2>
<p>06 Jul 2020
@@ -356,19 +376,6 @@ and provide a tutorial for running Streaming ETL with
Flink on Zeppelin.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/04/21/memory-management-improvements-flink-1.10.html">Memory
Management Improvements with Apache Flink 1.10</a></h2>
-
- <p>21 Apr 2020
- Andrey Zagrebin </p>
-
- <p>This post discusses the recent changes to the memory model of the
Task Managers and configuration options for your Flink applications in Flink
1.10.</p>
-
- <p><a
href="/news/2020/04/21/memory-management-improvements-flink-1.10.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -401,6 +408,16 @@ and provide a tutorial for running Streaming ETL with
Flink on Zeppelin.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -411,7 +428,7 @@ and provide a tutorial for running Streaming ETL with Flink
on Zeppelin.</p>
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page8/index.html b/content/blog/page8/index.html
index e0517a7..0f5aa19 100644
--- a/content/blog/page8/index.html
+++ b/content/blog/page8/index.html
@@ -227,6 +227,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/04/21/memory-management-improvements-flink-1.10.html">Memory
Management Improvements with Apache Flink 1.10</a></h2>
+
+ <p>21 Apr 2020
+ Andrey Zagrebin </p>
+
+ <p>This post discusses the recent changes to the memory model of the
Task Managers and configuration options for your Flink applications in Flink
1.10.</p>
+
+ <p><a
href="/news/2020/04/21/memory-management-improvements-flink-1.10.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2020/04/15/flink-serialization-tuning-vol-1.html">Flink
Serialization Tuning Vol. 1: Choosing your Serializer — if you can</a></h2>
<p>15 Apr 2020
@@ -350,19 +363,6 @@ This release marks a big milestone: Stateful Functions 2.0
is not only an API up
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html">A Guide
for Unit Testing in Apache Flink</a></h2>
-
- <p>07 Feb 2020
- Kartik Khare (<a
href="https://twitter.com/khare_khote";>@khare_khote</a>)</p>
-
- <p>This post provides a detailed guide for unit testing of Apache Flink
applications.</p>
-
- <p><a
href="/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -395,6 +395,16 @@ This release marks a big milestone: Stateful Functions 2.0
is not only an API up
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -405,7 +415,7 @@ This release marks a big milestone: Stateful Functions 2.0
is not only an API up
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/blog/page9/index.html b/content/blog/page9/index.html
index b7dc86b..65a221e 100644
--- a/content/blog/page9/index.html
+++ b/content/blog/page9/index.html
@@ -227,6 +227,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html">A Guide
for Unit Testing in Apache Flink</a></h2>
+
+ <p>07 Feb 2020
+ Kartik Khare (<a
href="https://twitter.com/khare_khote";>@khare_khote</a>)</p>
+
+ <p>This post provides a detailed guide for unit testing of Apache Flink
applications.</p>
+
+ <p><a
href="/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2020/01/30/release-1.9.2.html">Apache Flink 1.9.2 Released</a></h2>
<p>30 Jan 2020
@@ -351,19 +364,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2019/09/10/community-update.html">Flink Community Update -
September'19</a></h2>
-
- <p>10 Sep 2019
- Marta Paes (<a href="https://twitter.com/morsapaes";>@morsapaes</a>)</p>
-
- <p>This has been an exciting, fast-paced year for the Apache Flink
community. But with over 10k messages across the mailing lists, 3k Jira tickets
and 2k pull requests, it is not easy to keep up with the latest state of the
project. Plus everything happening around it. With that in mind, we want to
bring back regular community updates to the Flink blog.</p>
-
- <p><a href="/news/2019/09/10/community-update.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -396,6 +396,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/03/11/release-1.14.4.html">Apache Flink 1.14.4
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></li>
@@ -406,7 +416,7 @@
- <li><a href="/news/2022/02/09/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
+ <li><a href="/news/2022/02/18/release-1.13.6.html">Apache Flink 1.13.6
Release Announcement</a></li>
diff --git a/content/downloads.html b/content/downloads.html
index 8c2742f..17f440e 100644
--- a/content/downloads.html
+++ b/content/downloads.html
@@ -226,7 +226,7 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#apache-flink-1143" id="markdown-toc-apache-flink-1143">Apache
Flink 1.14.3</a></li>
+ <li><a href="#apache-flink-1144" id="markdown-toc-apache-flink-1144">Apache
Flink 1.14.4</a></li>
<li><a href="#apache-flink-1136" id="markdown-toc-apache-flink-1136">Apache
Flink 1.13.6</a></li>
<li><a href="#apache-flink-1127" id="markdown-toc-apache-flink-1127">Apache
Flink 1.12.7</a></li>
<li><a href="#apache-flink-1116" id="markdown-toc-apache-flink-1116">Apache
Flink 1.11.6</a></li>
@@ -252,21 +252,21 @@
</div>
-<p>Apache Flink® 1.14.3 is our latest stable release.</p>
+<p>Apache Flink® 1.14.4 is our latest stable release.</p>
-<h2 id="apache-flink-1143">Apache Flink 1.14.3</h2>
+<h2 id="apache-flink-1144">Apache Flink 1.14.4</h2>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz";
id="1142-download_211">Apache Flink 1.14.3 for Scala 2.11</a> (<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz";
id="1144-download_211">Apache Flink 1.14.4 for Scala 2.11</a> (<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz";
id="1142-download_212">Apache Flink 1.14.3 for Scala 2.12</a> (<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz";
id="1144-download_212">Apache Flink 1.14.4 for Scala 2.12</a> (<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-src.tgz";
id="1142-download-source">Apache Flink 1.14.3 Source Release</a>
-(<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-src.tgz";
id="1144-download-source">Apache Flink 1.14.4 Source Release</a>
+(<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-src.tgz.sha512";>sha512</a>)
</p>
<h4 id="release-notes">Release Notes</h4>
@@ -411,17 +411,17 @@ main Flink release:</p>
<div class="highlight"><pre><code class="language-xml"><span
class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-java<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3>
@@ -486,6 +486,17 @@ The <code>statefun-flink-harness</code> dependency
includes a local execution en
<li>
+Flink 1.14.4 - 2022-03-02
+(<a
href="https://archive.apache.org/dist/flink/flink-1.14.4/flink-1.14.4-src.tgz";>Source</a>,
+<a href="https://archive.apache.org/dist/flink/flink-1.14.4";>Binaries</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.14";>Docs</a>,
+<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.14/api/java";>Javadocs</a>,
+<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.14/api/scala/index.html";>Scaladocs</a>)
+
+</li>
+
+<li>
+
Flink 1.14.3 - 2022-01-17
(<a
href="https://archive.apache.org/dist/flink/flink-1.14.3/flink-1.14.3-src.tgz";>Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.14.3";>Binaries</a>,
@@ -519,7 +530,7 @@ Flink 1.14.0 - 2021-09-29
<li>
-Flink 1.13.6 - 2022-02-09
+Flink 1.13.6 - 2022-02-18
(<a
href="https://archive.apache.org/dist/flink/flink-1.13.6/flink-1.13.6-src.tgz";>Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.13.6";>Binaries</a>,
<a href="https://nightlies.apache.org/flink/flink-docs-release-1.13";>Docs</a>,
diff --git a/content/index.html b/content/index.html
index ec1d7dc..8f589c9 100644
--- a/content/index.html
+++ b/content/index.html
@@ -391,10 +391,13 @@
<dl>
+ <dt> <a href="/news/2022/03/11/release-1.14.4.html">Apache Flink
1.14.4 Release Announcement</a></dt>
+ <dd>The Apache Flink Community is please to announce another bug fix
release for Flink 1.14.</dd>
+
<dt> <a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></dt>
<dd>Apache Flink's runtime is now Scala free, allowing users to
leverage any Scala version in their user code - including Scala 3!</dd>
- <dt> <a href="/news/2022/02/09/release-1.13.6.html">Apache Flink
1.13.6 Release Announcement</a></dt>
+ <dt> <a href="/news/2022/02/18/release-1.13.6.html">Apache Flink
1.13.6 Release Announcement</a></dt>
<dd>The Apache Flink Community is please to announce another bug fix
release for Flink 1.13.</dd>
<dt> <a href="/news/2022/01/31/release-statefun-3.2.0.html">Stateful
Functions 3.2.0 Release Announcement</a></dt>
@@ -405,9 +408,6 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
<dt> <a href="/2022/01/20/pravega-connector-101.html">Pravega Flink
Connector 101</a></dt>
<dd>A brief introduction to the Pravega Flink Connector</dd>
-
- <dt> <a href="/news/2022/01/17/release-1.14.3.html">Apache Flink
1.14.3 Release Announcement</a></dt>
- <dd>The Apache Flink community released the second bugfix version of
the Apache Flink 1.14 series.</dd>
</dl>
diff --git a/content/news/2022/02/09/release-1.13.6.html
b/content/news/2022/02/18/release-1.13.6.html
similarity index 99%
copy from content/news/2022/02/09/release-1.13.6.html
copy to content/news/2022/02/18/release-1.13.6.html
index 518a96f..e4953ca 100644
--- a/content/news/2022/02/09/release-1.13.6.html
+++ b/content/news/2022/02/18/release-1.13.6.html
@@ -226,7 +226,7 @@
<p><i></i></p>
<article>
- <p>09 Feb 2022 Konstantin Knauf (<a
href="https://twitter.com/snntrable";>@snntrable</a>)</p>
+ <p>18 Feb 2022 Konstantin Knauf (<a
href="https://twitter.com/snntrable";>@snntrable</a>)</p>
<p>The Apache Flink Community is pleased to announce another bug fix release
for Flink 1.13.</p>
diff --git a/content/news/2022/02/09/release-1.13.6.html
b/content/news/2022/03/11/release-1.14.4.html
similarity index 64%
rename from content/news/2022/02/09/release-1.13.6.html
rename to content/news/2022/03/11/release-1.14.4.html
index 518a96f..4d75e13 100644
--- a/content/news/2022/02/09/release-1.13.6.html
+++ b/content/news/2022/03/11/release-1.14.4.html
@@ -5,7 +5,7 @@
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<meta name="viewport" content="width=device-width, initial-scale=1">
<!-- The above 3 meta tags *must* come first in the head; any other head
content must come *after* these tags -->
- <title>Apache Flink: Apache Flink 1.13.6 Release Announcement</title>
+ <title>Apache Flink: Apache Flink 1.14.4 Release Announcement</title>
<link rel="shortcut icon" href="/favicon.ico" type="image/x-icon">
<link rel="icon" href="/favicon.ico" type="image/x-icon">
@@ -222,19 +222,19 @@
<div class="row-fluid">
<div class="col-sm-12">
<div class="row">
- <h1>Apache Flink 1.13.6 Release Announcement</h1>
+ <h1>Apache Flink 1.14.4 Release Announcement</h1>
<p><i></i></p>
<article>
- <p>09 Feb 2022 Konstantin Knauf (<a
href="https://twitter.com/snntrable";>@snntrable</a>)</p>
+ <p>11 Mar 2022 Konstantin Knauf (<a
href="https://twitter.com/snntrable";>@snntrable</a>)</p>
-<p>The Apache Flink Community is pleased to announce another bug fix release
for Flink 1.13.</p>
+<p>The Apache Flink Community is pleased to announce another bug fix release
for Flink 1.14.</p>
-<p>This release includes 99 bug and vulnerability fixes and minor improvements
for Flink 1.13 including another upgrade of Apache Log4j (to 2.17.1).
+<p>This release includes 51 bug and vulnerability fixes and minor improvements
for Flink 1.14.
Below you will find a list of all bugfixes and improvements (excluding
improvements to the build infrastructure and build stability). For a complete
list of all changes see:
<a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12351074";>JIRA</a>.</p>
-<p>We highly recommend all users to upgrade to Flink 1.13.6.</p>
+<p>We highly recommend all users to upgrade to Flink 1.14.4.</p>
<h1 id="release-artifacts">Release Artifacts</h1>
@@ -243,17 +243,17 @@ Below you will find a list of all bugfixes and
improvements (excluding improveme
<div class="highlight"><pre><code class="language-xml"><span
class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-java<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.13.6<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.13.6<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.13.6<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h2 id="binaries">Binaries</h2>
@@ -263,159 +263,127 @@ Below you will find a list of all bugfixes and
improvements (excluding improveme
<h2 id="docker-images">Docker Images</h2>
<ul>
- <li><a
href="https://hub.docker.com/_/flink?tab=tags&page=1&name=1.13.6";>library/flink</a>
(official images)</li>
- <li><a
href="https://hub.docker.com/r/apache/flink/tags?page=1&name=1.13.6";>apache/flink</a>
(ASF repository)</li>
+ <li><a
href="https://hub.docker.com/_/flink?tab=tags&page=1&name=1.14.4";>library/flink</a>
(official images)</li>
+ <li><a
href="https://hub.docker.com/r/apache/flink/tags?page=1&name=1.14.4";>apache/flink</a>
(ASF repository)</li>
</ul>
<h2 id="pypi">PyPi</h2>
<ul>
- <li><a
href="https://pypi.org/project/apache-flink/1.13.6/";>apache-flink==1.13.6</a></li>
+ <li><a
href="https://pypi.org/project/apache-flink/1.14.4/";>apache-flink==1.14.4</a></li>
</ul>
<h1 id="release-notes">Release Notes</h1>
-<h2> Bug
+<h2> Sub-task
</h2>
<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-15987";>FLINK-15987</a>] -
SELECT 1.0e0 / 0.0e0 throws NumberFormatException
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21788";>FLINK-21788</a>] -
Throw PartitionNotFoundException if the partition file has been lost for
blocking shuffle
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-17914";>FLINK-17914</a>] -
HistoryServer deletes cached archives if archive listing fails
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24954";>FLINK-24954</a>] -
Reset read buffer request timeout on buffer recycling for sort-shuffle
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20195";>FLINK-20195</a>] -
Jobs endpoint returns duplicated jobs
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25653";>FLINK-25653</a>] -
Move buffer recycle in SortMergeSubpartitionReader out of lock to avoid
deadlock
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20370";>FLINK-20370</a>] -
Result is wrong when sink primary key is not the same with query
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25654";>FLINK-25654</a>] -
Remove the redundant lock in SortMergeResultPartition
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21289";>FLINK-21289</a>] -
Application mode ignores the pipeline.classpaths configuration
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25879";>FLINK-25879</a>] -
Track used search terms in Matomo
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23919";>FLINK-23919</a>] -
PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for
Window TVF
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25880";>FLINK-25880</a>] -
Implement Matomo in Flink documentation
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24232";>FLINK-24232</a>] -
Archiving of suspended jobs prevents breaks subsequent archive attempts
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24255";>FLINK-24255</a>] -
Test Environment / Mini Cluster do not forward configuration.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24310";>FLINK-24310</a>] -
A bug in the BufferingSink example in the doc
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21752";>FLINK-21752</a>] -
NullPointerException on restore in PojoSerializer
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24318";>FLINK-24318</a>] -
Casting a number to boolean has different results between 'select'
fields and 'where' condition
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23946";>FLINK-23946</a>] -
Application mode fails fatally when being shut down
</li>
<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24334";>FLINK-24334</a>] -
Configuration kubernetes.flink.log.dir not working
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24366";>FLINK-24366</a>] -
Unnecessary/misleading error message about failing restores when tasks are
already canceled.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24401";>FLINK-24401</a>] -
TM cannot exit after Metaspace OOM
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24465";>FLINK-24465</a>] -
Wrong javadoc and documentation for buffer timeout
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24492";>FLINK-24492</a>] -
incorrect implicit type conversion between numeric and (var)char
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24506";>FLINK-24506</a>] -
checkpoint directory is not configurable through the Flink configuration
passed into the StreamExecutionEnvironment
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24509";>FLINK-24509</a>] -
FlinkKafkaProducer example is not compiling due to incorrect constructer
signature used
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24540";>FLINK-24540</a>] -
Fix Resource leak due to Files.list
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24543";>FLINK-24543</a>] -
Zookeeper connection issue causes inconsistent state in Flink
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24407";>FLINK-24407</a>] -
Pulsar connector chinese document link to Pulsar document location
incorrectly.
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24563";>FLINK-24563</a>] -
Comparing timstamp_ltz with random string throws NullPointerException
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24607";>FLINK-24607</a>] -
SourceCoordinator may miss to close SplitEnumerator when failover frequently
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24597";>FLINK-24597</a>] -
RocksdbStateBackend getKeysAndNamespaces would return duplicate data when
using MapState
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25171";>FLINK-25171</a>] -
When the DDL statement was executed, the column names of the Derived
Columns were not validated
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24621";>FLINK-24621</a>] -
JobManager fails to recover 1.13.1 checkpoint due to
InflightDataRescalingDescriptor
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24662";>FLINK-24662</a>] -
PyFlink sphinx check failed with "node class 'meta' is already
registered, its visitors will be overridden"
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24667";>FLINK-24667</a>] -
Channel state writer would fail the task directly if meeting exception
previously
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24676";>FLINK-24676</a>] -
Schema does not match if explain insert statement with partial column
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24678";>FLINK-24678</a>] -
Correct the metric name of map state contains latency
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24708";>FLINK-24708</a>] -
`ConvertToNotInOrInRule` has a bug which leads to wrong result
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24728";>FLINK-24728</a>] -
Batch SQL file sink forgets to close the output stream
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24761";>FLINK-24761</a>] -
Fix PartitionPruner code gen compile fail
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25199";>FLINK-25199</a>] -
StreamEdges are not unique in self-union, which blocks propagation of
watermarks
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24846";>FLINK-24846</a>] -
AsyncWaitOperator fails during stop-with-savepoint
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25362";>FLINK-25362</a>] -
Incorrect dependencies in Table Confluent/Avro docs
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24860";>FLINK-24860</a>] -
Fix the wrong position mappings in the Python UDTF
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25407";>FLINK-25407</a>] -
Network stack deadlock when cancellation happens during initialisation
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24885";>FLINK-24885</a>] -
ProcessElement Interface parameter Collector :
java.lang.NullPointerException
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25466";>FLINK-25466</a>] -
TTL configuration could parse in StateTtlConfig#DISABLED
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24922";>FLINK-24922</a>] -
Fix spelling errors in the word "parallism"
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25486";>FLINK-25486</a>] -
Perjob can not recover from checkpoint when zookeeper leader changes
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25022";>FLINK-25022</a>] -
ClassLoader leak with ThreadLocals on the JM when submitting a job through
the REST API
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25494";>FLINK-25494</a>] -
Duplicate element serializer during
DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25067";>FLINK-25067</a>] -
Correct the description of RocksDB's background threads
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25678";>FLINK-25678</a>] -
TaskExecutorStateChangelogStoragesManager.shutdown is not thread-safe
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25084";>FLINK-25084</a>] -
Field names must be unique. Found duplicates
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25683";>FLINK-25683</a>] -
wrong result if table transfrom to DataStream then window process in batch
mode
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25091";>FLINK-25091</a>] -
Official website document FileSink orc compression attribute reference error
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25728";>FLINK-25728</a>] -
Potential memory leaks in StreamMultipleInputProcessor
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25096";>FLINK-25096</a>] -
Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25732";>FLINK-25732</a>] -
Dispatcher#requestMultipleJobDetails returns non-serialiable collection
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25199";>FLINK-25199</a>] -
StreamEdges are not unique in self-union, which blocks propagation of
watermarks
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25827";>FLINK-25827</a>] -
Potential memory leaks in SourceOperator
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25362";>FLINK-25362</a>] -
Incorrect dependencies in Table Confluent/Avro docs
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25856";>FLINK-25856</a>] -
Fix use of UserDefinedType in from_elements
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25468";>FLINK-25468</a>] -
Local recovery fails if local state storage and RocksDB working directory
are not on the same volume
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25883";>FLINK-25883</a>] -
The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too
large
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25486";>FLINK-25486</a>] -
Perjob can not recover from checkpoint when zookeeper leader changes
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25893";>FLINK-25893</a>] -
ResourceManagerServiceImpl's lifecycle can lead to exceptions
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25494";>FLINK-25494</a>] -
Duplicate element serializer during
DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25952";>FLINK-25952</a>] -
Savepoint on S3 are not relocatable even if entropy injection is not enabled
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25513";>FLINK-25513</a>] -
CoFlatMapFunction requires both two flat_maps to yield something
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26039";>FLINK-26039</a>] -
Incorrect value getter in map unnest table function
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25559";>FLINK-25559</a>] -
SQL JOIN causes data loss
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26159";>FLINK-26159</a>] -
Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain
slow consumption
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25683";>FLINK-25683</a>] -
wrong result if table transfrom to DataStream then window process in batch
mode
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26160";>FLINK-26160</a>] -
Pulsar Connector: stopCursor description should be changed. Connector only
stop when auto discovery is disabled.
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25728";>FLINK-25728</a>] -
Potential memory leaks in StreamMultipleInputProcessor
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26187";>FLINK-26187</a>] -
Chinese docs override english aliases
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25732";>FLINK-25732</a>] -
Dispatcher#requestMultipleJobDetails returns non-serialiable collection
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-26304";>FLINK-26304</a>] -
GlobalCommitter can receive failed committables
</li>
</ul>
-<h2> Improvement
+<h2> New Feature
</h2>
<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21407";>FLINK-21407</a>] -
Clarify which sources and APIs support which formats
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20443";>FLINK-20443</a>] -
ContinuousProcessingTimeTrigger doesn't fire at the end of the window
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20188";>FLINK-20188</a>] -
Add Documentation for new File Source
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21467";>FLINK-21467</a>] -
Document possible recommended usage of Bounded{One/Multi}Input.endInput and
emphasize that they could be called multiple times
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23842";>FLINK-23842</a>] -
Add log messages for reader registrations and split requests.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24631";>FLINK-24631</a>] -
Avoiding directly use the labels as selector for deployment and service
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21407";>FLINK-21407</a>] -
Clarify which sources and APIs support which formats
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24739";>FLINK-24739</a>] -
State requirements for Flink's application mode in the documentation
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20830";>FLINK-20830</a>] -
Add a type of HEADLESS_CLUSTER_IP for rest service type
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24987";>FLINK-24987</a>] -
Enhance ExternalizedCheckpointCleanup enum
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24880";>FLINK-24880</a>] -
Error messages "OverflowError: timeout value is too large" shown
when executing PyFlink jobs
</li>
<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25160";>FLINK-25160</a>] -
Make doc clear: tolerable-failed-checkpoints counts consecutive failures
</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25415";>FLINK-25415</a>] -
implement retrial on connections to Cassandra container
-</li>
<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25611";>FLINK-25611</a>] -
Remove CoordinatorExecutorThreadFactory thread creation guards
</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25650";>FLINK-25650</a>] -
Document unaligned checkpoints performance limitations (larger records/flat
map/timers/...)
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25767";>FLINK-25767</a>] -
Translation of page 'Working with State' is incomplete
+</li>
<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25818";>FLINK-25818</a>] -
Add explanation how Kafka Source deals with idleness when parallelism is
higher then the number of partitions
</li>
</ul>
-<h2> Technical Debt
+<h2> Technical Debt
</h2>
<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24740";>FLINK-24740</a>] -
Update testcontainers dependency to v1.16.2
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24796";>FLINK-24796</a>] -
Exclude javadocs / node[_modules] directories from CI compile artifact
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25472";>FLINK-25472</a>] -
Update to Log4j 2.17.1
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25375";>FLINK-25375</a>] -
Update Log4j to 2.17.0
-</li>
<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25576";>FLINK-25576</a>] -
Update com.h2database:h2 to 2.0.206
</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25785";>FLINK-25785</a>] -
Update com.h2database:h2 to 2.0.210
+</li>
</ul>
</article>
diff --git a/content/q/gradle-quickstart.sh b/content/q/gradle-quickstart.sh
index 68f61f0..b977c69 100755
--- a/content/q/gradle-quickstart.sh
+++ b/content/q/gradle-quickstart.sh
@@ -41,7 +41,7 @@ function mkPackage() {
defaultProjectName="quickstart"
defaultOrganization="org.myorg.quickstart"
defaultVersion="0.1-SNAPSHOT"
-defaultFlinkVersion="${1:-1.14.3}"
+defaultFlinkVersion="${1:-1.14.4}"
defaultScalaBinaryVersion="${2:-2.11}"
echo "This script creates a Flink project using Java and Gradle."
diff --git a/content/q/quickstart-scala.sh b/content/q/quickstart-scala.sh
index bd618b1..f9868ff 100755
--- a/content/q/quickstart-scala.sh
+++ b/content/q/quickstart-scala.sh
@@ -24,7 +24,7 @@ PACKAGE=quickstart
mvn archetype:generate
\
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-scala \
- -DarchetypeVersion=${1:-1.14.3}
\
+ -DarchetypeVersion=${1:-1.14.4}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/content/q/quickstart.sh b/content/q/quickstart.sh
index 14e5379..0b1a988 100755
--- a/content/q/quickstart.sh
+++ b/content/q/quickstart.sh
@@ -24,7 +24,7 @@ PACKAGE=quickstart
mvn archetype:generate
\
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-java \
- -DarchetypeVersion=${1:-1.14.3}
\
+ -DarchetypeVersion=${1:-1.14.4}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/content/q/sbt-quickstart.sh b/content/q/sbt-quickstart.sh
index 1c5d849..9669b7b 100755
--- a/content/q/sbt-quickstart.sh
+++ b/content/q/sbt-quickstart.sh
@@ -42,7 +42,7 @@ defaultProjectName="Flink Project"
defaultOrganization="org.example"
defaultVersion="0.1-SNAPSHOT"
defaultScalaVersion="2.12.7"
-defaultFlinkVersion="1.14.3"
+defaultFlinkVersion="1.14.4"
echo "This script creates a Flink project using Scala and SBT."
diff --git a/content/zh/downloads.html b/content/zh/downloads.html
index 537cec1..5a303d0 100644
--- a/content/zh/downloads.html
+++ b/content/zh/downloads.html
@@ -224,7 +224,7 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#apache-flink-1143" id="markdown-toc-apache-flink-1143">Apache
Flink 1.14.3</a></li>
+ <li><a href="#apache-flink-1144" id="markdown-toc-apache-flink-1144">Apache
Flink 1.14.4</a></li>
<li><a href="#apache-flink-1136" id="markdown-toc-apache-flink-1136">Apache
Flink 1.13.6</a></li>
<li><a href="#apache-flink-1127" id="markdown-toc-apache-flink-1127">Apache
Flink 1.12.7</a></li>
<li><a href="#apache-flink-1116" id="markdown-toc-apache-flink-1116">Apache
Flink 1.11.6</a></li>
@@ -249,23 +249,23 @@
</div>
-<p>Apache Flink® 1.14.3 是我们最新的稳定版本。</p>
+<p>Apache Flink® 1.14.4 是我们最新的稳定版本。</p>
-<h2 id="apache-flink-1143">Apache Flink 1.14.3</h2>
+<h2 id="apache-flink-1144">Apache Flink 1.14.4</h2>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz";
id="1142-download_211">Apache Flink 1.14.3 for Scala 2.11</a> (<a href="
-
https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz";
id="1144-download_211">Apache Flink 1.14.4 for Scala 2.11</a> (<a href="
+
https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.11.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz";
id="1142-download_212">Apache Flink 1.14.3 for Scala 2.12</a> (<a href="
-
https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz";
id="1144-download_212">Apache Flink 1.14.4 for Scala 2.12</a> (<a href="
+
https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-bin-scala_2.12.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-src.tgz";
id="1142-download-source">Apache Flink 1.14.3 Source Release</a>
- (<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.4/flink-1.14.4-src.tgz";
id="1144-download-source">Apache Flink 1.14.4 Source Release</a>
+ (<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.4/flink-1.14.4-src.tgz.sha512";>sha512</a>)
</p>
<h4 id="section">发布说明</h4>
@@ -419,17 +419,17 @@
flink-docs-release-1.11/release-notes/flink-1.11.html">Flink 1.11 的发布说
<div class="highlight"><pre><code class="language-xml"><span
class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-java<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.4<span
class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3>
@@ -494,6 +494,17 @@ The <code>statefun-flink-harness</code> dependency
includes a local execution en
<li>
+Flink 1.14.4 - 2022-03-02
+(<a
href="https://archive.apache.org/dist/flink/flink-1.14.4/flink-1.14.4-src.tgz";>Source</a>,
+<a href="https://archive.apache.org/dist/flink/flink-1.14.4";>Binaries</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.14";>Docs</a>,
+<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.14/api/java";>Javadocs</a>,
+<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.14/api/scala/index.html";>Scaladocs</a>)
+
+</li>
+
+<li>
+
Flink 1.14.3 - 2022-01-17
(<a
href="https://archive.apache.org/dist/flink/flink-1.14.3/flink-1.14.3-src.tgz";>Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.14.3";>Binaries</a>,
@@ -527,7 +538,7 @@ Flink 1.14.0 - 2021-09-29
<li>
-Flink 1.13.6 - 2022-02-09
+Flink 1.13.6 - 2022-02-18
(<a
href="https://archive.apache.org/dist/flink/flink-1.13.6/flink-1.13.6-src.tgz";>Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.13.6";>Binaries</a>,
<a href="https://nightlies.apache.org/flink/flink-docs-release-1.13";>Docs</a>,
diff --git a/content/zh/index.html b/content/zh/index.html
index 133c9c9..8dd2eaa 100644
--- a/content/zh/index.html
+++ b/content/zh/index.html
@@ -388,10 +388,13 @@
<dl>
+ <dt> <a href="/news/2022/03/11/release-1.14.4.html">Apache Flink
1.14.4 Release Announcement</a></dt>
+ <dd>The Apache Flink Community is please to announce another bug fix
release for Flink 1.14.</dd>
+
<dt> <a href="/2022/02/22/scala-free.html">Scala Free in One
Fifteen</a></dt>
<dd>Apache Flink's runtime is now Scala free, allowing users to
leverage any Scala version in their user code - including Scala 3!</dd>
- <dt> <a href="/news/2022/02/09/release-1.13.6.html">Apache Flink
1.13.6 Release Announcement</a></dt>
+ <dt> <a href="/news/2022/02/18/release-1.13.6.html">Apache Flink
1.13.6 Release Announcement</a></dt>
<dd>The Apache Flink Community is please to announce another bug fix
release for Flink 1.13.</dd>
<dt> <a href="/news/2022/01/31/release-statefun-3.2.0.html">Stateful
Functions 3.2.0 Release Announcement</a></dt>
@@ -402,9 +405,6 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
<dt> <a href="/2022/01/20/pravega-connector-101.html">Pravega Flink
Connector 101</a></dt>
<dd>A brief introduction to the Pravega Flink Connector</dd>
-
- <dt> <a href="/news/2022/01/17/release-1.14.3.html">Apache Flink
1.14.3 Release Announcement</a></dt>
- <dd>The Apache Flink community released the second bugfix version of
the Apache Flink 1.14 series.</dd>
</dl>
