You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2023/01/31 14:59:54 UTC
[flink-web] branch asf-site updated: Rebuild website
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 afa5085ed Rebuild website
afa5085ed is described below
commit afa5085ed6d837d075c23e079a6a17246ddc7c44
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Jan 31 15:58:33 2023 +0100
Rebuild website
---
content/blog/feed.xml | 361 +++++++++++++-------
content/blog/index.html | 36 +-
content/blog/page10/index.html | 40 ++-
content/blog/page11/index.html | 40 ++-
content/blog/page12/index.html | 40 ++-
content/blog/page13/index.html | 40 ++-
content/blog/page14/index.html | 40 ++-
content/blog/page15/index.html | 40 ++-
content/blog/page16/index.html | 38 ++-
content/blog/page17/index.html | 36 +-
content/blog/page18/index.html | 36 +-
content/blog/page19/index.html | 42 +--
content/blog/page2/index.html | 36 +-
content/blog/page20/index.html | 48 +--
content/blog/page21/index.html | 29 ++
content/blog/page3/index.html | 38 ++-
content/blog/page4/index.html | 40 ++-
content/blog/page5/index.html | 41 ++-
content/blog/page6/index.html | 41 ++-
content/blog/page7/index.html | 40 ++-
content/blog/page8/index.html | 38 ++-
content/blog/page9/index.html | 38 ++-
content/downloads.html | 33 +-
content/index.html | 6 +-
content/news/2023/01/30/release-1.16.1.html | 507 ++++++++++++++++++++++++++++
content/q/gradle-quickstart.sh | 6 +-
content/q/quickstart-scala.sh | 2 +-
content/q/quickstart.sh | 2 +-
content/q/sbt-quickstart.sh | 6 +-
content/zh/downloads.html | 33 +-
content/zh/index.html | 6 +-
31 files changed, 1315 insertions(+), 464 deletions(-)
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index d69118da8..6733ecc10 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -6,6 +6,236 @@
<link>https://flink.apache.org/blog</link>
<atom:link href="https://flink.apache.org/blog/feed.xml" rel="self" type="application/rss+xml" />
+<item>
+<title>Apache Flink 1.16.1 Release Announcement</title>
+<description><p>The Apache Flink Community is pleased to announce the first bug fix release of the Flink 1.16 series.</p>
+
+<p>This release includes 84 bug fixes, vulnerability fixes, and minor improvements for Flink 1.16.
+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=12352344">JIRA</a>.</p>
+
+<p>We highly recommend all users upgrade to Flink 1.16.1.</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.16.1<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<span class="nt">&lt;/artifactId&gt;</span>
+ <span class="nt">&lt;version&gt;</span>1.16.1<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<span class="nt">&lt;/artifactId&gt;</span>
+ <span class="nt">&lt;version&gt;</span>1.16.1<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.16.1">library/flink</a> (official images)</li>
+ <li><a href="https://hub.docker.com/r/apache/flink/tags?page=1&amp;name=1.16.1">apache/flink</a> (ASF repository)</li>
+</ul>
+
+<h2 id="pypi">PyPi</h2>
+
+<ul>
+ <li><a href="https://pypi.org/project/apache-flink/1.16.1/">apache-flink==1.16.1</a></li>
+</ul>
+
+<h1 id="upgrade-notes">Upgrade Notes</h1>
+
+<p><a href="https://issues.apache.org/jira/browse/FLINK-28988">FLINK-28988 - Incorrect result for filter after temporal join</a>
+The filter will not be pushed down into both inputs of the event time temporal join.
+This may cause incompatible plan changes compared to Flink 1.16.0, e.g., when the left input is an upsert source
+(like upsert-kafka connector), the query plan will remove the ChangelogNormalize node in Flink 1.16.1, while it
+did appear in 1.16.0.</p>
+
+<p><a href="https://issues.apache.org/jira/browse/FLINK-29849">FLINK-29849 - Event time temporal join on an upsert source may produce incorrect execution plan</a>
+This resolves the correctness issue when doing an event time temporal join with a versioned table backed by an upsert source.
+When the right input of the join is an upsert source, it no longer generates a ChangelogNormalize node for it.
+This is an incompatible plan change compared to 1.16.0</p>
+
+<p><a href="https://issues.apache.org/jira/browse/FLINK-30383">FLINK-30383 - UseLogicalIdentifier makes datadog consider metric as custom</a>
+The Datadog reporter now adds a “flink.” prefix to metric identifiers if “useLogicalIdentifier” is enabled.
+This is required for these metrics to be recognized as Flink metrics, not custom ones.</p>
+
+<h1 id="release-notes">Release Notes</h1>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16582">FLINK-16582</a>] - NettyBufferPoolTest may have warns on NettyBuffer leak
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26037">FLINK-26037</a>] - TaskManagerRunner may crash during shutdown sequence
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26890">FLINK-26890</a>] - DynamoDB consumer error consuming partitions close to retention
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27341">FLINK-27341</a>] - TaskManager running together with JobManager are bind to 127.0.0.1
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27944">FLINK-27944</a>] - IO metrics collision happens if a task has union inputs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28102">FLINK-28102</a>] - Flink AkkaRpcSystemLoader fails when temporary directory is a symlink
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28526">FLINK-28526</a>] - Fail to lateral join with UDTF from Table with timstamp column
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28695">FLINK-28695</a>] - Fail to send partition request to restarted taskmanager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28742">FLINK-28742</a>] - Table.to_pandas fails with lit(&quot;xxx&quot;)
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28786">FLINK-28786</a>] - Cannot run PyFlink 1.16 on MacOS with M1 chip
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28863">FLINK-28863</a>] - Snapshot result of RocksDB native savepoint should have empty shared-state
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28960">FLINK-28960</a>] - Pulsar throws java.lang.NoClassDefFoundError: javax/xml/bind/annotation/XmlElement
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28988">FLINK-28988</a>] - Incorrect result for filter after temporal join
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29231">FLINK-29231</a>] - PyFlink UDAF produces different results in the same sliding window
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29234">FLINK-29234</a>] - Dead lock in DefaultLeaderElectionService
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29298">FLINK-29298</a>] - LocalBufferPool request buffer from NetworkBufferPool hanging
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29479">FLINK-29479</a>] - Support whether using system PythonPath for PyFlink jobs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29539">FLINK-29539</a>] - dnsPolicy in FlinkPod is not overridable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29615">FLINK-29615</a>] - MetricStore does not remove metrics of nonexistent subtasks when adaptive scheduler lowers job parallelism
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29627">FLINK-29627</a>] - Sink - Duplicate key exception during recover more than 1 committable.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29677">FLINK-29677</a>] - Prevent dropping the current catalog
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29728">FLINK-29728</a>] - TablePlanner prevents Flink from starting is working directory is a symbolic link
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29749">FLINK-29749</a>] - flink info command support dynamic properties
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29781">FLINK-29781</a>] - ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29803">FLINK-29803</a>] - Table API Scala APIs lack proper source jars
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29817">FLINK-29817</a>] - Published metadata for apache-flink in pypi are inconsistent and causes poetry to fail
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29827">FLINK-29827</a>] - [Connector][AsyncSinkWriter] Checkpointed states block writer from sending records
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29839">FLINK-29839</a>] - HiveServer2 endpoint doesn&#39;t support TGetInfoType value &#39;CLI_ODBC_KEYWORDS&#39;
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29849">FLINK-29849</a>] - Event time temporal join on an upsert source may produce incorrect execution plan
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29857">FLINK-29857</a>] - Fix failure to connect to &#39;HiveServer2Endpoint&#39; when using hive3 beeline
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29899">FLINK-29899</a>] - Stacktrace printing in DefaultExecutionGraphCacheTest is confusing maven test log output
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29923">FLINK-29923</a>] - Hybrid Shuffle may face deadlock when running a task need to execute big size data
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29927">FLINK-29927</a>] - AkkaUtils#getAddress may cause memory leak
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30030">FLINK-30030</a>] - Unexpected behavior for overwrite in Hive dialect
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30133">FLINK-30133</a>] - HadoopModuleFactory creates error if the security module cannot be loaded
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30168">FLINK-30168</a>] - PyFlink Deserialization Error with Object Array
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30189">FLINK-30189</a>] - HsSubpartitionFileReader may load data that has been consumed from memory
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30239">FLINK-30239</a>] - The flame graph doesn&#39;t work due to groupExecutionsByLocation has bug
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30304">FLINK-30304</a>] - Possible Deadlock in Kinesis/Firehose/DynamoDB Connector
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30308">FLINK-30308</a>] - ClassCastException: class java.io.ObjectStreamClass$Caches$1 cannot be cast to class java.util.Map is showing in the logging when the job shutdown
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30334">FLINK-30334</a>] - SourceCoordinator error splitRequest check cause HybridSource loss of data and hang
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30359">FLINK-30359</a>] - Encountered NoClassDefFoundError when using flink-sql-connector-elasticsearch6
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30366">FLINK-30366</a>] - Python Group Agg failed in cleaning the idle state
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30525">FLINK-30525</a>] - Cannot open jobmanager configuration web page
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30558">FLINK-30558</a>] - The metric &#39;numRestarts&#39; reported in SchedulerBase will be overridden by metric &#39;fullRestarts&#39;
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30637">FLINK-30637</a>] - In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27327">FLINK-27327</a>] - Add description about changing max parallelism explicitly leads to state incompatibility
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29134">FLINK-29134</a>] - fetch metrics may cause oom(ThreadPool task pile up)
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29155">FLINK-29155</a>] - Improve default config of grpcServer in Process Mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29244">FLINK-29244</a>] - Add metric lastMaterializationDuration to ChangelogMaterializationMetricGroup
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29458">FLINK-29458</a>] - When two tables have the same field, do not specify the table name,Exception will be thrown：SqlValidatorException :Column &#39;currency&#39; is ambiguous
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29639">FLINK-29639</a>] - Add ResourceId in TransportException for debugging
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29693">FLINK-29693</a>] - MiniClusterExtension should respect DEFAULT_PARALLELISM if set
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29834">FLINK-29834</a>] - Clear static Jackson TypeFactory cache on CL release
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29966">FLINK-29966</a>] - Replace and redesign the Python api documentation base
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30016">FLINK-30016</a>] - Update Flink 1.16 release notes about updated oshi-core
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30116">FLINK-30116</a>] - Don&#39;t Show Env Vars in Web UI
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30183">FLINK-30183</a>] - We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30357">FLINK-30357</a>] - Wrong link in connector/jdbc doc.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30436">FLINK-30436</a>] - Integrate Opensearch connector docs into Flink docs v1.16
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30592">FLINK-30592</a>] - The unsupported hive version is not deleted on the hive overview document
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30633">FLINK-30633</a>] - Update AWS SDKv2 to v2.19.14
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30724">FLINK-30724</a>] - Update doc of kafka per-partition watermark to FLIP-27 source
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27731">FLINK-27731</a>] - Remove Hugo Modules integration
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29157">FLINK-29157</a>] - Clarify the contract between CompletedCheckpointStore and SharedStateRegistry
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29957">FLINK-29957</a>] - Rework connector docs integration
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29958">FLINK-29958</a>] - Add new connector_artifact shortcode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29972">FLINK-29972</a>] - Pin Flink docs to Elasticsearch Connector 3.0.0
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29973">FLINK-29973</a>] - connector_artifact should append Flink minor version
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30291">FLINK-30291</a>] - Integrate flink-connector-aws into Flink docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30382">FLINK-30382</a>] - Flink 1.16 to integrate KDS/KDF docs from flink-connector-aws
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30383">FLINK-30383</a>] - UseLogicalIdentifier makes datadog consider metric as custom
+</li>
+</ul>
+</description>
+<pubDate>Mon, 30 Jan 2023 17:00:00 +0100</pubDate>
+<link>https://flink.apache.org/news/2023/01/30/release-1.16.1.html</link>
+<guid isPermaLink="true">/news/2023/01/30/release-1.16.1.html</guid>
+</item>
+
<item>
<title>Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</title>
<description><p>The Apache Flink Community is pleased to announce that the upcoming minor version of Flink (1.17) includes
@@ -19498,136 +19728,5 @@ FLINK-16683 Flink no longer supports starting clusters with .bat scripts. Users
<guid isPermaLink="true">/news/2020/05/04/season-of-docs.html</guid>
</item>
-<item>
-<title>Apache Flink 1.9.3 Released</title>
-<description><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.9 series.</p>
-
-<p>This release includes 38 fixes and minor improvements for Flink 1.9.2. The list below includes a detailed list of all fixes and improvements.</p>
-
-<p>We highly recommend all users to upgrade to Flink 1.9.3.</p>
-
-<p>Updated Maven dependencies:</p>
-
-<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.9.3<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.9.3<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.9.3<span class="nt">&lt;/version&gt;</span>
-<span class="nt">&lt;/dependency&gt;</span></code></pre></div>
-
-<p>You can find the binaries on the updated <a href="/downloads.html">Downloads page</a>.</p>
-
-<p>List of resolved issues:</p>
-
-<h2> Sub-task
-</h2>
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15143">FLINK-15143</a>] - Create document for FLIP-49 TM memory model and configuration guide
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16389">FLINK-16389</a>] - Bump Kafka 0.10 to 0.10.2.2
-</li>
-</ul>
-
-<h2> Bug
-</h2>
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-11193">FLINK-11193</a>] - Rocksdb timer service factory configuration option is not settable per job
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14316">FLINK-14316</a>] - Stuck in &quot;Job leader ... lost leadership&quot; error
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14560">FLINK-14560</a>] - The value of taskmanager.memory.size in flink-conf.yaml is set to zero will cause taskmanager not to work
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15010">FLINK-15010</a>] - Temp directories flink-netty-shuffle-* are not cleaned up
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15085">FLINK-15085</a>] - HistoryServer dashboard config json out of sync
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15386">FLINK-15386</a>] - SingleJobSubmittedJobGraphStore.putJobGraph has a logic error
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15575">FLINK-15575</a>] - Azure Filesystem Shades Wrong Package &quot;httpcomponents&quot;
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15638">FLINK-15638</a>] - releasing/create_release_branch.sh does not set version in flink-python/pyflink/version.py
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15812">FLINK-15812</a>] - HistoryServer archiving is done in Dispatcher main thread
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15844">FLINK-15844</a>] - Removal of JobWithJars.buildUserCodeClassLoader method without Configuration breaks backwards compatibility
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15863">FLINK-15863</a>] - Fix docs stating that savepoints are relocatable
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16047">FLINK-16047</a>] - Blink planner produces wrong aggregate results with state clean up
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16242">FLINK-16242</a>] - BinaryGeneric serialization error cause checkpoint failure
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16308">FLINK-16308</a>] - SQL connector download links are broken
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16373">FLINK-16373</a>] - EmbeddedLeaderService: IllegalStateException: The RPC connection is already closed
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16573">FLINK-16573</a>] - Kinesis consumer does not properly shutdown RecordFetcher threads
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16576">FLINK-16576</a>] - State inconsistency on restore with memory state backends
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16696">FLINK-16696</a>] - Savepoint trigger documentation is insufficient
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16703">FLINK-16703</a>] - AkkaRpcActor state machine does not record transition to terminating state.
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16836">FLINK-16836</a>] - Losing leadership does not clear rpc connection in JobManagerLeaderListener
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16860">FLINK-16860</a>] - Failed to push filter into OrcTableSource when upgrading to 1.9.2
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16916">FLINK-16916</a>] - The logic of NullableSerializer#copy is wrong
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17062">FLINK-17062</a>] - Fix the conversion from Java row type to Python row type
-</li>
-</ul>
-
-<h2> Improvement
-</h2>
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14278">FLINK-14278</a>] - Pass in ioExecutor into AbstractDispatcherResourceManagerComponentFactory
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15908">FLINK-15908</a>] - Add description of support &#39;pip install&#39; to 1.9.x documents
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15909">FLINK-15909</a>] - Add PyPI release process into the subsequent release of 1.9.x
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15938">FLINK-15938</a>] - Idle state not cleaned in StreamingJoinOperator and StreamingSemiAntiJoinOperator
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16018">FLINK-16018</a>] - Improve error reporting when submitting batch job (instead of AskTimeoutException)
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16031">FLINK-16031</a>] - Improve the description in the README file of PyFlink 1.9.x
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16167">FLINK-16167</a>] - Update documentation about python shell execution
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16280">FLINK-16280</a>] - Fix sample code errors in the documentation about elasticsearch connector
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16697">FLINK-16697</a>] - Disable JMX rebinding
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16862">FLINK-16862</a>] - Remove example url in quickstarts
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16942">FLINK-16942</a>] - ES 5 sink should allow users to select netty transport client
-</li>
-</ul>
-
-<h2> Task
-</h2>
-<ul>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-11767">FLINK-11767</a>] - Introduce new TypeSerializerUpgradeTestBase, new PojoSerializerUpgradeTest
-</li>
-<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16454">FLINK-16454</a>] - Update the copyright year in NOTICE files
-</li>
-</ul>
-</description>
-<pubDate>Fri, 24 Apr 2020 14:00:00 +0200</pubDate>
-<link>https://flink.apache.org/news/2020/04/24/release-1.9.3.html</link>
-<guid isPermaLink="true">/news/2020/04/24/release-1.9.3.html</guid>
-</item>
-
</channel>
</rss>
diff --git a/content/blog/index.html b/content/blog/index.html
index 4c34dd2ba..7181a9708 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -240,6 +240,19 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></h2>
+
+ <p>30 Jan 2023
+ Martijn Visser (<a href="https://twitter.com/martijnvisser82">@martijnvisser82</a>)</p>
+
+ <p>The Apache Flink Community is pleased to announce a bug fix release for Flink 1.16.</p>
+
+ <p><a href="/news/2023/01/30/release-1.16.1.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
<article>
<h2 class="blog-title"><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></h2>
@@ -372,19 +385,6 @@ with 19 FLIPs and 1100+ issues completed, bringing a lot of exciting features to
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2022/09/28/release-1.14.6.html">Apache Flink 1.14.6 Release Announcement</a></h2>
-
- <p>28 Sep 2022
- Xingbo Huang </p>
-
- <p>The Apache Flink Community is pleased to announce another bug fix release for Flink 1.14.</p>
-
- <p><a href="/news/2022/09/28/release-1.14.6.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -417,6 +417,16 @@ with 19 FLIPs and 1100+ issues completed, bringing a lot of exciting features to
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page10/index.html b/content/blog/page10/index.html
index 1f1eb58d0..04757f373 100644
--- a/content/blog/page10/index.html
+++ b/content/blog/page10/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2020/07/21/release-1.11.1.html">Apache Flink 1.11.1 Released</a></h2>
+
+ <p>21 Jul 2020
+ Dian Fu (<a href="https://twitter.com/DianFu11">@DianFu11</a>)</p>
+
+ <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.11 series.</p>
+
+</p>
+
+ <p><a href="/news/2020/07/21/release-1.11.1.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -375,21 +390,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/24/release-1.9.3.html">Apache Flink 1.9.3 Released</a></h2>
-
- <p>24 Apr 2020
- Dian Fu (<a href="https://twitter.com/DianFu11">@DianFu11</a>)</p>
-
- <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.9 series.</p>
-
-</p>
-
- <p><a href="/news/2020/04/24/release-1.9.3.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -422,6 +422,16 @@ and provide a tutorial for running Streaming ETL with Flink on Zeppelin.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page11/index.html b/content/blog/page11/index.html
index 957066a9c..71d68ee17 100644
--- a/content/blog/page11/index.html
+++ b/content/blog/page11/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2020/04/24/release-1.9.3.html">Apache Flink 1.9.3 Released</a></h2>
+
+ <p>24 Apr 2020
+ Dian Fu (<a href="https://twitter.com/DianFu11">@DianFu11</a>)</p>
+
+ <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.9 series.</p>
+
+</p>
+
+ <p><a href="/news/2020/04/24/release-1.9.3.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -362,21 +377,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/11/release-1.10.0.html">Apache Flink 1.10.0 Release Announcement</a></h2>
-
- <p>11 Feb 2020
- Marta Paes (<a href="https://twitter.com/morsapaes">@morsapaes</a>)</p>
-
- <p><p>The Apache Flink community is excited to hit the double digits and announce the release of Flink 1.10.0! As a result of the biggest community effort to date, with over 1.2k issues implemented and more than 200 contributors, this release introduces significant improvements to the overall performance and stability of Flink jobs, a preview of native Kubernetes integration and great advances in Python support (PyFlink).</p>
-
-</p>
-
- <p><a href="/news/2020/02/11/release-1.10.0.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -409,6 +409,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/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page12/index.html b/content/blog/page12/index.html
index 30ab85181..5ba6996b6 100644
--- a/content/blog/page12/index.html
+++ b/content/blog/page12/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2020/02/11/release-1.10.0.html">Apache Flink 1.10.0 Release Announcement</a></h2>
+
+ <p>11 Feb 2020
+ Marta Paes (<a href="https://twitter.com/morsapaes">@morsapaes</a>)</p>
+
+ <p><p>The Apache Flink community is excited to hit the double digits and announce the release of Flink 1.10.0! As a result of the biggest community effort to date, with over 1.2k issues implemented and more than 200 contributors, this release introduces significant improvements to the overall performance and stability of Flink jobs, a preview of native Kubernetes integration and great advances in Python support (PyFlink).</p>
+
+</p>
+
+ <p><a href="/news/2020/02/11/release-1.10.0.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -363,21 +378,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2019/09/11/release-1.8.2.html">Apache Flink 1.8.2 Released</a></h2>
-
- <p>11 Sep 2019
- Jark Wu (<a href="https://twitter.com/JarkWu">@JarkWu</a>)</p>
-
- <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.8 series.</p>
-
-</p>
-
- <p><a href="/news/2019/09/11/release-1.8.2.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -410,6 +410,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page13/index.html b/content/blog/page13/index.html
index 3323faa2a..7ea503507 100644
--- a/content/blog/page13/index.html
+++ b/content/blog/page13/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2019/09/11/release-1.8.2.html">Apache Flink 1.8.2 Released</a></h2>
+
+ <p>11 Sep 2019
+ Jark Wu (<a href="https://twitter.com/JarkWu">@JarkWu</a>)</p>
+
+ <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.8 series.</p>
+
+</p>
+
+ <p><a href="/news/2019/09/11/release-1.8.2.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
<article>
<h2 class="blog-title"><a href="/news/2019/09/10/community-update.html">Flink Community Update - September'19</a></h2>
@@ -362,21 +377,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2019/04/17/sod.html">Apache Flink's Application to Season of Docs</a></h2>
-
- <p>17 Apr 2019
- Konstantin Knauf (<a href="https://twitter.com/snntrable">@snntrable</a>)</p>
-
- <p><p>The Apache Flink community is happy to announce its application to the first edition of <a href="https://developers.google.com/season-of-docs/">Season of Docs</a> by Google. The program is bringing together Open Source projects and technical writers to raise awareness for and improve documentation of Open Source projects. While the community is continuously looking for new contributors to collaborate on our documentation, we would like to take this chance to work with one or [...]
-
-</p>
-
- <p><a href="/news/2019/04/17/sod.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -409,6 +409,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page14/index.html b/content/blog/page14/index.html
index 2e7dbe303..ede0d52a0 100644
--- a/content/blog/page14/index.html
+++ b/content/blog/page14/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2019/04/17/sod.html">Apache Flink's Application to Season of Docs</a></h2>
+
+ <p>17 Apr 2019
+ Konstantin Knauf (<a href="https://twitter.com/snntrable">@snntrable</a>)</p>
+
+ <p><p>The Apache Flink community is happy to announce its application to the first edition of <a href="https://developers.google.com/season-of-docs/">Season of Docs</a> by Google. The program is bringing together Open Source projects and technical writers to raise awareness for and improve documentation of Open Source projects. While the community is continuously looking for new contributors to collaborate on our documentation, we would like to take this chance to work with one or [...]
+
+</p>
+
+ <p><a href="/news/2019/04/17/sod.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -371,21 +386,6 @@ for more details.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2018/12/21/release-1.7.1.html">Apache Flink 1.7.1 Released</a></h2>
-
- <p>21 Dec 2018
- </p>
-
- <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.7 series.</p>
-
-</p>
-
- <p><a href="/news/2018/12/21/release-1.7.1.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -418,6 +418,16 @@ for more details.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page15/index.html b/content/blog/page15/index.html
index 6ca6a6372..25670e62e 100644
--- a/content/blog/page15/index.html
+++ b/content/blog/page15/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2018/12/21/release-1.7.1.html">Apache Flink 1.7.1 Released</a></h2>
+
+ <p>21 Dec 2018
+ </p>
+
+ <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.7 series.</p>
+
+</p>
+
+ <p><a href="/news/2018/12/21/release-1.7.1.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -377,21 +392,6 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2018/05/25/release-1.5.0.html">Apache Flink 1.5.0 Release Announcement</a></h2>
-
- <p>25 May 2018
- Fabian Hueske (<a href="https://twitter.com/fhueske">@fhueske</a>)</p>
-
- <p><p>The Apache Flink community is thrilled to announce the 1.5.0 release. Over the past 5 months, the Flink community has been working hard to resolve more than 780 issues. Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?version=12341764&projectId=12315522">complete changelog</a> for more detail.</p>
-
-</p>
-
- <p><a href="/news/2018/05/25/release-1.5.0.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -424,6 +424,16 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page16/index.html b/content/blog/page16/index.html
index cb3071d90..54281d71e 100644
--- a/content/blog/page16/index.html
+++ b/content/blog/page16/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2018/05/25/release-1.5.0.html">Apache Flink 1.5.0 Release Announcement</a></h2>
+
+ <p>25 May 2018
+ Fabian Hueske (<a href="https://twitter.com/fhueske">@fhueske</a>)</p>
+
+ <p><p>The Apache Flink community is thrilled to announce the 1.5.0 release. Over the past 5 months, the Flink community has been working hard to resolve more than 780 issues. Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?version=12341764&projectId=12315522">complete changelog</a> for more detail.</p>
+
+</p>
+
+ <p><a href="/news/2018/05/25/release-1.5.0.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -374,19 +389,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="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></h2>
-
- <p>04 Jul 2017 by Stefan Richter (<a href="https://twitter.com/">@StefanRRichter</a>)
- </p>
-
- <p><p>A primer on stateful stream processing and an in-depth walkthrough of rescalable state in Apache Flink.</p></p>
-
- <p><a href="/features/2017/07/04/flink-rescalable-state.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -419,6 +421,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/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page17/index.html b/content/blog/page17/index.html
index 13f97a93f..b241fc6ec 100644
--- a/content/blog/page17/index.html
+++ b/content/blog/page17/index.html
@@ -240,6 +240,19 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/features/2017/07/04/flink-rescalable-state.html">A Deep Dive into Rescalable State in Apache Flink</a></h2>
+
+ <p>04 Jul 2017 by Stefan Richter (<a href="https://twitter.com/">@StefanRRichter</a>)
+ </p>
+
+ <p><p>A primer on stateful stream processing and an in-depth walkthrough of rescalable state in Apache Flink.</p></p>
+
+ <p><a href="/features/2017/07/04/flink-rescalable-state.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -370,19 +383,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2016/12/19/2016-year-in-review.html">Apache Flink in 2016: Year in Review</a></h2>
-
- <p>19 Dec 2016 by Mike Winters
- </p>
-
- <p><p>As 2016 comes to a close, let's take a moment to look back on the Flink community's great work during the past year.</p></p>
-
- <p><a href="/news/2016/12/19/2016-year-in-review.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -415,6 +415,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page18/index.html b/content/blog/page18/index.html
index aa39a388c..efeac50ca 100644
--- a/content/blog/page18/index.html
+++ b/content/blog/page18/index.html
@@ -240,6 +240,19 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2016/12/19/2016-year-in-review.html">Apache Flink in 2016: Year in Review</a></h2>
+
+ <p>19 Dec 2016 by Mike Winters
+ </p>
+
+ <p><p>As 2016 comes to a close, let's take a moment to look back on the Flink community's great work during the past year.</p></p>
+
+ <p><a href="/news/2016/12/19/2016-year-in-review.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -374,19 +387,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2016/04/06/cep-monitoring.html">Introducing Complex Event Processing (CEP) with Apache Flink</a></h2>
-
- <p>06 Apr 2016 by Till Rohrmann (<a href="https://twitter.com/">@stsffap</a>)
- </p>
-
- <p>In this blog post, we introduce Flink's new <a href="{{site.DOCS_BASE_URL}}flink-docs-master/apis/streaming/libs/cep.html">CEP library</a> that allows you to do pattern matching on event streams. Through the example of monitoring a data center and generating alerts, we showcase the library's ease of use and its intuitive Pattern API.</p>
-
- <p><a href="/news/2016/04/06/cep-monitoring.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -419,6 +419,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page19/index.html b/content/blog/page19/index.html
index 6ffd30d5f..a2a819b61 100644
--- a/content/blog/page19/index.html
+++ b/content/blog/page19/index.html
@@ -240,6 +240,19 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2016/04/06/cep-monitoring.html">Introducing Complex Event Processing (CEP) with Apache Flink</a></h2>
+
+ <p>06 Apr 2016 by Till Rohrmann (<a href="https://twitter.com/">@stsffap</a>)
+ </p>
+
+ <p>In this blog post, we introduce Flink's new <a href="{{site.DOCS_BASE_URL}}flink-docs-master/apis/streaming/libs/cep.html">CEP library</a> that allows you to do pattern matching on event streams. Through the example of monitoring a data center and generating alerts, we showcase the library's ease of use and its intuitive Pattern API.</p>
+
+ <p><a href="/news/2016/04/06/cep-monitoring.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
<article>
<h2 class="blog-title"><a href="/news/2016/04/06/release-1.0.1.html">Flink 1.0.1 Released</a></h2>
@@ -369,25 +382,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2015/09/03/flink-forward.html">Announcing Flink Forward 2015</a></h2>
-
- <p>03 Sep 2015
- </p>
-
- <p><p><a href="http://2015.flink-forward.org/">Flink Forward 2015</a> is the first
-conference with Flink at its center that aims to bring together the
-Apache Flink community in a single place. The organizers are starting
-this conference in October 12 and 13 from Berlin, the place where
-Apache Flink started.</p>
-
-</p>
-
- <p><a href="/news/2015/09/03/flink-forward.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -420,6 +414,16 @@ Apache Flink started.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index fe987d8f2..9b30a1f33 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -240,6 +240,19 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2022/09/28/release-1.14.6.html">Apache Flink 1.14.6 Release Announcement</a></h2>
+
+ <p>28 Sep 2022
+ Xingbo Huang </p>
+
+ <p>The Apache Flink Community is pleased to announce another bug fix release for Flink 1.14.</p>
+
+ <p><a href="/news/2022/09/28/release-1.14.6.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
<article>
<h2 class="blog-title"><a href="/news/2022/09/08/akka-license-change.html">Regarding Akka's licensing change</a></h2>
@@ -361,19 +374,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/2022/06/17/adaptive-batch-scheduler.html">Adaptive Batch Scheduler: Automatically Decide Parallelism of Flink Batch Jobs</a></h2>
-
- <p>17 Jun 2022
- Lijie Wang & Zhu Zhu </p>
-
- <p>To automatically decide parallelism of Flink batch jobs, we introduced adaptive batch scheduler in Flink 1.15. In this post, we'll take a close look at the design & implementation details.</p>
-
- <p><a href="/2022/06/17/adaptive-batch-scheduler.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -406,6 +406,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page20/index.html b/content/blog/page20/index.html
index 7de72ba95..683662b9f 100644
--- a/content/blog/page20/index.html
+++ b/content/blog/page20/index.html
@@ -240,6 +240,25 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2015/09/03/flink-forward.html">Announcing Flink Forward 2015</a></h2>
+
+ <p>03 Sep 2015
+ </p>
+
+ <p><p><a href="http://2015.flink-forward.org/">Flink Forward 2015</a> is the first
+conference with Flink at its center that aims to bring together the
+Apache Flink community in a single place. The organizers are starting
+this conference in October 12 and 13 from Berlin, the place where
+Apache Flink started.</p>
+
+</p>
+
+ <p><a href="/news/2015/09/03/flink-forward.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -381,25 +400,6 @@ community last month.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2015/02/09/streaming-example.html">Introducing Flink Streaming</a></h2>
-
- <p>09 Feb 2015
- </p>
-
- <p><p>This post is the first of a series of blog posts on Flink Streaming,
-the recent addition to Apache Flink that makes it possible to analyze
-continuous data sources in addition to static files. Flink Streaming
-uses the pipelined Flink engine to process data streams in real time
-and offers a new API including definition of flexible windows.</p>
-
-</p>
-
- <p><a href="/news/2015/02/09/streaming-example.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -432,6 +432,16 @@ and offers a new API including definition of flexible windows.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page21/index.html b/content/blog/page21/index.html
index ef383b14c..15e2df90b 100644
--- a/content/blog/page21/index.html
+++ b/content/blog/page21/index.html
@@ -240,6 +240,25 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2015/02/09/streaming-example.html">Introducing Flink Streaming</a></h2>
+
+ <p>09 Feb 2015
+ </p>
+
+ <p><p>This post is the first of a series of blog posts on Flink Streaming,
+the recent addition to Apache Flink that makes it possible to analyze
+continuous data sources in addition to static files. Flink Streaming
+uses the pipelined Flink engine to process data streams in real time
+and offers a new API including definition of flexible windows.</p>
+
+</p>
+
+ <p><a href="/news/2015/02/09/streaming-example.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
<article>
<h2 class="blog-title"><a href="/news/2015/02/04/january-in-flink.html">January 2015 in the Flink community</a></h2>
@@ -395,6 +414,16 @@ academic and open source project that Flink originates from.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index 70a068bc9..4e6f1bd72 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -240,6 +240,19 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/2022/06/17/adaptive-batch-scheduler.html">Adaptive Batch Scheduler: Automatically Decide Parallelism of Flink Batch Jobs</a></h2>
+
+ <p>17 Jun 2022
+ Lijie Wang & Zhu Zhu </p>
+
+ <p>To automatically decide parallelism of Flink batch jobs, we introduced adaptive batch scheduler in Flink 1.15. In this post, we'll take a close look at the design & implementation details.</p>
+
+ <p><a href="/2022/06/17/adaptive-batch-scheduler.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
<article>
<h2 class="blog-title"><a href="/news/2022/06/05/release-kubernetes-operator-1.0.0.html">Apache Flink Kubernetes Operator 1.0.0 Release Announcement</a></h2>
@@ -369,21 +382,6 @@ exciting changes.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2022/04/03/release-kubernetes-operator-0.1.0.html">Apache Flink Kubernetes Operator 0.1.0 Release Announcement</a></h2>
-
- <p>03 Apr 2022
- Gyula Fora (<a href="https://twitter.com/GyulaFora">@GyulaFora</a>)</p>
-
- <p><p>The Apache Flink Community is pleased to announce the preview release of the Apache Flink Kubernetes Operator (0.1.0)</p>
-
-</p>
-
- <p><a href="/news/2022/04/03/release-kubernetes-operator-0.1.0.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -416,6 +414,16 @@ exciting changes.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index ddfaa83c4..96507f88c 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2022/04/03/release-kubernetes-operator-0.1.0.html">Apache Flink Kubernetes Operator 0.1.0 Release Announcement</a></h2>
+
+ <p>03 Apr 2022
+ Gyula Fora (<a href="https://twitter.com/GyulaFora">@GyulaFora</a>)</p>
+
+ <p><p>The Apache Flink Community is pleased to announce the preview release of the Apache Flink Kubernetes Operator (0.1.0)</p>
+
+</p>
+
+ <p><a href="/news/2022/04/03/release-kubernetes-operator-0.1.0.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
<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>
@@ -360,21 +375,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/22/log4j-statefun-release.html">Apache Flink StateFun Log4j emergency release</a></h2>
-
- <p>22 Dec 2021
- Igal Shilman & Seth Wiesman </p>
-
- <p><p>The Apache Flink community has released an emergency bugfix version of Apache Flink Stateful Function 3.1.1.</p>
-
-</p>
-
- <p><a href="/news/2021/12/22/log4j-statefun-release.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -407,6 +407,16 @@ This new release brings various improvements to the StateFun runtime, a leaner w
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html
index ea20a3447..26928db04 100644
--- a/content/blog/page5/index.html
+++ b/content/blog/page5/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2021/12/22/log4j-statefun-release.html">Apache Flink StateFun Log4j emergency release</a></h2>
+
+ <p>22 Dec 2021
+ Igal Shilman & Seth Wiesman </p>
+
+ <p><p>The Apache Flink community has released an emergency bugfix version of Apache Flink Stateful Function 3.1.1.</p>
+
+</p>
+
+ <p><a href="/news/2021/12/22/log4j-statefun-release.html">Continue reading »</a></p>
+ </article>
+
+ <hr>
+
<article>
<h2 class="blog-title"><a href="/news/2021/12/16/log4j-patch-releases.html">Apache Flink Log4j emergency releases</a></h2>
@@ -365,22 +380,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2021/08/31/release-statefun-3.1.0.html">Stateful Functions 3.1.0 Release Announcement</a></h2>
-
- <p>31 Aug 2021
- Seth Wiesman (<a href="https://twitter.com/sjwiesman">@sjwiesman</a>), 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>Stateful Functions is a cross-platform stack for building Stateful Serverless applications, making it radically simpler to develop scalable, consistent, and elastic distributed applications.
-This new release brings various improvements to the StateFun runtime, a leaner way to specify StateFun module components, and a brand new GoLang SDK!</p>
-
-</p>
-
- <p><a href="/news/2021/08/31/release-statefun-3.1.0.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -413,6 +412,16 @@ This new release brings various improvements to the StateFun runtime, a leaner w
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page6/index.html b/content/blog/page6/index.html
index fdd71ff27..c95eb46d0 100644
--- a/content/blog/page6/index.html
+++ b/content/blog/page6/index.html
@@ -240,6 +240,22 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2021/08/31/release-statefun-3.1.0.html">Stateful Functions 3.1.0 Release Announcement</a></h2>
+
+ <p>31 Aug 2021
+ Seth Wiesman (<a href="https://twitter.com/sjwiesman">@sjwiesman</a>), 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>Stateful Functions is a cross-platform stack for building Stateful Serverless applications, making it radically simpler to develop scalable, consistent, and elastic distributed applications.
+This new release brings various improvements to the StateFun runtime, a leaner way to specify StateFun module components, and a brand new GoLang SDK!</p>
+
+</p>
+
+ <p><a href="/news/2021/08/31/release-statefun-3.1.0.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -376,21 +392,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2021/04/29/release-1.12.3.html">Apache Flink 1.12.3 Released</a></h2>
-
- <p>29 Apr 2021
- Arvid Heise </p>
-
- <p><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.12 series.</p>
-
-</p>
-
- <p><a href="/news/2021/04/29/release-1.12.3.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -423,6 +424,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page7/index.html b/content/blog/page7/index.html
index a2b27f96a..982f70524 100644
--- a/content/blog/page7/index.html
+++ b/content/blog/page7/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2021/04/29/release-1.12.3.html">Apache Flink 1.12.3 Released</a></h2>
+
+ <p>29 Apr 2021
+ Arvid Heise </p>
+
+ <p><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.12 series.</p>
+
+</p>
+
+ <p><a href="/news/2021/04/29/release-1.12.3.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -367,21 +382,6 @@ to develop scalable, consistent, and elastic distributed applications.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2021/01/02/release-statefun-2.2.2.html">Stateful Functions 2.2.2 Release Announcement</a></h2>
-
- <p>02 Jan 2021
- Tzu-Li (Gordon) Tai (<a href="https://twitter.com/tzulitai">@tzulitai</a>)</p>
-
- <p><p>The Apache Flink community released the second bugfix release of the Stateful Functions (StateFun) 2.2 series, version 2.2.2.</p>
-
-</p>
-
- <p><a href="/news/2021/01/02/release-statefun-2.2.2.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -414,6 +414,16 @@ to develop scalable, consistent, and elastic distributed applications.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page8/index.html b/content/blog/page8/index.html
index e202f078e..bac89c9ae 100644
--- a/content/blog/page8/index.html
+++ b/content/blog/page8/index.html
@@ -240,6 +240,21 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/news/2021/01/02/release-statefun-2.2.2.html">Stateful Functions 2.2.2 Release Announcement</a></h2>
+
+ <p>02 Jan 2021
+ Tzu-Li (Gordon) Tai (<a href="https://twitter.com/tzulitai">@tzulitai</a>)</p>
+
+ <p><p>The Apache Flink community released the second bugfix release of the Stateful Functions (StateFun) 2.2 series, version 2.2.2.</p>
+
+</p>
+
+ <p><a href="/news/2021/01/02/release-statefun-2.2.2.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -369,19 +384,6 @@ as well as increased observability for operational purposes.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/2020/09/01/flink-1.11-memory-management-improvements.html">Memory Management improvements for Flink’s JobManager in Apache Flink 1.11</a></h2>
-
- <p>01 Sep 2020
- Andrey Zagrebin </p>
-
- <p>In a previous blog post, we focused on the memory model of the TaskManagers and its improvements with the Apache Flink 1.10 release. This blog post addresses the same topic but for Flink's JobManager instead.</p>
-
- <p><a href="/2020/09/01/flink-1.11-memory-management-improvements.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -414,6 +416,16 @@ as well as increased observability for operational purposes.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/blog/page9/index.html b/content/blog/page9/index.html
index d003b5c93..7fb9ac697 100644
--- a/content/blog/page9/index.html
+++ b/content/blog/page9/index.html
@@ -240,6 +240,19 @@
<div class="col-sm-8">
<!-- Blog posts -->
+ <article>
+ <h2 class="blog-title"><a href="/2020/09/01/flink-1.11-memory-management-improvements.html">Memory Management improvements for Flink’s JobManager in Apache Flink 1.11</a></h2>
+
+ <p>01 Sep 2020
+ Andrey Zagrebin </p>
+
+ <p>In a previous blog post, we focused on the memory model of the TaskManagers and its improvements with the Apache Flink 1.10 release. This blog post addresses the same topic but for Flink's JobManager instead.</p>
+
+ <p><a href="/2020/09/01/flink-1.11-memory-management-improvements.html">Continue reading »</a></p>
+ </article>
+
+ <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>
@@ -363,21 +376,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2020/07/21/release-1.11.1.html">Apache Flink 1.11.1 Released</a></h2>
-
- <p>21 Jul 2020
- Dian Fu (<a href="https://twitter.com/DianFu11">@DianFu11</a>)</p>
-
- <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.11 series.</p>
-
-</p>
-
- <p><a href="/news/2020/07/21/release-1.11.1.html">Continue reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -410,6 +408,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></li>
diff --git a/content/downloads.html b/content/downloads.html
index 2435926c9..324f45c63 100644
--- a/content/downloads.html
+++ b/content/downloads.html
@@ -240,7 +240,7 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#apache-flink-1160" id="markdown-toc-apache-flink-1160">Apache Flink 1.16.0</a></li>
+ <li><a href="#apache-flink-1161" id="markdown-toc-apache-flink-1161">Apache Flink 1.16.1</a></li>
<li><a href="#apache-flink-1153" id="markdown-toc-apache-flink-1153">Apache Flink 1.15.3</a></li>
<li><a href="#flink-connectors" id="markdown-toc-flink-connectors">Flink connectors</a> <ul>
<li><a href="#apache-flink-elasticsearch-connector-300" id="markdown-toc-apache-flink-elasticsearch-connector-300">Apache Flink Elasticsearch Connector 3.0.0</a></li>
@@ -285,17 +285,17 @@
</div>
-<p>Apache Flink® 1.16.0 is our latest stable release.</p>
+<p>Apache Flink® 1.16.1 is our latest stable release.</p>
-<h2 id="apache-flink-1160">Apache Flink 1.16.0</h2>
+<h2 id="apache-flink-1161">Apache Flink 1.16.1</h2>
<p>
-<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz" id="1160-download_212">Apache Flink 1.16.0 for Scala 2.12</a> (<a href="https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz.sha512">sha512</a>)
+<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz" id="1161-download_212">Apache Flink 1.16.1 for Scala 2.12</a> (<a href="https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz.sha512">sha512</a>)
</p>
<p>
-<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.16.0/flink-1.16.0-src.tgz" id="1160-download-source">Apache Flink 1.16.0 Source Release</a>
-(<a href="https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-src.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-src.tgz.sha512">sha512</a>)
+<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.16.1/flink-1.16.1-src.tgz" id="1161-download-source">Apache Flink 1.16.1 Source Release</a>
+(<a href="https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-src.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-src.tgz.sha512">sha512</a>)
</p>
<h4 id="release-notes">Release Notes</h4>
@@ -486,7 +486,7 @@
(<a href="https://downloads.apache.org/flink/flink-kubernetes-operator-1.3.1/flink-kubernetes-operator-1.3.1-helm.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-kubernetes-operator-1.3.1/flink-kubernetes-operator-1.3.1-helm.tgz.sha512">sha512</a>)
</p>
-<p>This version is compatible with Apache Flink version 1.16.0, 1.15.3, 1.14.6, 1.13.6.</p>
+<p>This version is compatible with Apache Flink version 1.16.1, 1.15.3, 1.14.6, 1.13.6.</p>
<hr />
@@ -518,7 +518,7 @@
(<a href="https://downloads.apache.org/flink/flink-table-store-0.3.0/flink-table-store-dist-0.3.0.jar.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-table-store-0.3.0/flink-table-store-dist-0.3.0.jar.sha512">sha512</a>)
</p>
-<p>This version is compatible with Apache Flink version 1.16.0.</p>
+<p>This version is compatible with Apache Flink version 1.16.1.</p>
<hr />
@@ -599,17 +599,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.16.0<span class="nt"></version></span>
+ <span class="nt"><version></span>1.16.1<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<span class="nt"></artifactId></span>
- <span class="nt"><version></span>1.16.0<span class="nt"></version></span>
+ <span class="nt"><version></span>1.16.1<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<span class="nt"></artifactId></span>
- <span class="nt"><version></span>1.16.0<span class="nt"></version></span>
+ <span class="nt"><version></span>1.16.1<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3>
@@ -684,6 +684,17 @@ The <code>statefun-flink-harness</code> dependency includes a local execution en
<li>
+Flink 1.16.1 - 2023-01-26
+(<a href="https://archive.apache.org/dist/flink/flink-1.16.1/flink-1.16.1-src.tgz">Source</a>,
+<a href="https://archive.apache.org/dist/flink/flink-1.16.1">Binaries</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.16">Docs</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/api/java">Javadocs</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/api/scala/index.html">Scaladocs</a>)
+
+</li>
+
+<li>
+
Flink 1.16.0 - 2022-10-28
(<a href="https://archive.apache.org/dist/flink/flink-1.16.0/flink-1.16.0-src.tgz">Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.16.0">Binaries</a>,
diff --git a/content/index.html b/content/index.html
index 887592fbe..1634f5f64 100644
--- a/content/index.html
+++ b/content/index.html
@@ -405,6 +405,9 @@
<dl>
+ <dt> <a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></dt>
+ <dd>The Apache Flink Community is pleased to announce a bug fix release for Flink 1.16.</dd>
+
<dt> <a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></dt>
<dd><p>The Apache Flink Community is pleased to announce that the upcoming minor version of Flink (1.17) includes
the Delegation Token Framework proposed in <a href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-272%3A+Generalized+delegation+token+support">FLIP-272</a>.
@@ -425,9 +428,6 @@ tokens to the TaskManagers.</p>
<dd><p>The Flink community is happy to announce that the latest Flink Kubernetes Operator version went live today. Beyond the regular operator improvements and fixes the 1.3.0 version also integrates better with some popular infrastructure management tools like OLM and Argo CD. These improvements are clear indicators that the original intentions of the Flink community, namely to provide the de facto standard solution for managing Flink applications on Kubernetes is making steady [...]
</dd>
-
- <dt> <a href="/2022/11/25/async-sink-rate-limiting-strategy.html">Optimising the throughput of async sinks using a custom RateLimitingStrategy</a></dt>
- <dd>An overview of how to optimise the throughput of async sinks using a custom RateLimitingStrategy</dd>
</dl>
diff --git a/content/news/2023/01/30/release-1.16.1.html b/content/news/2023/01/30/release-1.16.1.html
new file mode 100644
index 000000000..79166b128
--- /dev/null
+++ b/content/news/2023/01/30/release-1.16.1.html
@@ -0,0 +1,507 @@
+<!DOCTYPE html>
+<html lang="en">
+ <head>
+ <meta charset="utf-8">
+ <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.16.1 Release Announcement</title>
+ <link rel="shortcut icon" href="/favicon.ico" type="image/x-icon">
+ <link rel="icon" href="/favicon.ico" type="image/x-icon">
+
+ <!-- Bootstrap -->
+ <link rel="stylesheet" href="/css/bootstrap.min.css">
+ <link rel="stylesheet" href="/css/flink.css">
+ <link rel="stylesheet" href="/css/syntax.css">
+
+ <!-- Blog RSS feed -->
+ <link href="/blog/feed.xml" rel="alternate" type="application/rss+xml" title="Apache Flink Blog: RSS feed" />
+
+ <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
+ <!-- We need to load Jquery in the header for custom google analytics event tracking-->
+ <script src="/js/jquery.min.js"></script>
+
+ <!-- HTML5 shim and Respond.js for IE8 support of HTML5 elements and media queries -->
+ <!-- WARNING: Respond.js doesn't work if you view the page via file:// -->
+ <!--[if lt IE 9]>
+ <script src="https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js"></script>
+ <script src="https://oss.maxcdn.com/respond/1.4.2/respond.min.js"></script>
+ <![endif]-->
+ <!-- Matomo -->
+ <script>
+ var _paq = window._paq = window._paq || [];
+ /* tracker methods like "setCustomDimension" should be called before "trackPageView" */
+ /* We explicitly disable cookie tracking to avoid privacy issues */
+ _paq.push(['disableCookies']);
+ /* Measure a visit to flink.apache.org and nightlies.apache.org/flink as the same visit */
+ _paq.push(["setDomains", ["*.flink.apache.org","*.nightlies.apache.org/flink"]]);
+ _paq.push(['trackPageView']);
+ _paq.push(['enableLinkTracking']);
+ (function() {
+ var u="//matomo.privacy.apache.org/";
+ _paq.push(['setTrackerUrl', u+'matomo.php']);
+ _paq.push(['setSiteId', '1']);
+ var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0];
+ g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s);
+ })();
+ </script>
+ <!-- End Matomo Code -->
+ </head>
+ <body>
+
+
+ <!-- Main content. -->
+ <div class="container">
+ <div class="row">
+
+
+ <div id="sidebar" class="col-sm-3">
+
+
+<!-- Top navbar. -->
+ <nav class="navbar navbar-default">
+ <!-- The logo. -->
+ <div class="navbar-header">
+ <button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#bs-example-navbar-collapse-1">
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ <span class="icon-bar"></span>
+ </button>
+ <div class="navbar-logo">
+ <a href="/">
+ <img alt="Apache Flink" src="/img/flink-header-logo.svg" width="147px" height="73px">
+ </a>
+ </div>
+ </div><!-- /.navbar-header -->
+
+ <!-- The navigation links. -->
+ <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1">
+ <ul class="nav navbar-nav navbar-main">
+
+ <!-- First menu section explains visitors what Flink is -->
+
+ <!-- What is Stream Processing? -->
+ <!--
+ <li><a href="/streamprocessing1.html">What is Stream Processing?</a></li>
+ -->
+
+ <!-- What is Flink? -->
+ <li><a href="/flink-architecture.html">What is Apache Flink?</a></li>
+
+
+
+ <!-- Stateful Functions? -->
+
+ <li><a href="https://nightlies.apache.org/flink/flink-statefun-docs-stable/">What is Stateful Functions?</a></li>
+
+ <!-- Flink ML? -->
+
+ <li><a href="https://nightlies.apache.org/flink/flink-ml-docs-stable/">What is Flink ML?</a></li>
+
+ <!-- Flink Kubernetes Operator? -->
+
+ <li><a href="https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-stable/">What is the Flink Kubernetes Operator?</a></li>
+
+ <!-- Flink Table Store? -->
+
+ <li><a href="https://nightlies.apache.org/flink/flink-table-store-docs-stable/">What is Flink Table Store?</a></li>
+
+ <!-- Use cases -->
+ <li><a href="/usecases.html">Use Cases</a></li>
+
+ <!-- Powered by -->
+ <li><a href="/poweredby.html">Powered By</a></li>
+
+
+
+ <!-- Second menu section aims to support Flink users -->
+
+ <!-- Downloads -->
+ <li><a href="/downloads.html">Downloads</a></li>
+
+ <!-- Getting Started -->
+ <li class="dropdown">
+ <a class="dropdown-toggle" data-toggle="dropdown" href="#">Getting Started<span class="caret"></span></a>
+ <ul class="dropdown-menu">
+ <li><a href="https://nightlies.apache.org/flink/flink-docs-release-1.16//docs/try-flink/local_installation/" target="_blank">With Flink <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-statefun-docs-release-3.2/getting-started/project-setup.html" target="_blank">With Flink Stateful Functions <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-ml-docs-release-2.1/try-flink-ml/quick-start.html" target="_blank">With Flink ML <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.3/try-flink-kubernetes-operator/quick-start.html" target="_blank">With Flink Kubernetes Operator <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-table-store-docs-release-0.3/try-table-store/quick-start.html" target="_blank">With Flink Table Store <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="/training.html">Training Course</a></li>
+ </ul>
+ </li>
+
+ <!-- Documentation -->
+ <li class="dropdown">
+ <a class="dropdown-toggle" data-toggle="dropdown" href="#">Documentation<span class="caret"></span></a>
+ <ul class="dropdown-menu">
+ <li><a href="https://nightlies.apache.org/flink/flink-docs-release-1.16" target="_blank">Flink 1.16 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-docs-master" target="_blank">Flink Master (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-statefun-docs-release-3.2" target="_blank">Flink Stateful Functions 3.2 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-statefun-docs-master" target="_blank">Flink Stateful Functions Master (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-ml-docs-release-2.1" target="_blank">Flink ML 2.1 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-ml-docs-master" target="_blank">Flink ML Master (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.3" target="_blank">Flink Kubernetes Operator 1.3 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main" target="_blank">Flink Kubernetes Operator Main (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-table-store-docs-release-0.3" target="_blank">Flink Table Store 0.3 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a href="https://nightlies.apache.org/flink/flink-table-store-docs-master" target="_blank">Flink Table Store Master (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ </ul>
+ </li>
+
+ <!-- getting help -->
+ <li><a href="/gettinghelp.html">Getting Help</a></li>
+
+ <!-- Blog -->
+ <li class="active"><a href="/blog/"><b>Flink Blog</b></a></li>
+
+
+ <!-- Flink-packages -->
+ <li>
+ <a href="https://flink-packages.org" target="_blank">flink-packages.org <small><span class="glyphicon glyphicon-new-window"></span></small></a>
+ </li>
+
+
+ <!-- Third menu section aim to support community and contributors -->
+
+ <!-- Community -->
+ <li><a href="/community.html">Community & Project Info</a></li>
+
+ <!-- Roadmap -->
+ <li><a href="/roadmap.html">Roadmap</a></li>
+
+ <!-- Contribute -->
+ <li><a href="/contributing/how-to-contribute.html">How to Contribute</a></li>
+
+
+ <!-- GitHub -->
+ <li>
+ <a href="https://github.com/apache/flink" target="_blank">Flink on GitHub <small><span class="glyphicon glyphicon-new-window"></span></small></a>
+ </li>
+
+
+
+ <!-- Language Switcher -->
+ <li>
+
+
+ <!-- link to the Chinese home page when current is blog page -->
+ <a href="/zh">中文版</a>
+
+
+ </li>
+
+ </ul>
+
+ <style>
+ .smalllinks:link {
+ display: inline-block !important; background: none; padding-top: 0px; padding-bottom: 0px; padding-right: 0px; min-width: 75px;
+ }
+ </style>
+
+ <ul class="nav navbar-nav navbar-bottom">
+ <hr />
+
+ <!-- Twitter -->
+ <li><a href="https://twitter.com/apacheflink" target="_blank">@ApacheFlink <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+
+ <!-- Visualizer -->
+ <li class=" hidden-md hidden-sm"><a href="/visualizer/" target="_blank">Plan Visualizer <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+
+ <li >
+ <a href="/security.html">Flink Security</a>
+ </li>
+
+ <hr />
+
+ <li><a href="https://apache.org" target="_blank">Apache Software Foundation <small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+
+ <li>
+
+ <a class="smalllinks" href="https://www.apache.org/licenses/" target="_blank">License</a> <small><span class="glyphicon glyphicon-new-window"></span></small>
+
+ <a class="smalllinks" href="https://www.apache.org/security/" target="_blank">Security</a> <small><span class="glyphicon glyphicon-new-window"></span></small>
+
+ <a class="smalllinks" href="https://www.apache.org/foundation/sponsorship.html" target="_blank">Donate</a> <small><span class="glyphicon glyphicon-new-window"></span></small>
+
+ <a class="smalllinks" href="https://www.apache.org/foundation/thanks.html" target="_blank">Thanks</a> <small><span class="glyphicon glyphicon-new-window"></span></small>
+ </li>
+
+ </ul>
+ </div><!-- /.navbar-collapse -->
+ </nav>
+
+ </div>
+ <div class="col-sm-9">
+ <div class="row-fluid">
+ <div class="col-sm-12">
+ <div class="row">
+ <h1>Apache Flink 1.16.1 Release Announcement</h1>
+ <p><i></i></p>
+
+ <article>
+ <p>30 Jan 2023 Martijn Visser (<a href="https://twitter.com/martijnvisser82">@martijnvisser82</a>)</p>
+
+<p>The Apache Flink Community is pleased to announce the first bug fix release of the Flink 1.16 series.</p>
+
+<p>This release includes 84 bug fixes, vulnerability fixes, and minor improvements for Flink 1.16.
+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=12352344">JIRA</a>.</p>
+
+<p>We highly recommend all users upgrade to Flink 1.16.1.</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"><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.16.1<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<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.16.1<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<span class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.16.1<span class="nt"></version></span>
+<span class="nt"></dependency></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&page=1&name=1.16.1">library/flink</a> (official images)</li>
+ <li><a href="https://hub.docker.com/r/apache/flink/tags?page=1&name=1.16.1">apache/flink</a> (ASF repository)</li>
+</ul>
+
+<h2 id="pypi">PyPi</h2>
+
+<ul>
+ <li><a href="https://pypi.org/project/apache-flink/1.16.1/">apache-flink==1.16.1</a></li>
+</ul>
+
+<h1 id="upgrade-notes">Upgrade Notes</h1>
+
+<p><a href="https://issues.apache.org/jira/browse/FLINK-28988">FLINK-28988 - Incorrect result for filter after temporal join</a>
+The filter will not be pushed down into both inputs of the event time temporal join.
+This may cause incompatible plan changes compared to Flink 1.16.0, e.g., when the left input is an upsert source
+(like upsert-kafka connector), the query plan will remove the ChangelogNormalize node in Flink 1.16.1, while it
+did appear in 1.16.0.</p>
+
+<p><a href="https://issues.apache.org/jira/browse/FLINK-29849">FLINK-29849 - Event time temporal join on an upsert source may produce incorrect execution plan</a>
+This resolves the correctness issue when doing an event time temporal join with a versioned table backed by an upsert source.
+When the right input of the join is an upsert source, it no longer generates a ChangelogNormalize node for it.
+This is an incompatible plan change compared to 1.16.0</p>
+
+<p><a href="https://issues.apache.org/jira/browse/FLINK-30383">FLINK-30383 - UseLogicalIdentifier makes datadog consider metric as custom</a>
+The Datadog reporter now adds a “flink.” prefix to metric identifiers if “useLogicalIdentifier” is enabled.
+This is required for these metrics to be recognized as Flink metrics, not custom ones.</p>
+
+<h1 id="release-notes">Release Notes</h1>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16582">FLINK-16582</a>] - NettyBufferPoolTest may have warns on NettyBuffer leak
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26037">FLINK-26037</a>] - TaskManagerRunner may crash during shutdown sequence
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26890">FLINK-26890</a>] - DynamoDB consumer error consuming partitions close to retention
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27341">FLINK-27341</a>] - TaskManager running together with JobManager are bind to 127.0.0.1
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27944">FLINK-27944</a>] - IO metrics collision happens if a task has union inputs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28102">FLINK-28102</a>] - Flink AkkaRpcSystemLoader fails when temporary directory is a symlink
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28526">FLINK-28526</a>] - Fail to lateral join with UDTF from Table with timstamp column
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28695">FLINK-28695</a>] - Fail to send partition request to restarted taskmanager
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28742">FLINK-28742</a>] - Table.to_pandas fails with lit("xxx")
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28786">FLINK-28786</a>] - Cannot run PyFlink 1.16 on MacOS with M1 chip
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28863">FLINK-28863</a>] - Snapshot result of RocksDB native savepoint should have empty shared-state
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28960">FLINK-28960</a>] - Pulsar throws java.lang.NoClassDefFoundError: javax/xml/bind/annotation/XmlElement
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28988">FLINK-28988</a>] - Incorrect result for filter after temporal join
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29231">FLINK-29231</a>] - PyFlink UDAF produces different results in the same sliding window
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29234">FLINK-29234</a>] - Dead lock in DefaultLeaderElectionService
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29298">FLINK-29298</a>] - LocalBufferPool request buffer from NetworkBufferPool hanging
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29479">FLINK-29479</a>] - Support whether using system PythonPath for PyFlink jobs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29539">FLINK-29539</a>] - dnsPolicy in FlinkPod is not overridable
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29615">FLINK-29615</a>] - MetricStore does not remove metrics of nonexistent subtasks when adaptive scheduler lowers job parallelism
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29627">FLINK-29627</a>] - Sink - Duplicate key exception during recover more than 1 committable.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29677">FLINK-29677</a>] - Prevent dropping the current catalog
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29728">FLINK-29728</a>] - TablePlanner prevents Flink from starting is working directory is a symbolic link
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29749">FLINK-29749</a>] - flink info command support dynamic properties
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29781">FLINK-29781</a>] - ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29803">FLINK-29803</a>] - Table API Scala APIs lack proper source jars
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29817">FLINK-29817</a>] - Published metadata for apache-flink in pypi are inconsistent and causes poetry to fail
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29827">FLINK-29827</a>] - [Connector][AsyncSinkWriter] Checkpointed states block writer from sending records
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29839">FLINK-29839</a>] - HiveServer2 endpoint doesn't support TGetInfoType value 'CLI_ODBC_KEYWORDS'
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29849">FLINK-29849</a>] - Event time temporal join on an upsert source may produce incorrect execution plan
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29857">FLINK-29857</a>] - Fix failure to connect to 'HiveServer2Endpoint' when using hive3 beeline
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29899">FLINK-29899</a>] - Stacktrace printing in DefaultExecutionGraphCacheTest is confusing maven test log output
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29923">FLINK-29923</a>] - Hybrid Shuffle may face deadlock when running a task need to execute big size data
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29927">FLINK-29927</a>] - AkkaUtils#getAddress may cause memory leak
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30030">FLINK-30030</a>] - Unexpected behavior for overwrite in Hive dialect
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30133">FLINK-30133</a>] - HadoopModuleFactory creates error if the security module cannot be loaded
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30168">FLINK-30168</a>] - PyFlink Deserialization Error with Object Array
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30189">FLINK-30189</a>] - HsSubpartitionFileReader may load data that has been consumed from memory
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30239">FLINK-30239</a>] - The flame graph doesn't work due to groupExecutionsByLocation has bug
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30304">FLINK-30304</a>] - Possible Deadlock in Kinesis/Firehose/DynamoDB Connector
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30308">FLINK-30308</a>] - ClassCastException: class java.io.ObjectStreamClass$Caches$1 cannot be cast to class java.util.Map is showing in the logging when the job shutdown
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30334">FLINK-30334</a>] - SourceCoordinator error splitRequest check cause HybridSource loss of data and hang
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30359">FLINK-30359</a>] - Encountered NoClassDefFoundError when using flink-sql-connector-elasticsearch6
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30366">FLINK-30366</a>] - Python Group Agg failed in cleaning the idle state
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30525">FLINK-30525</a>] - Cannot open jobmanager configuration web page
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30558">FLINK-30558</a>] - The metric 'numRestarts' reported in SchedulerBase will be overridden by metric 'fullRestarts'
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30637">FLINK-30637</a>] - In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27327">FLINK-27327</a>] - Add description about changing max parallelism explicitly leads to state incompatibility
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29134">FLINK-29134</a>] - fetch metrics may cause oom(ThreadPool task pile up)
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29155">FLINK-29155</a>] - Improve default config of grpcServer in Process Mode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29244">FLINK-29244</a>] - Add metric lastMaterializationDuration to ChangelogMaterializationMetricGroup
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29458">FLINK-29458</a>] - When two tables have the same field, do not specify the table name,Exception will be thrown：SqlValidatorException :Column 'currency' is ambiguous
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29639">FLINK-29639</a>] - Add ResourceId in TransportException for debugging
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29693">FLINK-29693</a>] - MiniClusterExtension should respect DEFAULT_PARALLELISM if set
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29834">FLINK-29834</a>] - Clear static Jackson TypeFactory cache on CL release
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29966">FLINK-29966</a>] - Replace and redesign the Python api documentation base
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30016">FLINK-30016</a>] - Update Flink 1.16 release notes about updated oshi-core
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30116">FLINK-30116</a>] - Don't Show Env Vars in Web UI
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30183">FLINK-30183</a>] - We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30357">FLINK-30357</a>] - Wrong link in connector/jdbc doc.
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30436">FLINK-30436</a>] - Integrate Opensearch connector docs into Flink docs v1.16
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30592">FLINK-30592</a>] - The unsupported hive version is not deleted on the hive overview document
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30633">FLINK-30633</a>] - Update AWS SDKv2 to v2.19.14
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30724">FLINK-30724</a>] - Update doc of kafka per-partition watermark to FLIP-27 source
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27731">FLINK-27731</a>] - Remove Hugo Modules integration
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29157">FLINK-29157</a>] - Clarify the contract between CompletedCheckpointStore and SharedStateRegistry
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29957">FLINK-29957</a>] - Rework connector docs integration
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29958">FLINK-29958</a>] - Add new connector_artifact shortcode
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29972">FLINK-29972</a>] - Pin Flink docs to Elasticsearch Connector 3.0.0
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-29973">FLINK-29973</a>] - connector_artifact should append Flink minor version
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30291">FLINK-30291</a>] - Integrate flink-connector-aws into Flink docs
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30382">FLINK-30382</a>] - Flink 1.16 to integrate KDS/KDF docs from flink-connector-aws
+</li>
+<li>[<a href="https://issues.apache.org/jira/browse/FLINK-30383">FLINK-30383</a>] - UseLogicalIdentifier makes datadog consider metric as custom
+</li>
+</ul>
+
+ </article>
+ </div>
+
+ <div class="row">
+ <div id="disqus_thread"></div>
+ <script type="text/javascript">
+ /* * * CONFIGURATION VARIABLES: EDIT BEFORE PASTING INTO YOUR WEBPAGE * * */
+ var disqus_shortname = 'stratosphere-eu'; // required: replace example with your forum shortname
+
+ /* * * DON'T EDIT BELOW THIS LINE * * */
+ (function() {
+ var dsq = document.createElement('script'); dsq.type = 'text/javascript'; dsq.async = true;
+ dsq.src = '//' + disqus_shortname + '.disqus.com/embed.js';
+ (document.getElementsByTagName('head')[0] || document.getElementsByTagName('body')[0]).appendChild(dsq);
+ })();
+ </script>
+ </div>
+ </div>
+</div>
+ </div>
+ </div>
+
+ <hr />
+
+ <div class="row">
+ <div class="footer text-center col-sm-12">
+ <p>Copyright © 2014-2022 <a href="http://apache.org">The Apache Software Foundation</a>. All Rights Reserved.</p>
+ <p>Apache Flink, Flink®, Apache®, the squirrel logo, and the Apache feather logo are either registered trademarks or trademarks of The Apache Software Foundation.</p>
+ <p><a href="https://privacy.apache.org/policies/privacy-policy-public.html">Privacy Policy</a> · <a href="/blog/feed.xml">RSS feed</a></p>
+ </div>
+ </div>
+ </div><!-- /.container -->
+
+ <!-- Include all compiled plugins (below), or include individual files as needed -->
+ <script src="/js/jquery.matchHeight-min.js"></script>
+ <script src="/js/bootstrap.min.js"></script>
+ <script src="/js/codetabs.js"></script>
+ <script src="/js/stickysidebar.js"></script>
+ </body>
+</html>
diff --git a/content/q/gradle-quickstart.sh b/content/q/gradle-quickstart.sh
index b6e2f6502..253313ffb 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.16.0}"
+defaultFlinkVersion="${1:-1.16.1}"
# flink-docs-master/docs/dev/datastream/project-configuration/#gradle
# passes the scala version prefixed with a _, e.g.: _2.12
scalaBinaryVersionFromCmdArg="${2/_/}"
@@ -114,9 +114,9 @@ ext {
javaVersion = '1.8'
flinkVersion = '${flinkVersion}'
scalaBinaryVersion = '${scalaBinaryVersion}'
- slf4jVersion = '1.7.32'
+ slf4jVersion = '1.7.36'
log4jVersion = '2.17.1'
- flinkVersionNew = flinkVersion.toString().replace("-SNAPSHOT", "") >= "1.15"
+ flinkVersionNew = flinkVersion.toString().replace("-SNAPSHOT", "") >= "1.16"
}
// artifact properties
diff --git a/content/q/quickstart-scala.sh b/content/q/quickstart-scala.sh
index 924fdf2df..3f501f02f 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.16.0} \
+ -DarchetypeVersion=${1:-1.16.1} \
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE \
-Dversion=0.1 \
diff --git a/content/q/quickstart.sh b/content/q/quickstart.sh
index 8a4abe060..e9d2bbe4e 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.16.0} \
+ -DarchetypeVersion=${1:-1.16.1} \
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE \
-Dversion=0.1 \
diff --git a/content/q/sbt-quickstart.sh b/content/q/sbt-quickstart.sh
index b9e8a1013..40a3bf013 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.16.0"
+defaultFlinkVersion="1.16.1"
echo "This script creates a Flink project using Scala and SBT."
@@ -103,9 +103,9 @@ version := \"0.1-SNAPSHOT\"
organization := \"org.example\"
-ThisBuild / scalaVersion := \"2.11.12\"
+ThisBuild / scalaVersion := \"2.12.7\"
-val flinkVersion = \"1.14.0\"
+val flinkVersion = \"1.16.1\"
val flinkDependencies = Seq(
\"org.apache.flink\" %% \"flink-scala\" % flinkVersion % \"provided\",
diff --git a/content/zh/downloads.html b/content/zh/downloads.html
index 1903a24be..984184875 100644
--- a/content/zh/downloads.html
+++ b/content/zh/downloads.html
@@ -238,7 +238,7 @@
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#apache-flink-1160" id="markdown-toc-apache-flink-1160">Apache Flink 1.16.0</a></li>
+ <li><a href="#apache-flink-1161" id="markdown-toc-apache-flink-1161">Apache Flink 1.16.1</a></li>
<li><a href="#apache-flink-1153" id="markdown-toc-apache-flink-1153">Apache Flink 1.15.3</a></li>
<li><a href="#flink-connectors" id="markdown-toc-flink-connectors">Flink connectors</a> <ul>
<li><a href="#apache-flink-elasticsearch-connector-300" id="markdown-toc-apache-flink-elasticsearch-connector-300">Apache Flink Elasticsearch Connector 3.0.0</a></li>
@@ -278,18 +278,18 @@
</div>
-<p>Apache Flink® 1.16.0 是我们最新的稳定版本。</p>
+<p>Apache Flink® 1.16.1 是我们最新的稳定版本。</p>
-<h2 id="apache-flink-1160">Apache Flink 1.16.0</h2>
+<h2 id="apache-flink-1161">Apache Flink 1.16.1</h2>
<p>
-<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz" id="1160-download_212">Apache Flink 1.16.0 for Scala 2.12</a> (<a href="
- https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz.sha512">sha512</a>)
+<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz" id="1161-download_212">Apache Flink 1.16.1 for Scala 2.12</a> (<a href="
+ https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-bin-scala_2.12.tgz.sha512">sha512</a>)
</p>
<p>
-<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.16.0/flink-1.16.0-src.tgz" id="1160-download-source">Apache Flink 1.16.0 Source Release</a>
- (<a href="https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-src.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.16.0/flink-1.16.0-src.tgz.sha512">sha512</a>)
+<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.16.1/flink-1.16.1-src.tgz" id="1161-download-source">Apache Flink 1.16.1 Source Release</a>
+ (<a href="https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-src.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.16.1/flink-1.16.1-src.tgz.sha512">sha512</a>)
</p>
<h4 id="section">发布说明</h4>
@@ -483,7 +483,7 @@ flink-docs-release-1.15/release-notes/flink-1.15.html">Flink 1.15 的发布说
(<a href="https://downloads.apache.org/flink/flink-table-store-0.3.0/flink-table-store-dist-0.3.0.jar.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-table-store-0.3.0/flink-table-store-dist-0.3.0.jar.sha512">sha512</a>)
</p>
-<p>这个版本和 Apache Flink 版本 1.16.0 兼容。</p>
+<p>这个版本和 Apache Flink 版本 1.16.1 兼容。</p>
<hr />
@@ -563,17 +563,17 @@ flink-docs-release-1.15/release-notes/flink-1.15.html">Flink 1.15 的发布说
<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.16.0<span class="nt"></version></span>
+ <span class="nt"><version></span>1.16.1<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<span class="nt"></artifactId></span>
- <span class="nt"><version></span>1.16.0<span class="nt"></version></span>
+ <span class="nt"><version></span>1.16.1<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<span class="nt"></artifactId></span>
- <span class="nt"><version></span>1.16.0<span class="nt"></version></span>
+ <span class="nt"><version></span>1.16.1<span class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3>
@@ -635,6 +635,17 @@ flink-docs-release-1.15/release-notes/flink-1.15.html">Flink 1.15 的发布说
<li>
+Flink 1.16.1 - 2023-01-26
+(<a href="https://archive.apache.org/dist/flink/flink-1.16.1/flink-1.16.1-src.tgz">Source</a>,
+<a href="https://archive.apache.org/dist/flink/flink-1.16.1">Binaries</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.16">Docs</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/api/java">Javadocs</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.16/api/scala/index.html">Scaladocs</a>)
+
+</li>
+
+<li>
+
Flink 1.16.0 - 2022-10-28
(<a href="https://archive.apache.org/dist/flink/flink-1.16.0/flink-1.16.0-src.tgz">Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.16.0">Binaries</a>,
diff --git a/content/zh/index.html b/content/zh/index.html
index 07648b578..518d83678 100644
--- a/content/zh/index.html
+++ b/content/zh/index.html
@@ -402,6 +402,9 @@
<dl>
+ <dt> <a href="/news/2023/01/30/release-1.16.1.html">Apache Flink 1.16.1 Release Announcement</a></dt>
+ <dd>The Apache Flink Community is pleased to announce a bug fix release for Flink 1.16.</dd>
+
<dt> <a href="/news/2023/01/20/delegation-token-framework.html">Delegation Token Framework: Obtain, Distribute and Use Temporary Credentials Automatically</a></dt>
<dd><p>The Apache Flink Community is pleased to announce that the upcoming minor version of Flink (1.17) includes
the Delegation Token Framework proposed in <a href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-272%3A+Generalized+delegation+token+support">FLIP-272</a>.
@@ -422,9 +425,6 @@ tokens to the TaskManagers.</p>
<dd><p>The Flink community is happy to announce that the latest Flink Kubernetes Operator version went live today. Beyond the regular operator improvements and fixes the 1.3.0 version also integrates better with some popular infrastructure management tools like OLM and Argo CD. These improvements are clear indicators that the original intentions of the Flink community, namely to provide the de facto standard solution for managing Flink applications on Kubernetes is making steady [...]
</dd>
-
- <dt> <a href="/2022/11/25/async-sink-rate-limiting-strategy.html">Optimising the throughput of async sinks using a custom RateLimitingStrategy</a></dt>
- <dd>An overview of how to optimise the throughput of async sinks using a custom RateLimitingStrategy</dd>
</dl>