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 <[email protected]>
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>
