This is an automated email from the ASF dual-hosted git repository.
tangyun 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 9e8fb58 Rebuild website
9e8fb58 is described below
commit 9e8fb58ca7836181764eafc01f6817448b0b1964
Author: Myasuka <[email protected]>
AuthorDate: Fri Aug 6 13:34:32 2021 +0800
Rebuild website
---
content/blog/feed.xml | 487 +++++++++++++++---------
content/blog/index.html | 38 +-
content/blog/page10/index.html | 40 +-
content/blog/page11/index.html | 40 +-
content/blog/page12/index.html | 40 +-
content/blog/page13/index.html | 38 +-
content/blog/page14/index.html | 36 +-
content/blog/page15/index.html | 38 +-
content/blog/page16/index.html | 25 ++
content/blog/page2/index.html | 38 +-
content/blog/page3/index.html | 38 +-
content/blog/page4/index.html | 40 +-
content/blog/page5/index.html | 43 ++-
content/blog/page6/index.html | 39 +-
content/blog/page7/index.html | 38 +-
content/blog/page8/index.html | 38 +-
content/blog/page9/index.html | 38 +-
content/downloads.html | 31 +-
content/index.html | 8 +-
content/news/2021/08/06/release-1.13.2.html | 560 ++++++++++++++++++++++++++++
content/q/gradle-quickstart.sh | 2 +-
content/q/quickstart-scala.sh | 2 +-
content/q/quickstart.sh | 2 +-
content/q/sbt-quickstart.sh | 4 +-
content/zh/downloads.html | 35 +-
content/zh/index.html | 8 +-
26 files changed, 1322 insertions(+), 424 deletions(-)
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 9b414da..f2f0c7c 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,318 @@
<atom:link href="https://flink.apache.org/blog/feed.xml"; rel="self"
type="application/rss+xml" />
<item>
+<title>Apache Flink 1.13.2 Released</title>
+<description><p>The Apache Flink community released the second bugfix
version of the Apache Flink 1.13 series.</p>
+
+<p>This release includes 127 fixes and minor improvements for Flink
1.13.2. The list below includes bugfixes and improvements. For a complete list
of all changes see:
+<a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?version=12350218&amp;styleName=&amp;projectId=12315522">JIRA</a>.</p>
+
+<p>We highly recommend all users to upgrade to Flink 1.13.2.</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.13.2<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.13.2<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.13.2<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>
+
+<div class="highlight"><pre><code> Release
Notes - Flink - Version 1.13.2
+</code></pre></div>
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22726">FLINK-22726</a>]
- Hive GROUPING__ID returns different value in older versions
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20888">FLINK-20888</a>]
- ContinuousFileReaderOperator should not close the output on close()
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20975">FLINK-20975</a>]
- HiveTableSourceITCase.testPartitionFilter fails on AZP
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21389">FLINK-21389</a>]
- ParquetInputFormat should not need parquet schema as user input
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21445">FLINK-21445</a>]
- Application mode does not set the configuration when building
PackagedProgram
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21952">FLINK-21952</a>]
- Make all the &quot;Connection reset by peer&quot; exception
wrapped as RemoteTransportException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22045">FLINK-22045</a>]
- Set log level for shaded zookeeper logger
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22195">FLINK-22195</a>]
- YARNHighAvailabilityITCase.testClusterClientRetrieval because of
TestTimedOutException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22203">FLINK-22203</a>]
- KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to
ConcurrentModificationException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22272">FLINK-22272</a>]
- Some scenes can&#39;t drop table by hive catalog
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22312">FLINK-22312</a>]
-
YARNSessionFIFOSecuredITCase&gt;YARNSessionFIFOITCase.checkForProhibitedLogContents
due to the heartbeat exception with Yarn RM
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22376">FLINK-22376</a>]
- SequentialChannelStateReaderImpl may recycle buffer twice
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22443">FLINK-22443</a>]
- can not be execute an extreme long sql under batch mode
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22462">FLINK-22462</a>]
- JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many
clients.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22464">FLINK-22464</a>]
-
OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure
hangs with `AdaptiveScheduler`
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22492">FLINK-22492</a>]
- KinesisTableApiITCase with wrong results
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22496">FLINK-22496</a>]
- ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook
failed
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22545">FLINK-22545</a>]
- JVM crashes when runing
OperatorEventSendingCheckpointITCase.testOperatorEventAckLost
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22547">FLINK-22547</a>]
- OperatorCoordinatorHolderTest.
verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22613">FLINK-22613</a>]
- FlinkKinesisITCase.testStopWithSavepoint fails
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22662">FLINK-22662</a>]
- YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22683">FLINK-22683</a>]
- The total Flink/process memory of memoryConfiguration in
/taskmanagers can be null or incorrect value
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22686">FLINK-22686</a>]
- Incompatible subtask mappings while resuming from unaligned
checkpoints
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22689">FLINK-22689</a>]
- Table API Documentation Row-Based Operations Example Fails
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22698">FLINK-22698</a>]
- RabbitMQ source does not stop unless message arrives in queue
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22725">FLINK-22725</a>]
- SlotManagers should unregister metrics at the start of suspend()
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22730">FLINK-22730</a>]
- Lookup join condition with CURRENT_DATE fails to filter records
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22746">FLINK-22746</a>]
- Links to connectors in docs are broken
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22759">FLINK-22759</a>]
- Correct the applicability of RocksDB related options as per operator
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22760">FLINK-22760</a>]
- HiveParser::setCurrentTimestamp fails with hive-3.1.2
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22777">FLINK-22777</a>]
- Restore lost sections in Try Flink DataStream API example
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22779">FLINK-22779</a>]
- KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due
to ConcurrentModificationException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22786">FLINK-22786</a>]
- sql-client can not create .flink-sql-history file
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22795">FLINK-22795</a>]
- Throw better exception when executing remote SQL file in SQL Client
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22796">FLINK-22796</a>]
- Update mem_setup_tm documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22814">FLINK-22814</a>]
- New sources are not defining/exposing checkpointStartDelayNanos
metric
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22815">FLINK-22815</a>]
- Disable unaligned checkpoints for broadcast partitioning
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22819">FLINK-22819</a>]
- YARNFileReplicationITCase fails with &quot;The YARN application
unexpectedly switched to state FAILED during deployment&quot;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22820">FLINK-22820</a>]
- Stopping Yarn session cluster will cause fatal error
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22833">FLINK-22833</a>]
- Source tasks (both old and new) are not reporting
checkpointStartDelay via CheckpointMetrics
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22856">FLINK-22856</a>]
- Move our Azure pipelines away from Ubuntu 16.04 by September
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22863">FLINK-22863</a>]
- ArrayIndexOutOfBoundsException may happen when building rescale edges
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22884">FLINK-22884</a>]
- Select view columns fail when store metadata with hive
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22886">FLINK-22886</a>]
- Thread leak in RocksDBStateUploader
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22890">FLINK-22890</a>]
- Few tests fail in HiveTableSinkITCase
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22894">FLINK-22894</a>]
- Window Top-N should allow n=1
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22898">FLINK-22898</a>]
- HiveParallelismInference limit return wrong parallelism
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22908">FLINK-22908</a>]
- FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown
should wait until job is running
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22927">FLINK-22927</a>]
- Exception on JobClient.get_job_status().result()
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22945">FLINK-22945</a>]
- StackOverflowException can happen when a large scale job is
CANCELING/FAILING
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22946">FLINK-22946</a>]
- Network buffer deadlock introduced by unaligned checkpoint
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22948">FLINK-22948</a>]
- Scala example for toDataStream does not compile
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22952">FLINK-22952</a>]
- docs_404_check fail on azure due to ruby version not available
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22961">FLINK-22961</a>]
- Incorrect calculation of alignment timeout for LocalInputChannel
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22963">FLINK-22963</a>]
- The description of taskmanager.memory.task.heap.size in the official
document is incorrect
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22964">FLINK-22964</a>]
- Connector-base exposes dependency to flink-core.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22966">FLINK-22966</a>]
- NPE in StateAssignmentOperation when rescaling
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22980">FLINK-22980</a>]
- FileExecutionGraphInfoStoreTest hangs on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22982">FLINK-22982</a>]
- java.lang.ClassCastException when using Python UDF
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22987">FLINK-22987</a>]
- Scala suffix check isn&#39;t working
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22993">FLINK-22993</a>]
- CompactFileWriter won&#39;t emit EndCheckpoint with
Long.MAX_VALUE checkpointId
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23001">FLINK-23001</a>]
- flink-avro-glue-schema-registry lacks scala suffix
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23003">FLINK-23003</a>]
- Resource leak in RocksIncrementalSnapshotStrategy
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23010">FLINK-23010</a>]
- HivePartitionFetcherContextBase::getComparablePartitionValueList can
return partitions that don&#39;t exist
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23018">FLINK-23018</a>]
- State factories should handle extended state descriptors
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23024">FLINK-23024</a>]
- RPC result TaskManagerInfoWithSlots not serializable
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23025">FLINK-23025</a>]
- sink-buffer-max-rows and sink-buffer-flush-interval options produce
a lot of duplicates
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23030">FLINK-23030</a>]
- PartitionRequestClientFactory#createPartitionRequestClient should
throw when network failure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23034">FLINK-23034</a>]
- NPE in JobDetailsDeserializer during the reading old version of
ExecutionState
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23045">FLINK-23045</a>]
- RunnablesTest.testExecutorService_uncaughtExceptionHandler fails on
azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23073">FLINK-23073</a>]
- Fix space handling in Row CSV timestamp parser
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23074">FLINK-23074</a>]
- There is a class conflict between flink-connector-hive and
flink-parquet
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23092">FLINK-23092</a>]
- Built-in UDAFs could not be mixed use with Python UDAF in group
window
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23096">FLINK-23096</a>]
- HiveParser could not attach the sessionstate of hive
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23119">FLINK-23119</a>]
- Fix the issue that the exception that General Python UDAF is
unsupported is not thrown in Compile Stage.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23120">FLINK-23120</a>]
- ByteArrayWrapperSerializer.serialize should use writeInt to
serialize the length
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23121">FLINK-23121</a>]
- Fix the issue that the InternalRow as arguments in Python UDAF
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23129">FLINK-23129</a>]
- When cancelling any running job of multiple jobs in an application
cluster, JobManager shuts down
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23133">FLINK-23133</a>]
- The dependencies are not handled properly when mixing use of Python
Table API and Python DataStream API
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23151">FLINK-23151</a>]
- KinesisTableApiITCase.testTableApiSourceAndSink fails on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23166">FLINK-23166</a>]
- ZipUtils doesn&#39;t handle properly for softlinks inside the
zip file
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23182">FLINK-23182</a>]
- Connection leak in RMQSource
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23184">FLINK-23184</a>]
- CompileException Assignment conversion not possible from type
&quot;int&quot; to type &quot;short&quot;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23188">FLINK-23188</a>]
- Unsupported function definition: IFNULL. Only user defined functions
are supported as inline functions
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23196">FLINK-23196</a>]
- JobMasterITCase fail on azure due to BindException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23201">FLINK-23201</a>]
- The check on alignmentDurationNanos seems to be too strict
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23223">FLINK-23223</a>]
- When flushAlways is enabled the subpartition may lose notification
of data availability
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23233">FLINK-23233</a>]
-
OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure
fails on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23235">FLINK-23235</a>]
-
SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails on
azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23248">FLINK-23248</a>]
- SinkWriter is not closed when failing
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23259">FLINK-23259</a>]
- [DOCS]The &#39;window&#39; link on page
docs/dev/datastream/operators/overview is failed and 404 is returned
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23260">FLINK-23260</a>]
- [DOCS]The link on page docs/libs/gelly/overview is failed and 404 is
returned
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23270">FLINK-23270</a>]
- Impove description of Regular Joins section
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23280">FLINK-23280</a>]
- Python ExplainDetails does not have JSON_EXECUTION_PLAN option
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23306">FLINK-23306</a>]
- FlinkRelMdUniqueKeys causes exception when used with new Schema
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23359">FLINK-23359</a>]
- Fix the number of available slots in
testResourceCanBeAllocatedForDifferentJobAfterFree
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23368">FLINK-23368</a>]
- Fix the wrong mapping of state cache in PyFlink
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23429">FLINK-23429</a>]
- State Processor API failed with FileNotFoundException when working
with state files on Cloud Storage
+</li>
+</ul>
+
+<h2> New Feature
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22770">FLINK-22770</a>]
- Expose SET/RESET from the parser
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-18182">FLINK-18182</a>]
- Upgrade AWS SDK in flink-connector-kinesis to include new region
af-south-1
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20140">FLINK-20140</a>]
- Add documentation of TableResult.collect for Python Table API
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21229">FLINK-21229</a>]
- Support ssl connection with schema registry format
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21393">FLINK-21393</a>]
- Implement ParquetAvroInputFormat
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21411">FLINK-21411</a>]
- The components on which Flink depends may contain vulnerabilities.
If yes, fix them.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22528">FLINK-22528</a>]
- Document latency tracking metrics for state accesses
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22638">FLINK-22638</a>]
- Keep channels blocked on alignment timeout
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22655">FLINK-22655</a>]
- When using -i &lt;init.sql&gt; option to initialize SQL
Client session It should be possible to annotate the script with --
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22722">FLINK-22722</a>]
- Add Documentation for Kafka New Source
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22747">FLINK-22747</a>]
- Update commons-io to 2.8
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22766">FLINK-22766</a>]
- Report metrics of KafkaConsumer in Kafka new source
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22774">FLINK-22774</a>]
- Update Kinesis SQL connector&#39;s Guava to 27.0-jre
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22855">FLINK-22855</a>]
- Translate the &#39;Overview of Python API&#39; page into
Chinese.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22873">FLINK-22873</a>]
- Add ToC to configuration documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22905">FLINK-22905</a>]
- Fix missing comma in SQL example in &quot;Versioned
Table&quot; page
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22939">FLINK-22939</a>]
- Generalize JDK switch in azure setup
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22996">FLINK-22996</a>]
- The description about coalesce is wrong
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23009">FLINK-23009</a>]
- Bump up Guava in Kinesis Connector
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23052">FLINK-23052</a>]
- cron_snapshot_deployment_maven unstable on maven
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23138">FLINK-23138</a>]
- Raise an exception if types other than PickledBytesTypeInfo are
specified for state descriptor
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23156">FLINK-23156</a>]
- Change the reference of &#39;docs/dev/table/sql/queries&#39;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23157">FLINK-23157</a>]
- Fix missing comma in SQL example in &quot;Versioned
View&quot; page
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23162">FLINK-23162</a>]
- Create table uses time_ltz in the column name and it&#39;s
expression which results in exception
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23168">FLINK-23168</a>]
- Catalog shouldn&#39;t merge properties for alter DB operation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23178">FLINK-23178</a>]
- Raise an error for writing stream data into partitioned hive tables
without a partition committer
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23200">FLINK-23200</a>]
- Correct grammatical mistakes in &#39;Table API&#39; page of
&#39;Table API &amp; SQL&#39;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23226">FLINK-23226</a>]
- Flink Chinese doc learn-flink/etl transformation.svg display issue
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23312">FLINK-23312</a>]
- Use -Dfast for building e2e tests on AZP
+</li>
+</ul>
+
+</description>
+<pubDate>Fri, 06 Aug 2021 02:00:00 +0200</pubDate>
+<link>https://flink.apache.org/news/2021/08/06/release-1.13.2.html</link>
+<guid isPermaLink="true">/news/2021/08/06/release-1.13.2.html</guid>
+</item>
+
+<item>
<title>How to identify the source of backpressure?</title>
<description><div class="page-toc">
<ul id="markdown-toc">
@@ -19076,180 +19388,5 @@ Feedback through the Flink <a
href="http://flink.apache.org/community.ht
<guid
isPermaLink="true">/features/2018/03/01/end-to-end-exactly-once-apache-flink.html</guid>
</item>
-<item>
-<title>Apache Flink 1.4.1 Released</title>
-<description><p>The Apache Flink community released the first bugfix
version of the Apache Flink 1.4 series.</p>
-
-<p>This release includes more than 60 fixes and minor improvements for
Flink 1.4.0. The list below includes a detailed list of all fixes.</p>
-
-<p>We highly recommend all users to upgrade to Flink 1.4.1.</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.4.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_2.11<span
class="nt">&lt;/artifactId&gt;</span>
- <span
class="nt">&lt;version&gt;</span>1.4.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_2.11<span
class="nt">&lt;/artifactId&gt;</span>
- <span
class="nt">&lt;version&gt;</span>1.4.1<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="http://flink.apache.org/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-6321">FLINK-6321</a>]
- RocksDB state backend Checkpointing is not working with KeyedCEP.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-7499">FLINK-7499</a>]
- double buffer release in SpillableSubpartitionView
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-7756">FLINK-7756</a>]
- RocksDB state backend Checkpointing (Async and Incremental) is not
working with CEP.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-7760">FLINK-7760</a>]
- Restore failing from external checkpointing metadata.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8323">FLINK-8323</a>]
- Fix Mod scala function bug
-</li>
-</ul>
-
-<h2> Bug
-</h2>
-<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-5506">FLINK-5506</a>]
- Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-6951">FLINK-6951</a>]
- Incompatible versions of httpcomponents jars for Flink kinesis
connector
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-7949">FLINK-7949</a>]
- AsyncWaitOperator is not restarting when queue is full
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8145">FLINK-8145</a>]
- IOManagerAsync not properly shut down in various tests
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8200">FLINK-8200</a>]
- RocksDBAsyncSnapshotTest should use temp fold instead of fold with
fixed name
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8226">FLINK-8226</a>]
- Dangling reference generated after NFA clean up timed out
SharedBufferEntry
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8230">FLINK-8230</a>]
- NPE in OrcRowInputFormat on nested structs
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8235">FLINK-8235</a>]
- Cannot run spotbugs for single module
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8242">FLINK-8242</a>]
- ClassCastException in OrcTableSource.toOrcPredicate
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8248">FLINK-8248</a>]
- RocksDB state backend Checkpointing is not working with KeyedCEP in
1.4
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8249">FLINK-8249</a>]
- Kinesis Producer didnt configure region
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8261">FLINK-8261</a>]
- Typos in the shading exclusion for jsr305 in the quickstarts
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8263">FLINK-8263</a>]
- Wrong packaging of flink-core in scala quickstarty
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8265">FLINK-8265</a>]
- Missing jackson dependency for flink-mesos
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8270">FLINK-8270</a>]
- TaskManagers do not use correct local path for shipped Keytab files
in Yarn deployment modes
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8275">FLINK-8275</a>]
- Flink YARN deployment with Kerberos enabled not working
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8278">FLINK-8278</a>]
- Scala examples in Metric documentation do not compile
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8283">FLINK-8283</a>]
- FlinkKafkaConsumerBase failing on Travis with no output in 10min
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8295">FLINK-8295</a>]
- Netty shading does not work properly
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8306">FLINK-8306</a>]
- FlinkKafkaConsumerBaseTest has invalid mocks on final methods
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8318">FLINK-8318</a>]
- Conflict jackson library with ElasticSearch connector
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8325">FLINK-8325</a>]
- Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1)
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8352">FLINK-8352</a>]
- Flink UI Reports No Error on Job Submission Failures
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8355">FLINK-8355</a>]
- DataSet Should not union a NULL row for AGG without GROUP BY clause.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8371">FLINK-8371</a>]
- Buffers are not recycled in a non-spilled SpillableSubpartition upon
release
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8398">FLINK-8398</a>]
- Stabilize flaky KinesisDataFetcherTests
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8406">FLINK-8406</a>]
- BucketingSink does not detect hadoop file systems
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8409">FLINK-8409</a>]
- Race condition in KafkaConsumerThread leads to potential NPE
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8419">FLINK-8419</a>]
- Kafka consumer&#39;s offset metrics are not registered for
dynamically discovered partitions
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8421">FLINK-8421</a>]
- HeapInternalTimerService should reconfigure compatible key /
namespace serializers on restore
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8433">FLINK-8433</a>]
- Update code example for &quot;Managed Operator State&quot;
documentation
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8461">FLINK-8461</a>]
- Wrong logger configurations for shaded Netty
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8466">FLINK-8466</a>]
- ErrorInfo needs to hold Exception as SerializedThrowable
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8484">FLINK-8484</a>]
- Kinesis consumer re-reads closed shards on job restart
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8485">FLINK-8485</a>]
- Running Flink inside Intellij no longer works after upgrading from
1.3.2 to 1.4.0
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8489">FLINK-8489</a>]
- Data is not emitted by second ElasticSearch connector
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8496">FLINK-8496</a>]
- WebUI does not display TM MemorySegment metrics
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8499">FLINK-8499</a>]
- Kryo must not be child-first loaded
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8522">FLINK-8522</a>]
- DefaultOperatorStateBackend writes data in checkpoint that is never
read.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8559">FLINK-8559</a>]
- Exceptions in RocksDBIncrementalSnapshotOperation#takeSnapshot cause
job to get stuck
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8561">FLINK-8561</a>]
- SharedBuffer line 573 uses == to compare BufferEntries instead of
.equals.
-</li>
-</ul>
-
-<h2> Improvement
-</h2>
-<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8079">FLINK-8079</a>]
- Skip remaining E2E tests if one failed
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8202">FLINK-8202</a>]
- Update queryable section on configuration page
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8243">FLINK-8243</a>]
- OrcTableSource should recursively read all files in nested
directories of the input path.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8260">FLINK-8260</a>]
- Document API of Kafka 0.11 Producer
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8264">FLINK-8264</a>]
- Add Scala to the parent-first loading patterns
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8271">FLINK-8271</a>]
- upgrade from deprecated classes to AmazonKinesis
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8287">FLINK-8287</a>]
- Flink Kafka Producer docs should clearly state what partitioner is
used by default
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8296">FLINK-8296</a>]
- Rework FlinkKafkaConsumerBestTest to not use Java reflection for
dependency injection
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8346">FLINK-8346</a>]
- add S3 signature v4 workaround to docs
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8362">FLINK-8362</a>]
- Shade Elasticsearch dependencies away
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8455">FLINK-8455</a>]
- Add Hadoop to the parent-first loading patterns
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8473">FLINK-8473</a>]
- JarListHandler may fail with NPE if directory is deleted
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8571">FLINK-8571</a>]
- Provide an enhanced KeyedStream implementation to use
ForwardPartitioner
-</li>
-</ul>
-
-<h2> Test
-</h2>
-<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-8472">FLINK-8472</a>]
- Extend migration tests for Flink 1.4
-</li>
-</ul>
-</description>
-<pubDate>Thu, 15 Feb 2018 13:00:00 +0100</pubDate>
-<link>https://flink.apache.org/news/2018/02/15/release-1.4.1.html</link>
-<guid isPermaLink="true">/news/2018/02/15/release-1.4.1.html</guid>
-</item>
-
</channel>
</rss>
diff --git a/content/blog/index.html b/content/blog/index.html
index 067b4b1..e497a2f 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></h2>
+
+ <p>06 Aug 2021
+ Yun Tang </p>
+
+ <p><p>The Apache Flink community released the second bugfix version of
the Apache Flink 1.13 series.</p>
+
+</p>
+
+ <p><a href="/news/2021/08/06/release-1.13.2.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/2021/07/07/backpressure.html">How to
identify the source of backpressure?</a></h2>
<p>07 Jul 2021
@@ -329,19 +344,6 @@ to develop scalable, consistent, and elastic distributed
applications.</p>
<hr>
- <article>
- <h2 class="blog-title"><a href="/2021/02/10/native-k8s-with-ha.html">How
to natively deploy Flink on Kubernetes with High-Availability (HA)</a></h2>
-
- <p>10 Feb 2021
- Yang Wang </p>
-
- <p>Kubernetes provides built-in functionalities that Flink can leverage
for JobManager failover. In Flink 1.12 (FLIP-144), the community implemented a
Kubernetes High Availability (HA) service as an alternative to ZooKeeper for
highly available production setups. In this blogpost, we will have a close look
at how to deploy Flink applications natively on Kubernetes cluster with HA.</p>
-
- <p><a href="/2021/02/10/native-k8s-with-ha.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -374,6 +376,16 @@ to develop scalable, consistent, and elastic distributed
applications.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page10/index.html b/content/blog/page10/index.html
index b3253dc..19f1be1 100644
--- a/content/blog/page10/index.html
+++ b/content/blog/page10/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2018/09/20/release-1.6.1.html">Apache Flink 1.6.1 Released</a></h2>
+
+ <p>20 Sep 2018
+ </p>
+
+ <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.6 series.</p>
+
+</p>
+
+ <p><a href="/news/2018/09/20/release-1.6.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2018/09/20/release-1.5.4.html">Apache Flink 1.5.4 Released</a></h2>
<p>20 Sep 2018
@@ -333,21 +348,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2018/02/15/release-1.4.1.html">Apache Flink 1.4.1 Released</a></h2>
-
- <p>15 Feb 2018
- </p>
-
- <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.4 series.</p>
-
-</p>
-
- <p><a href="/news/2018/02/15/release-1.4.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -380,6 +380,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page11/index.html b/content/blog/page11/index.html
index 8b86f5f..f7fb0c9 100644
--- a/content/blog/page11/index.html
+++ b/content/blog/page11/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2018/02/15/release-1.4.1.html">Apache Flink 1.4.1 Released</a></h2>
+
+ <p>15 Feb 2018
+ </p>
+
+ <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.4 series.</p>
+
+</p>
+
+ <p><a href="/news/2018/02/15/release-1.4.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/features/2018/01/30/incremental-checkpointing.html">Managing Large State
in Apache Flink: An Intro to Incremental Checkpointing</a></h2>
<p>30 Jan 2018
@@ -334,21 +349,6 @@ what’s coming in Flink 1.4.0 as well as a preview of what
the Flink community
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2017/04/26/release-1.2.1.html">Apache Flink 1.2.1 Released</a></h2>
-
- <p>26 Apr 2017
- </p>
-
- <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.2 series.</p>
-
-</p>
-
- <p><a href="/news/2017/04/26/release-1.2.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -381,6 +381,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/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page12/index.html b/content/blog/page12/index.html
index e70b8b2..fbc16b7 100644
--- a/content/blog/page12/index.html
+++ b/content/blog/page12/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2017/04/26/release-1.2.1.html">Apache Flink 1.2.1 Released</a></h2>
+
+ <p>26 Apr 2017
+ </p>
+
+ <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.2 series.</p>
+
+</p>
+
+ <p><a href="/news/2017/04/26/release-1.2.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2017/04/04/dynamic-tables.html">Continuous Queries on Dynamic
Tables</a></h2>
<p>04 Apr 2017 by Fabian Hueske, Shaoxuan Wang, and Xiaowei Jiang
@@ -328,21 +343,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2016/08/11/release-1.1.1.html">Flink 1.1.1 Released</a></h2>
-
- <p>11 Aug 2016
- </p>
-
- <p><p>Today, the Flink community released Flink version 1.1.1.</p>
-
-</p>
-
- <p><a href="/news/2016/08/11/release-1.1.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -375,6 +375,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page13/index.html b/content/blog/page13/index.html
index fae12ab..8876e64 100644
--- a/content/blog/page13/index.html
+++ b/content/blog/page13/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2016/08/11/release-1.1.1.html">Flink 1.1.1 Released</a></h2>
+
+ <p>11 Aug 2016
+ </p>
+
+ <p><p>Today, the Flink community released Flink version 1.1.1.</p>
+
+</p>
+
+ <p><a href="/news/2016/08/11/release-1.1.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2016/08/08/release-1.1.0.html">Announcing Apache Flink
1.1.0</a></h2>
<p>08 Aug 2016
@@ -332,19 +347,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2015/12/18/a-year-in-review.html">Flink 2015: A year in review, and
a lookout to 2016</a></h2>
-
- <p>18 Dec 2015 by Robert Metzger (<a
href="https://twitter.com/";>@rmetzger_</a>)
- </p>
-
- <p><p>With 2015 ending, we thought that this would be good time to
reflect on the amazing work done by the Flink community over this past year,
and how much this community has grown.</p></p>
-
- <p><a href="/news/2015/12/18/a-year-in-review.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -377,6 +379,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page14/index.html b/content/blog/page14/index.html
index 6d2893a..c2a4a0e 100644
--- a/content/blog/page14/index.html
+++ b/content/blog/page14/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2015/12/18/a-year-in-review.html">Flink 2015: A year in review, and
a lookout to 2016</a></h2>
+
+ <p>18 Dec 2015 by Robert Metzger (<a
href="https://twitter.com/";>@rmetzger_</a>)
+ </p>
+
+ <p><p>With 2015 ending, we thought that this would be good time to
reflect on the amazing work done by the Flink community over this past year,
and how much this community has grown.</p></p>
+
+ <p><a href="/news/2015/12/18/a-year-in-review.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2015/12/11/storm-compatibility.html">Storm Compatibility in Apache
Flink: How to run existing Storm topologies on Flink</a></h2>
<p>11 Dec 2015 by Matthias J. Sax (<a
href="https://twitter.com/";>@MatthiasJSax</a>)
@@ -338,19 +351,6 @@ vertex-centric or gather-sum-apply to Flink dataflows.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2015/05/14/Community-update-April.html">April 2015 in the Flink
community</a></h2>
-
- <p>14 May 2015 by Kostas Tzoumas (<a
href="https://twitter.com/";>@kostas_tzoumas</a>)
- </p>
-
- <p><p>The monthly update from the Flink community. Including the
availability of a new preview release, lots of meetups and conference talks and
a great interview about Flink.</p></p>
-
- <p><a href="/news/2015/05/14/Community-update-April.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -383,6 +383,16 @@ vertex-centric or gather-sum-apply to Flink dataflows.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page15/index.html b/content/blog/page15/index.html
index 1a821be..7bb3160 100644
--- a/content/blog/page15/index.html
+++ b/content/blog/page15/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2015/05/14/Community-update-April.html">April 2015 in the Flink
community</a></h2>
+
+ <p>14 May 2015 by Kostas Tzoumas (<a
href="https://twitter.com/";>@kostas_tzoumas</a>)
+ </p>
+
+ <p><p>The monthly update from the Flink community. Including the
availability of a new preview release, lots of meetups and conference talks and
a great interview about Flink.</p></p>
+
+ <p><a href="/news/2015/05/14/Community-update-April.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2015/05/11/Juggling-with-Bits-and-Bytes.html">Juggling with Bits
and Bytes</a></h2>
<p>11 May 2015 by Fabian Hüske (<a
href="https://twitter.com/";>@fhueske</a>)
@@ -344,21 +357,6 @@ and offers a new API including definition of flexible
windows.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2014/11/18/hadoop-compatibility.html">Hadoop Compatibility in
Flink</a></h2>
-
- <p>18 Nov 2014 by Fabian Hüske (<a
href="https://twitter.com/";>@fhueske</a>)
- </p>
-
- <p><p><a href="http://hadoop.apache.org";>Apache Hadoop</a> is an
industry standard for scalable analytical data processing. Many data analysis
applications have been implemented as Hadoop MapReduce jobs and run in clusters
around the world. Apache Flink can be an alternative to MapReduce and improves
it in many dimensions. Among other features, Flink provides much better
performance and offers APIs in Java and Scala, which are very easy to use.
Similar to Hadoop, Flink’s APIs provi [...]
-
-</p>
-
- <p><a href="/news/2014/11/18/hadoop-compatibility.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -391,6 +389,16 @@ and offers a new API including definition of flexible
windows.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page16/index.html b/content/blog/page16/index.html
index 03c1059..8d5588b 100644
--- a/content/blog/page16/index.html
+++ b/content/blog/page16/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2014/11/18/hadoop-compatibility.html">Hadoop Compatibility in
Flink</a></h2>
+
+ <p>18 Nov 2014 by Fabian Hüske (<a
href="https://twitter.com/";>@fhueske</a>)
+ </p>
+
+ <p><p><a href="http://hadoop.apache.org";>Apache Hadoop</a> is an
industry standard for scalable analytical data processing. Many data analysis
applications have been implemented as Hadoop MapReduce jobs and run in clusters
around the world. Apache Flink can be an alternative to MapReduce and improves
it in many dimensions. Among other features, Flink provides much better
performance and offers APIs in Java and Scala, which are very easy to use.
Similar to Hadoop, Flink’s APIs provi [...]
+
+</p>
+
+ <p><a href="/news/2014/11/18/hadoop-compatibility.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2014/11/04/release-0.7.0.html">Apache Flink 0.7.0 available</a></h2>
<p>04 Nov 2014
@@ -295,6 +310,16 @@ academic and open source project that Flink originates
from.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index 5a770ab..ee5f1cf 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/2021/02/10/native-k8s-with-ha.html">How
to natively deploy Flink on Kubernetes with High-Availability (HA)</a></h2>
+
+ <p>10 Feb 2021
+ Yang Wang </p>
+
+ <p>Kubernetes provides built-in functionalities that Flink can leverage
for JobManager failover. In Flink 1.12 (FLIP-144), the community implemented a
Kubernetes High Availability (HA) service as an alternative to ZooKeeper for
highly available production setups. In this blogpost, we will have a close look
at how to deploy Flink applications natively on Kubernetes cluster with HA.</p>
+
+ <p><a href="/2021/02/10/native-k8s-with-ha.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2021/01/29/release-1.10.3.html">Apache Flink 1.10.3
Released</a></h2>
<p>29 Jan 2021
@@ -325,21 +338,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/11/11/release-statefun-2.2.1.html">Stateful Functions 2.2.1
Release Announcement</a></h2>
-
- <p>11 Nov 2020
- Tzu-Li (Gordon) Tai (<a
href="https://twitter.com/tzulitai";>@tzulitai</a>)</p>
-
- <p><p>The Apache Flink community released the first bugfix release of
the Stateful Functions (StateFun) 2.2 series, version 2.2.1.</p>
-
-</p>
-
- <p><a href="/news/2020/11/11/release-statefun-2.2.1.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -372,6 +370,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index 1a2c858..eb41bde 100644
--- a/content/blog/page3/index.html
+++ b/content/blog/page3/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/11/11/release-statefun-2.2.1.html">Stateful Functions 2.2.1
Release Announcement</a></h2>
+
+ <p>11 Nov 2020
+ Tzu-Li (Gordon) Tai (<a
href="https://twitter.com/tzulitai";>@tzulitai</a>)</p>
+
+ <p><p>The Apache Flink community released the first bugfix release of
the Stateful Functions (StateFun) 2.2 series, version 2.2.1.</p>
+
+</p>
+
+ <p><a href="/news/2020/11/11/release-statefun-2.2.1.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/2020/10/15/from-aligned-to-unaligned-checkpoints-part-1.html">From
Aligned to Unaligned Checkpoints - Part 1: Checkpoints, Alignment, and
Backpressure</a></h2>
<p>15 Oct 2020
@@ -329,19 +344,6 @@ as well as increased observability for operational
purposes.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/08/06/external-resource.html">Accelerating your workload with
GPU and other external resources</a></h2>
-
- <p>06 Aug 2020
- Yangze Guo </p>
-
- <p>This post introduces the new External Resource Framework in Flink
1.11 and take GPU as an example to show how to accelerate your workload with
external resources.</p>
-
- <p><a href="/news/2020/08/06/external-resource.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -374,6 +376,16 @@ as well as increased observability for operational
purposes.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index 636dbc3..4c7d480 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/08/06/external-resource.html">Accelerating your workload with
GPU and other external resources</a></h2>
+
+ <p>06 Aug 2020
+ Yangze Guo </p>
+
+ <p>This post introduces the new External Resource Framework in Flink
1.11 and take GPU as an example to show how to accelerate your workload with
external resources.</p>
+
+ <p><a href="/news/2020/08/06/external-resource.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/2020/08/04/pyflink-pandas-udf-support-flink.html">PyFlink: The
integration of Pandas into PyFlink</a></h2>
<p>04 Aug 2020
@@ -331,23 +344,6 @@ perform streaming data visualization via Flink on Zeppelin
and how to use Apache
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/06/15/flink-on-zeppelin-part1.html">Flink on Zeppelin
Notebooks for Interactive Data Analysis - Part 1</a></h2>
-
- <p>15 Jun 2020
- Jeff Zhang (<a href="https://twitter.com/zjffdu";>@zjffdu</a>)</p>
-
- <p><p>The latest release of <a
href="https://zeppelin.apache.org/";>Apache Zeppelin</a> comes with a redesigned
interpreter for Apache Flink (version Flink 1.10+ is only supported moving
forward)
-that allows developers to use Flink directly on Zeppelin notebooks for
interactive data analysis. I wrote 2 posts about how to use Flink in Zeppelin.
This is part-1 where I explain how the Flink interpreter in Zeppelin works,
-and provide a tutorial for running Streaming ETL with Flink on Zeppelin.</p>
-
-</p>
-
- <p><a href="/news/2020/06/15/flink-on-zeppelin-part1.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -380,6 +376,16 @@ and provide a tutorial for running Streaming ETL with
Flink on Zeppelin.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html
index 2246b0f..a797f3d 100644
--- a/content/blog/page5/index.html
+++ b/content/blog/page5/index.html
@@ -201,6 +201,23 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/06/15/flink-on-zeppelin-part1.html">Flink on Zeppelin
Notebooks for Interactive Data Analysis - Part 1</a></h2>
+
+ <p>15 Jun 2020
+ Jeff Zhang (<a href="https://twitter.com/zjffdu";>@zjffdu</a>)</p>
+
+ <p><p>The latest release of <a
href="https://zeppelin.apache.org/";>Apache Zeppelin</a> comes with a redesigned
interpreter for Apache Flink (version Flink 1.10+ is only supported moving
forward)
+that allows developers to use Flink directly on Zeppelin notebooks for
interactive data analysis. I wrote 2 posts about how to use Flink in Zeppelin.
This is part-1 where I explain how the Flink interpreter in Zeppelin works,
+and provide a tutorial for running Streaming ETL with Flink on Zeppelin.</p>
+
+</p>
+
+ <p><a href="/news/2020/06/15/flink-on-zeppelin-part1.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2020/06/11/community-update.html">Flink Community Update -
June'20</a></h2>
<p>11 Jun 2020
@@ -323,22 +340,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/04/07/release-statefun-2.0.0.html">Stateful Functions 2.0 - An
Event-driven Database on Apache Flink</a></h2>
-
- <p>07 Apr 2020
- Stephan Ewen (<a
href="https://twitter.com/stephanewen";>@stephanewen</a>)</p>
-
- <p><p>Today, we are announcing the release of Stateful Functions
(StateFun) 2.0 — the first release of Stateful Functions as part of the Apache
Flink project.
-This release marks a big milestone: Stateful Functions 2.0 is not only an API
update, but the <strong>first version of an event-driven database</strong> that
is built on Apache Flink.</p>
-
-</p>
-
- <p><a href="/news/2020/04/07/release-statefun-2.0.0.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -371,6 +372,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/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page6/index.html b/content/blog/page6/index.html
index 735cada..fc245c4 100644
--- a/content/blog/page6/index.html
+++ b/content/blog/page6/index.html
@@ -201,6 +201,22 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/04/07/release-statefun-2.0.0.html">Stateful Functions 2.0 - An
Event-driven Database on Apache Flink</a></h2>
+
+ <p>07 Apr 2020
+ Stephan Ewen (<a
href="https://twitter.com/stephanewen";>@stephanewen</a>)</p>
+
+ <p><p>Today, we are announcing the release of Stateful Functions
(StateFun) 2.0 — the first release of Stateful Functions as part of the Apache
Flink project.
+This release marks a big milestone: Stateful Functions 2.0 is not only an API
update, but the <strong>first version of an event-driven database</strong> that
is built on Apache Flink.</p>
+
+</p>
+
+ <p><a href="/news/2020/04/07/release-statefun-2.0.0.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2020/04/01/community-update.html">Flink Community Update -
April'20</a></h2>
<p>01 Apr 2020
@@ -323,19 +339,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/01/15/demo-fraud-detection.html">Advanced Flink Application
Patterns Vol.1: Case Study of a Fraud Detection System</a></h2>
-
- <p>15 Jan 2020
- Alexander Fedulov (<a
href="https://twitter.com/alex_fedulov";>@alex_fedulov</a>)</p>
-
- <p>In this series of blog posts you will learn about three powerful
Flink patterns for building streaming applications.</p>
-
- <p><a href="/news/2020/01/15/demo-fraud-detection.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -368,6 +371,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page7/index.html b/content/blog/page7/index.html
index 698af1e..5b6a684 100644
--- a/content/blog/page7/index.html
+++ b/content/blog/page7/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/01/15/demo-fraud-detection.html">Advanced Flink Application
Patterns Vol.1: Case Study of a Fraud Detection System</a></h2>
+
+ <p>15 Jan 2020
+ Alexander Fedulov (<a
href="https://twitter.com/alex_fedulov";>@alex_fedulov</a>)</p>
+
+ <p>In this series of blog posts you will learn about three powerful
Flink patterns for building streaming applications.</p>
+
+ <p><a href="/news/2020/01/15/demo-fraud-detection.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2019/12/11/release-1.8.3.html">Apache Flink 1.8.3 Released</a></h2>
<p>11 Dec 2019
@@ -326,21 +339,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2019/07/02/release-1.8.1.html">Apache Flink 1.8.1 Released</a></h2>
-
- <p>02 Jul 2019
- Jincheng Sun (<a
href="https://twitter.com/sunjincheng121";>@sunjincheng121</a>)</p>
-
- <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.8 series.</p>
-
-</p>
-
- <p><a href="/news/2019/07/02/release-1.8.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -373,6 +371,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page8/index.html b/content/blog/page8/index.html
index 1cd63ff..8a53bef 100644
--- a/content/blog/page8/index.html
+++ b/content/blog/page8/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2019/07/02/release-1.8.1.html">Apache Flink 1.8.1 Released</a></h2>
+
+ <p>02 Jul 2019
+ Jincheng Sun (<a
href="https://twitter.com/sunjincheng121";>@sunjincheng121</a>)</p>
+
+ <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.8 series.</p>
+
+</p>
+
+ <p><a href="/news/2019/07/02/release-1.8.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/2019/06/26/broadcast-state.html">A
Practical Guide to Broadcast State in Apache Flink</a></h2>
<p>26 Jun 2019
@@ -325,19 +340,6 @@ for more details.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2019/02/25/monitoring-best-practices.html">Monitoring Apache Flink
Applications 101</a></h2>
-
- <p>25 Feb 2019
- Konstantin Knauf (<a
href="https://twitter.com/snntrable";>@snntrable</a>)</p>
-
- <p>The monitoring of business-critical applications is a crucial aspect
of a production deployment. It ensures that any degradation or downtime is
immediately identified and can be resolved as quickly as possible. In this
post, we discuss the most important metrics that indicate healthy Flink
applications.</p>
-
- <p><a href="/news/2019/02/25/monitoring-best-practices.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -370,6 +372,16 @@ for more details.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/blog/page9/index.html b/content/blog/page9/index.html
index 7bed33b..2c0614c 100644
--- a/content/blog/page9/index.html
+++ b/content/blog/page9/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2019/02/25/monitoring-best-practices.html">Monitoring Apache Flink
Applications 101</a></h2>
+
+ <p>25 Feb 2019
+ Konstantin Knauf (<a
href="https://twitter.com/snntrable";>@snntrable</a>)</p>
+
+ <p>The monitoring of business-critical applications is a crucial aspect
of a production deployment. It ensures that any degradation or downtime is
immediately identified and can be resolved as quickly as possible. In this
post, we discuss the most important metrics that indicate healthy Flink
applications.</p>
+
+ <p><a href="/news/2019/02/25/monitoring-best-practices.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2019/02/25/release-1.6.4.html">Apache Flink 1.6.4 Released</a></h2>
<p>25 Feb 2019
@@ -335,21 +348,6 @@ Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2018/09/20/release-1.6.1.html">Apache Flink 1.6.1 Released</a></h2>
-
- <p>20 Sep 2018
- </p>
-
- <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.6 series.</p>
-
-</p>
-
- <p><a href="/news/2018/09/20/release-1.6.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -382,6 +380,16 @@ Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<ul id="markdown-toc">
+ <li><a href="/news/2021/08/06/release-1.13.2.html">Apache Flink 1.13.2
Released</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/2021/07/07/backpressure.html">How to identify the source
of backpressure?</a></li>
diff --git a/content/downloads.html b/content/downloads.html
index e3a9aa5..e8e82e7 100644
--- a/content/downloads.html
+++ b/content/downloads.html
@@ -212,7 +212,7 @@ $( document ).ready(function() {
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#apache-flink-1131" id="markdown-toc-apache-flink-1131">Apache
Flink 1.13.1</a></li>
+ <li><a href="#apache-flink-1132" id="markdown-toc-apache-flink-1132">Apache
Flink 1.13.2</a></li>
<li><a href="#apache-flink-1124" id="markdown-toc-apache-flink-1124">Apache
Flink 1.12.4</a></li>
<li><a href="#apache-flink-stateful-functions-300"
id="markdown-toc-apache-flink-stateful-functions-300">Apache Flink Stateful
Functions 3.0.0</a></li>
<li><a href="#additional-components"
id="markdown-toc-additional-components">Additional Components</a></li>
@@ -233,21 +233,21 @@ $( document ).ready(function() {
</div>
-<p>Apache Flink® 1.13.1 is our latest stable release.</p>
+<p>Apache Flink® 1.13.2 is our latest stable release.</p>
-<h2 id="apache-flink-1131">Apache Flink 1.13.1</h2>
+<h2 id="apache-flink-1132">Apache Flink 1.13.2</h2>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.11.tgz";
class="ga-track" id="1131-download_211">Apache Flink 1.13.1 for Scala 2.11</a>
(<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.11.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.11.tgz";
class="ga-track" id="1132-download_211">Apache Flink 1.13.2 for Scala 2.11</a>
(<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.11.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.12.tgz";
class="ga-track" id="1131-download_212">Apache Flink 1.13.1 for Scala 2.12</a>
(<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.12.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.12.tgz";
class="ga-track" id="1132-download_212">Apache Flink 1.13.2 for Scala 2.12</a>
(<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.12.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.1/flink-1.13.1-src.tgz";
class="ga-track" id="1131-download-source">Apache Flink 1.13.1 Source
Release</a>
-(<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-src.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.2/flink-1.13.2-src.tgz";
class="ga-track" id="1132-download-source">Apache Flink 1.13.2 Source
Release</a>
+(<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-src.tgz.sha512";>sha512</a>)
</p>
<h4 id="release-notes">Release Notes</h4>
@@ -343,17 +343,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.13.1<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.13.2<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.13.1<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.13.2<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.13.1<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.13.2<span
class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3>
@@ -390,6 +390,17 @@ The <code>statefun-flink-harness</code> dependency
includes a local execution en
<li>
+Flink 1.13.2 - 2021-08-02
+(<a
href="https://archive.apache.org/dist/flink/flink-1.13.2/flink-1.13.2-src.tgz";>Source</a>,
+<a href="https://archive.apache.org/dist/flink/flink-1.13.2";>Binaries</a>,
+<a
href="https://ci.apache.org/projects/flink/flink-docs-release-1.13";>Docs</a>,
+<a
href="https://ci.apache.org/projects/flink/flink-docs-release-1.13/api/java";>Javadocs</a>,
+<a
href="https://ci.apache.org/projects/flink/flink-docs-release-1.13/api/scala/index.html";>Scaladocs</a>)
+
+</li>
+
+<li>
+
Flink 1.13.1 - 2021-05-28
(<a
href="https://archive.apache.org/dist/flink/flink-1.13.1/flink-1.13.1-src.tgz";>Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.13.1";>Binaries</a>,
diff --git a/content/index.html b/content/index.html
index 1260e15..c47a230 100644
--- a/content/index.html
+++ b/content/index.html
@@ -577,6 +577,11 @@
<dl>
+ <dt> <a href="/news/2021/08/06/release-1.13.2.html">Apache Flink
1.13.2 Released</a></dt>
+ <dd><p>The Apache Flink community released the second bugfix version
of the Apache Flink 1.13 series.</p>
+
+</dd>
+
<dt> <a href="/2021/07/07/backpressure.html">How to identify the
source of backpressure?</a></dt>
<dd>Apache Flink 1.13 introduced a couple of important changes in the
area of backpressure monitoring and performance analysis of Flink Jobs. This
blog post aims to introduce those changes and explain how to use them.</dd>
@@ -592,9 +597,6 @@
<dt> <a href="/2021/05/06/reactive-mode.html">Scaling Flink
automatically with Reactive Mode</a></dt>
<dd>Apache Flink 1.13 introduced Reactive Mode, a big step forward in
Flink's ability to dynamically adjust to changing workloads, reducing resource
utilization and overall costs. This blog post showcases how to use this new
feature on Kubernetes, including some lessons learned.</dd>
-
- <dt> <a href="/news/2021/05/03/release-1.13.0.html">Apache Flink
1.13.0 Release Announcement</a></dt>
- <dd>The Apache Flink community is excited to announce the release of
Flink 1.13.0! Around 200 contributors worked on over 1,000 issues to bring
significant improvements to usability and observability as well as new features
that improve the elasticity of Flink's Application-style deployments.</dd>
</dl>
diff --git a/content/news/2021/08/06/release-1.13.2.html
b/content/news/2021/08/06/release-1.13.2.html
new file mode 100644
index 0000000..7c8b53e
--- /dev/null
+++ b/content/news/2021/08/06/release-1.13.2.html
@@ -0,0 +1,560 @@
+<!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.13.2 Released</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]-->
+ </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>
+
+
+
+ <!-- What is Stateful Functions? -->
+
+ <li><a href="/stateful-functions.html">What is Stateful
Functions?</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://ci.apache.org/projects/flink/flink-docs-release-1.13//docs/try-flink/local_installation/";
target="_blank">With Flink <small><span class="glyphicon
glyphicon-new-window"></span></small></a></li>
+ <li><a
href="https://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0/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="/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://ci.apache.org/projects/flink/flink-docs-release-1.13";
target="_blank">Flink 1.13 (Latest stable release) <small><span
class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a
href="https://ci.apache.org/projects/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://ci.apache.org/projects/flink/flink-statefun-docs-release-3.0";
target="_blank">Flink Stateful Functions 3.0 (Latest stable release)
<small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a
href="https://ci.apache.org/projects/flink/flink-statefun-docs-master";
target="_blank">Flink Stateful Functions 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.13.2 Released</h1>
+ <p><i></i></p>
+
+ <article>
+ <p>06 Aug 2021 Yun Tang </p>
+
+<p>The Apache Flink community released the second bugfix version of the Apache
Flink 1.13 series.</p>
+
+<p>This release includes 127 fixes and minor improvements for Flink 1.13.2.
The list below includes bugfixes and improvements. For a complete list of all
changes see:
+<a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?version=12350218&styleName=&projectId=12315522";>JIRA</a>.</p>
+
+<p>We highly recommend all users to upgrade to Flink 1.13.2.</p>
+
+<p>Updated Maven dependencies:</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.13.2<span
class="nt"></version></span>
+<span class="nt"></dependency></span>
+<span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.13.2<span
class="nt"></version></span>
+<span class="nt"></dependency></span>
+<span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.13.2<span
class="nt"></version></span>
+<span class="nt"></dependency></span></code></pre></div>
+
+<p>You can find the binaries on the updated <a
href="/downloads.html">Downloads page</a>.</p>
+
+<div class="highlight"><pre><code> Release Notes - Flink - Version 1.13.2
+</code></pre></div>
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22726";>FLINK-22726</a>] -
Hive GROUPING__ID returns different value in older versions
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20888";>FLINK-20888</a>] -
ContinuousFileReaderOperator should not close the output on close()
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20975";>FLINK-20975</a>] -
HiveTableSourceITCase.testPartitionFilter fails on AZP
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21389";>FLINK-21389</a>] -
ParquetInputFormat should not need parquet schema as user input
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21445";>FLINK-21445</a>] -
Application mode does not set the configuration when building
PackagedProgram
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21952";>FLINK-21952</a>] -
Make all the "Connection reset by peer" exception wrapped as
RemoteTransportException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22045";>FLINK-22045</a>] -
Set log level for shaded zookeeper logger
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22195";>FLINK-22195</a>] -
YARNHighAvailabilityITCase.testClusterClientRetrieval because of
TestTimedOutException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22203";>FLINK-22203</a>] -
KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to
ConcurrentModificationException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22272";>FLINK-22272</a>] -
Some scenes can't drop table by hive catalog
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22312";>FLINK-22312</a>] -
YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents
due to the heartbeat exception with Yarn RM
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22376";>FLINK-22376</a>] -
SequentialChannelStateReaderImpl may recycle buffer twice
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22443";>FLINK-22443</a>] -
can not be execute an extreme long sql under batch mode
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22462";>FLINK-22462</a>] -
JdbcExactlyOnceSinkE2eTest.testInsert failed because of too many clients.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22464";>FLINK-22464</a>] -
OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure
hangs with `AdaptiveScheduler`
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22492";>FLINK-22492</a>] -
KinesisTableApiITCase with wrong results
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22496";>FLINK-22496</a>] -
ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22545";>FLINK-22545</a>] -
JVM crashes when runing
OperatorEventSendingCheckpointITCase.testOperatorEventAckLost
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22547";>FLINK-22547</a>] -
OperatorCoordinatorHolderTest.
verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22613";>FLINK-22613</a>] -
FlinkKinesisITCase.testStopWithSavepoint fails
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22662";>FLINK-22662</a>] -
YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22683";>FLINK-22683</a>] -
The total Flink/process memory of memoryConfiguration in /taskmanagers can
be null or incorrect value
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22686";>FLINK-22686</a>] -
Incompatible subtask mappings while resuming from unaligned checkpoints
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22689";>FLINK-22689</a>] -
Table API Documentation Row-Based Operations Example Fails
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22698";>FLINK-22698</a>] -
RabbitMQ source does not stop unless message arrives in queue
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22725";>FLINK-22725</a>] -
SlotManagers should unregister metrics at the start of suspend()
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22730";>FLINK-22730</a>] -
Lookup join condition with CURRENT_DATE fails to filter records
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22746";>FLINK-22746</a>] -
Links to connectors in docs are broken
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22759";>FLINK-22759</a>] -
Correct the applicability of RocksDB related options as per operator
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22760";>FLINK-22760</a>] -
HiveParser::setCurrentTimestamp fails with hive-3.1.2
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22777";>FLINK-22777</a>] -
Restore lost sections in Try Flink DataStream API example
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22779";>FLINK-22779</a>] -
KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to
ConcurrentModificationException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22786";>FLINK-22786</a>] -
sql-client can not create .flink-sql-history file
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22795";>FLINK-22795</a>] -
Throw better exception when executing remote SQL file in SQL Client
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22796";>FLINK-22796</a>] -
Update mem_setup_tm documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22814";>FLINK-22814</a>] -
New sources are not defining/exposing checkpointStartDelayNanos metric
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22815";>FLINK-22815</a>] -
Disable unaligned checkpoints for broadcast partitioning
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22819";>FLINK-22819</a>] -
YARNFileReplicationITCase fails with "The YARN application
unexpectedly switched to state FAILED during deployment"
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22820";>FLINK-22820</a>] -
Stopping Yarn session cluster will cause fatal error
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22833";>FLINK-22833</a>] -
Source tasks (both old and new) are not reporting checkpointStartDelay via
CheckpointMetrics
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22856";>FLINK-22856</a>] -
Move our Azure pipelines away from Ubuntu 16.04 by September
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22863";>FLINK-22863</a>] -
ArrayIndexOutOfBoundsException may happen when building rescale edges
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22884";>FLINK-22884</a>] -
Select view columns fail when store metadata with hive
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22886";>FLINK-22886</a>] -
Thread leak in RocksDBStateUploader
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22890";>FLINK-22890</a>] -
Few tests fail in HiveTableSinkITCase
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22894";>FLINK-22894</a>] -
Window Top-N should allow n=1
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22898";>FLINK-22898</a>] -
HiveParallelismInference limit return wrong parallelism
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22908";>FLINK-22908</a>] -
FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should
wait until job is running
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22927";>FLINK-22927</a>] -
Exception on JobClient.get_job_status().result()
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22945";>FLINK-22945</a>] -
StackOverflowException can happen when a large scale job is
CANCELING/FAILING
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22946";>FLINK-22946</a>] -
Network buffer deadlock introduced by unaligned checkpoint
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22948";>FLINK-22948</a>] -
Scala example for toDataStream does not compile
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22952";>FLINK-22952</a>] -
docs_404_check fail on azure due to ruby version not available
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22961";>FLINK-22961</a>] -
Incorrect calculation of alignment timeout for LocalInputChannel
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22963";>FLINK-22963</a>] -
The description of taskmanager.memory.task.heap.size in the official
document is incorrect
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22964";>FLINK-22964</a>] -
Connector-base exposes dependency to flink-core.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22966";>FLINK-22966</a>] -
NPE in StateAssignmentOperation when rescaling
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22980";>FLINK-22980</a>] -
FileExecutionGraphInfoStoreTest hangs on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22982";>FLINK-22982</a>] -
java.lang.ClassCastException when using Python UDF
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22987";>FLINK-22987</a>] -
Scala suffix check isn't working
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22993";>FLINK-22993</a>] -
CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE
checkpointId
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23001";>FLINK-23001</a>] -
flink-avro-glue-schema-registry lacks scala suffix
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23003";>FLINK-23003</a>] -
Resource leak in RocksIncrementalSnapshotStrategy
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23010";>FLINK-23010</a>] -
HivePartitionFetcherContextBase::getComparablePartitionValueList can return
partitions that don't exist
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23018";>FLINK-23018</a>] -
State factories should handle extended state descriptors
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23024";>FLINK-23024</a>] -
RPC result TaskManagerInfoWithSlots not serializable
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23025";>FLINK-23025</a>] -
sink-buffer-max-rows and sink-buffer-flush-interval options produce a lot
of duplicates
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23030";>FLINK-23030</a>] -
PartitionRequestClientFactory#createPartitionRequestClient should throw
when network failure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23034";>FLINK-23034</a>] -
NPE in JobDetailsDeserializer during the reading old version of
ExecutionState
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23045";>FLINK-23045</a>] -
RunnablesTest.testExecutorService_uncaughtExceptionHandler fails on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23073";>FLINK-23073</a>] -
Fix space handling in Row CSV timestamp parser
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23074";>FLINK-23074</a>] -
There is a class conflict between flink-connector-hive and flink-parquet
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23092";>FLINK-23092</a>] -
Built-in UDAFs could not be mixed use with Python UDAF in group window
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23096";>FLINK-23096</a>] -
HiveParser could not attach the sessionstate of hive
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23119";>FLINK-23119</a>] -
Fix the issue that the exception that General Python UDAF is unsupported is
not thrown in Compile Stage.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23120";>FLINK-23120</a>] -
ByteArrayWrapperSerializer.serialize should use writeInt to serialize the
length
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23121";>FLINK-23121</a>] -
Fix the issue that the InternalRow as arguments in Python UDAF
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23129";>FLINK-23129</a>] -
When cancelling any running job of multiple jobs in an application cluster,
JobManager shuts down
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23133";>FLINK-23133</a>] -
The dependencies are not handled properly when mixing use of Python Table
API and Python DataStream API
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23151";>FLINK-23151</a>] -
KinesisTableApiITCase.testTableApiSourceAndSink fails on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23166";>FLINK-23166</a>] -
ZipUtils doesn't handle properly for softlinks inside the zip file
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23182";>FLINK-23182</a>] -
Connection leak in RMQSource
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23184";>FLINK-23184</a>] -
CompileException Assignment conversion not possible from type
"int" to type "short"
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23188";>FLINK-23188</a>] -
Unsupported function definition: IFNULL. Only user defined functions are
supported as inline functions
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23196";>FLINK-23196</a>] -
JobMasterITCase fail on azure due to BindException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23201";>FLINK-23201</a>] -
The check on alignmentDurationNanos seems to be too strict
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23223";>FLINK-23223</a>] -
When flushAlways is enabled the subpartition may lose notification of data
availability
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23233";>FLINK-23233</a>] -
OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure
fails on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23235";>FLINK-23235</a>] -
SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fails
on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23248";>FLINK-23248</a>] -
SinkWriter is not closed when failing
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23259";>FLINK-23259</a>] -
[DOCS]The 'window' link on page
docs/dev/datastream/operators/overview is failed and 404 is returned
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23260";>FLINK-23260</a>] -
[DOCS]The link on page docs/libs/gelly/overview is failed and 404 is
returned
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23270";>FLINK-23270</a>] -
Impove description of Regular Joins section
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23280";>FLINK-23280</a>] -
Python ExplainDetails does not have JSON_EXECUTION_PLAN option
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23306";>FLINK-23306</a>] -
FlinkRelMdUniqueKeys causes exception when used with new Schema
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23359";>FLINK-23359</a>] -
Fix the number of available slots in
testResourceCanBeAllocatedForDifferentJobAfterFree
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23368";>FLINK-23368</a>] -
Fix the wrong mapping of state cache in PyFlink
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23429";>FLINK-23429</a>] -
State Processor API failed with FileNotFoundException when working with
state files on Cloud Storage
+</li>
+</ul>
+
+<h2> New Feature
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22770";>FLINK-22770</a>] -
Expose SET/RESET from the parser
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-18182";>FLINK-18182</a>] -
Upgrade AWS SDK in flink-connector-kinesis to include new region af-south-1
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20140";>FLINK-20140</a>] -
Add documentation of TableResult.collect for Python Table API
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21229";>FLINK-21229</a>] -
Support ssl connection with schema registry format
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21393";>FLINK-21393</a>] -
Implement ParquetAvroInputFormat
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21411";>FLINK-21411</a>] -
The components on which Flink depends may contain vulnerabilities. If yes,
fix them.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22528";>FLINK-22528</a>] -
Document latency tracking metrics for state accesses
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22638";>FLINK-22638</a>] -
Keep channels blocked on alignment timeout
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22655";>FLINK-22655</a>] -
When using -i <init.sql> option to initialize SQL Client session It
should be possible to annotate the script with --
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22722";>FLINK-22722</a>] -
Add Documentation for Kafka New Source
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22747";>FLINK-22747</a>] -
Update commons-io to 2.8
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22766";>FLINK-22766</a>] -
Report metrics of KafkaConsumer in Kafka new source
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22774";>FLINK-22774</a>] -
Update Kinesis SQL connector's Guava to 27.0-jre
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22855";>FLINK-22855</a>] -
Translate the 'Overview of Python API' page into Chinese.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22873";>FLINK-22873</a>] -
Add ToC to configuration documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22905";>FLINK-22905</a>] -
Fix missing comma in SQL example in "Versioned Table" page
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22939";>FLINK-22939</a>] -
Generalize JDK switch in azure setup
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22996";>FLINK-22996</a>] -
The description about coalesce is wrong
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23009";>FLINK-23009</a>] -
Bump up Guava in Kinesis Connector
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23052";>FLINK-23052</a>] -
cron_snapshot_deployment_maven unstable on maven
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23138";>FLINK-23138</a>] -
Raise an exception if types other than PickledBytesTypeInfo are specified
for state descriptor
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23156";>FLINK-23156</a>] -
Change the reference of 'docs/dev/table/sql/queries'
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23157";>FLINK-23157</a>] -
Fix missing comma in SQL example in "Versioned View" page
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23162";>FLINK-23162</a>] -
Create table uses time_ltz in the column name and it's expression which
results in exception
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23168";>FLINK-23168</a>] -
Catalog shouldn't merge properties for alter DB operation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23178";>FLINK-23178</a>] -
Raise an error for writing stream data into partitioned hive tables without
a partition committer
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23200";>FLINK-23200</a>] -
Correct grammatical mistakes in 'Table API' page of 'Table API
& SQL'
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23226";>FLINK-23226</a>] -
Flink Chinese doc learn-flink/etl transformation.svg display issue
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23312";>FLINK-23312</a>] -
Use -Dfast for building e2e tests on AZP
+</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-2021 <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="/privacy-policy.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>
+
+ <!-- Google Analytics -->
+ <script>
+
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
+ (i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new
Date();a=s.createElement(o),
+
m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
+
})(window,document,'script','//www.google-analytics.com/analytics.js','ga');
+
+ ga('create', 'UA-52545728-1', 'auto');
+ ga('send', 'pageview');
+ </script>
+ </body>
+</html>
diff --git a/content/q/gradle-quickstart.sh b/content/q/gradle-quickstart.sh
index 9833cd6..efbb33a 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.13.1}"
+defaultFlinkVersion="${1:-1.13.2}"
defaultScalaBinaryVersion="${2:-2.11}"
echo "This script creates a Flink project using Java and Gradle."
diff --git a/content/q/quickstart-scala.sh b/content/q/quickstart-scala.sh
index e177d8e..2eea1b3 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.13.1}
\
+ -DarchetypeVersion=${1:-1.13.2}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/content/q/quickstart.sh b/content/q/quickstart.sh
index 64f2542..018a58f 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.13.1}
\
+ -DarchetypeVersion=${1:-1.13.2}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/content/q/sbt-quickstart.sh b/content/q/sbt-quickstart.sh
index b3f4ae9..cf03a60 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.13.1"
+defaultFlinkVersion="1.13.2"
echo "This script creates a Flink project using Scala and SBT."
@@ -105,7 +105,7 @@ organization := \"org.example\"
ThisBuild / scalaVersion := \"2.11.12\"
-val flinkVersion = \"1.13.1\"
+val flinkVersion = \"1.13.2\"
val flinkDependencies = Seq(
\"org.apache.flink\" %% \"flink-scala\" % flinkVersion % \"provided\",
diff --git a/content/zh/downloads.html b/content/zh/downloads.html
index a0ddb7f..ce9825c 100644
--- a/content/zh/downloads.html
+++ b/content/zh/downloads.html
@@ -210,7 +210,7 @@ $( document ).ready(function() {
<div class="page-toc">
<ul id="markdown-toc">
- <li><a href="#apache-flink-1131" id="markdown-toc-apache-flink-1131">Apache
Flink 1.13.1</a></li>
+ <li><a href="#apache-flink-1132" id="markdown-toc-apache-flink-1132">Apache
Flink 1.13.2</a></li>
<li><a href="#apache-flink-1124" id="markdown-toc-apache-flink-1124">Apache
Flink 1.12.4</a></li>
<li><a href="#section-3" id="markdown-toc-section-3">额外组件</a></li>
<li><a href="#section-4" id="markdown-toc-section-4">验证哈希和签名</a></li>
@@ -225,23 +225,23 @@ $( document ).ready(function() {
</div>
-<p>Apache Flink® 1.13.1 是我们最新的稳定版本。</p>
+<p>Apache Flink® 1.13.2 是我们最新的稳定版本。</p>
-<h2 id="apache-flink-1131">Apache Flink 1.13.1</h2>
+<h2 id="apache-flink-1132">Apache Flink 1.13.2</h2>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.11.tgz";
class="ga-track" id="1131-download_211">Apache Flink 1.13.1 for Scala 2.11</a>
(<a href="
-
https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.11.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.11.tgz";
class="ga-track" id="1132-download_211">Apache Flink 1.13.2 for Scala 2.11</a>
(<a href="
+
https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.11.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.12.tgz";
class="ga-track" id="1131-download_212">Apache Flink 1.13.1 for Scala 2.12</a>
(<a href="
-
https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-bin-scala_2.12.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.12.tgz";
class="ga-track" id="1132-download_212">Apache Flink 1.13.2 for Scala 2.12</a>
(<a href="
+
https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-bin-scala_2.12.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.1/flink-1.13.1-src.tgz";
class="ga-track" id="1131-download-source">Apache Flink 1.13.1 Source
Release</a>
- (<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.1/flink-1.13.1-src.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.13.2/flink-1.13.2-src.tgz";
class="ga-track" id="1132-download-source">Apache Flink 1.13.2 Source
Release</a>
+ (<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.13.2/flink-1.13.2-src.tgz.sha512";>sha512</a>)
</p>
<h4 id="section">发布说明</h4>
@@ -321,17 +321,17 @@
flink-docs-release-1.12/release-notes/flink-1.12.html">Flink 1.12 的发布说
<div class="highlight"><pre><code class="language-xml"><span
class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-java<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.13.1<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.13.2<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.13.1<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.13.2<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.13.1<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.13.2<span
class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h2 id="section-5">旧版本的更新策略</h2>
@@ -348,6 +348,17 @@
flink-docs-release-1.12/release-notes/flink-1.12.html">Flink 1.12 的发布说
<li>
+Flink 1.13.2 - 2021-08-02
+(<a
href="https://archive.apache.org/dist/flink/flink-1.13.2/flink-1.13.2-src.tgz";>Source</a>,
+<a href="https://archive.apache.org/dist/flink/flink-1.13.2";>Binaries</a>,
+<a
href="https://ci.apache.org/projects/flink/flink-docs-release-1.13";>Docs</a>,
+<a
href="https://ci.apache.org/projects/flink/flink-docs-release-1.13/api/java";>Javadocs</a>,
+<a
href="https://ci.apache.org/projects/flink/flink-docs-release-1.13/api/scala/index.html";>Scaladocs</a>)
+
+</li>
+
+<li>
+
Flink 1.13.1 - 2021-05-28
(<a
href="https://archive.apache.org/dist/flink/flink-1.13.1/flink-1.13.1-src.tgz";>Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.13.1";>Binaries</a>,
diff --git a/content/zh/index.html b/content/zh/index.html
index b109d1d..ec208c5 100644
--- a/content/zh/index.html
+++ b/content/zh/index.html
@@ -570,6 +570,11 @@
<dl>
+ <dt> <a href="/news/2021/08/06/release-1.13.2.html">Apache Flink
1.13.2 Released</a></dt>
+ <dd><p>The Apache Flink community released the second bugfix version
of the Apache Flink 1.13 series.</p>
+
+</dd>
+
<dt> <a href="/2021/07/07/backpressure.html">How to identify the
source of backpressure?</a></dt>
<dd>Apache Flink 1.13 introduced a couple of important changes in the
area of backpressure monitoring and performance analysis of Flink Jobs. This
blog post aims to introduce those changes and explain how to use them.</dd>
@@ -585,9 +590,6 @@
<dt> <a href="/2021/05/06/reactive-mode.html">Scaling Flink
automatically with Reactive Mode</a></dt>
<dd>Apache Flink 1.13 introduced Reactive Mode, a big step forward in
Flink's ability to dynamically adjust to changing workloads, reducing resource
utilization and overall costs. This blog post showcases how to use this new
feature on Kubernetes, including some lessons learned.</dd>
-
- <dt> <a href="/news/2021/05/03/release-1.13.0.html">Apache Flink
1.13.0 Release Announcement</a></dt>
- <dd>The Apache Flink community is excited to announce the release of
Flink 1.13.0! Around 200 contributors worked on over 1,000 issues to bring
significant improvements to usability and observability as well as new features
that improve the elasticity of Flink's Application-style deployments.</dd>
</dl>
