This is an automated email from the ASF dual-hosted git repository.
thw 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 e1657ab Rebuild website
e1657ab is described below
commit e1657ab3ded5fcc17d0d4b69974839c95e15d6e8
Author: Thomas Weise <[email protected]>
AuthorDate: Wed Jan 19 17:32:53 2022 -0800
Rebuild website
---
content/blog/feed.xml | 469 +++++++++++++++--------
content/blog/index.html | 38 +-
content/blog/page10/index.html | 38 +-
content/blog/page11/index.html | 40 +-
content/blog/page12/index.html | 38 +-
content/blog/page13/index.html | 36 +-
content/blog/page14/index.html | 37 +-
content/blog/page15/index.html | 38 +-
content/blog/page16/index.html | 44 ++-
content/blog/page17/index.html | 45 ++-
content/blog/page18/index.html | 25 ++
content/blog/page2/index.html | 40 +-
content/blog/page3/index.html | 40 +-
content/blog/page4/index.html | 38 +-
content/blog/page5/index.html | 36 +-
content/blog/page6/index.html | 38 +-
content/blog/page7/index.html | 40 +-
content/blog/page8/index.html | 38 +-
content/blog/page9/index.html | 36 +-
content/downloads.html | 31 +-
content/index.html | 8 +-
content/news/2022/01/17/release-1.14.3.html | 566 ++++++++++++++++++++++++++++
content/q/gradle-quickstart.sh | 2 +-
content/q/quickstart-scala.sh | 2 +-
content/q/quickstart.sh | 2 +-
content/q/sbt-quickstart.sh | 2 +-
content/zh/downloads.html | 35 +-
content/zh/index.html | 8 +-
28 files changed, 1377 insertions(+), 433 deletions(-)
diff --git a/content/blog/feed.xml b/content/blog/feed.xml
index 024dca6..24fd2a2 100644
--- a/content/blog/feed.xml
+++ b/content/blog/feed.xml
@@ -7,6 +7,324 @@
<atom:link href="https://flink.apache.org/blog/feed.xml"; rel="self"
type="application/rss+xml" />
<item>
+<title>Apache Flink 1.14.3 Release Announcement</title>
+<description><p>The Apache Flink community released the second bugfix
version of the Apache Flink 1.14 series.
+The first bugfix release was 1.14.2, being an emergency release due to an
Apache Log4j Zero Day (CVE-2021-44228). Flink 1.14.1 was abandoned.
+That means that this Flink release is the first bugfix release of the Flink
1.14 series which contains bugfixes not related to the mentioned CVE.</p>
+
+<p>This release includes 164 fixes and minor improvements for Flink
1.14.0. 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=12351075&amp;projectId=12315522">JIRA</a>.</p>
+
+<p>We highly recommend all users to upgrade to Flink 1.14.3.</p>
+
+<p>Updated Maven dependencies:</p>
+
+<div class="highlight"><pre><code
class="language-xml"><span
class="nt">&lt;dependency&gt;</span>
+ <span
class="nt">&lt;groupId&gt;</span>org.apache.flink<span
class="nt">&lt;/groupId&gt;</span>
+ <span
class="nt">&lt;artifactId&gt;</span>flink-java<span
class="nt">&lt;/artifactId&gt;</span>
+ <span
class="nt">&lt;version&gt;</span>1.14.3<span
class="nt">&lt;/version&gt;</span>
+<span class="nt">&lt;/dependency&gt;</span>
+<span class="nt">&lt;dependency&gt;</span>
+ <span
class="nt">&lt;groupId&gt;</span>org.apache.flink<span
class="nt">&lt;/groupId&gt;</span>
+ <span
class="nt">&lt;artifactId&gt;</span>flink-streaming-java_2.11<span
class="nt">&lt;/artifactId&gt;</span>
+ <span
class="nt">&lt;version&gt;</span>1.14.3<span
class="nt">&lt;/version&gt;</span>
+<span class="nt">&lt;/dependency&gt;</span>
+<span class="nt">&lt;dependency&gt;</span>
+ <span
class="nt">&lt;groupId&gt;</span>org.apache.flink<span
class="nt">&lt;/groupId&gt;</span>
+ <span
class="nt">&lt;artifactId&gt;</span>flink-clients_2.11<span
class="nt">&lt;/artifactId&gt;</span>
+ <span
class="nt">&lt;version&gt;</span>1.14.3<span
class="nt">&lt;/version&gt;</span>
+<span
class="nt">&lt;/dependency&gt;</span></code></pre></div>
+
+<p>You can find the binaries on the updated <a
href="/downloads.html">Downloads page</a>.</p>
+
+<div class="highlight"><pre><code> Release
Notes - Flink - Version 1.14.3
+</code></pre></div>
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24355">FLINK-24355</a>]
- Expose the flag for enabling checkpoints after tasks finish in the
Web UI
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-15987">FLINK-15987</a>]
- SELECT 1.0e0 / 0.0e0 throws NumberFormatException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-17914">FLINK-17914</a>]
- HistoryServer deletes cached archives if archive listing fails
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-19142">FLINK-19142</a>]
- Local recovery can be broken if slot hijacking happened during a
full restart
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20195">FLINK-20195</a>]
- Jobs endpoint returns duplicated jobs
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20370">FLINK-20370</a>]
- Result is wrong when sink primary key is not the same with query
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21289">FLINK-21289</a>]
- Application mode ignores the pipeline.classpaths configuration
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21345">FLINK-21345</a>]
- NullPointerException
LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22113">FLINK-22113</a>]
- UniqueKey constraint is lost with multiple sources join in SQL
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22954">FLINK-22954</a>]
- Don&#39;t support consuming update and delete changes when use
table function that does not contain table field
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23614">FLINK-23614</a>]
- The resulting scale of TRUNCATE(DECIMAL, ...) is not correct
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23704">FLINK-23704</a>]
- FLIP-27 sources are not generating LatencyMarkers
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23827">FLINK-23827</a>]
- Fix ModifiedMonotonicity inference for some node
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23919">FLINK-23919</a>]
- PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid
Calc for Window TVF
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24156">FLINK-24156</a>]
- BlobServer crashes due to SocketTimeoutException in Java 11
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24232">FLINK-24232</a>]
- Archiving of suspended jobs prevents breaks subsequent archive
attempts
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24291">FLINK-24291</a>]
- Decimal precision is lost when deserializing in test cases
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24310">FLINK-24310</a>]
- A bug in the BufferingSink example in the doc
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24315">FLINK-24315</a>]
- Cannot rebuild watcher thread while the K8S API server is unavailable
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24318">FLINK-24318</a>]
- Casting a number to boolean has different results between
&#39;select&#39; fields and &#39;where&#39; condition
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24331">FLINK-24331</a>]
- PartiallyFinishedSourcesITCase fails with &quot;No downstream
received 0 from xxx;&quot;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24336">FLINK-24336</a>]
- PyFlink TableEnvironment executes the SQL randomly
MalformedURLException with the configuration for
&#39;pipeline.classpaths&#39;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24344">FLINK-24344</a>]
- Handling of IOExceptions when triggering checkpoints doesn&#39;t
cause job failover
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24353">FLINK-24353</a>]
- Bash scripts do not respect dynamic configurations when calculating
memory sizes
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24366">FLINK-24366</a>]
- Unnecessary/misleading error message about failing restores when
tasks are already canceled.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24371">FLINK-24371</a>]
- Support SinkWriter preCommit without the need of a committer
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24377">FLINK-24377</a>]
- TM resource may not be properly released after heartbeat timeout
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24380">FLINK-24380</a>]
- Flink should handle the state transition of the pod from Pending to
Failed
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24381">FLINK-24381</a>]
- Table API exceptions may leak sensitive configuration values
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24401">FLINK-24401</a>]
- TM cannot exit after Metaspace OOM
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24407">FLINK-24407</a>]
- Pulsar connector chinese document link to Pulsar document location
incorrectly.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24408">FLINK-24408</a>]
- org.codehaus.janino.InternalCompilerException: Compiling
&quot;StreamExecValues$200&quot;: Code of method
&quot;nextRecord(Ljava/lang/Object;)Ljava/lang/Object;&quot; of class
&quot;StreamExecValues$200&quot; grows beyond 64 KB
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24409">FLINK-24409</a>]
- Kafka topics with periods in their names generate a constant stream
of errors
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24431">FLINK-24431</a>]
- [Kinesis][EFO] EAGER registration strategy does not work when job
fails over
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24432">FLINK-24432</a>]
- RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator
method
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24465">FLINK-24465</a>]
- Wrong javadoc and documentation for buffer timeout
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24467">FLINK-24467</a>]
- Set min and max buffer size even if the difference less than
threshold
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24468">FLINK-24468</a>]
- NPE when notifyNewBufferSize
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24469">FLINK-24469</a>]
- Incorrect calcualtion of the buffer size in case of channel data skew
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24480">FLINK-24480</a>]
- EqualiserCodeGeneratorTest fails on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24488">FLINK-24488</a>]
- KafkaRecordSerializationSchemaBuilder does not forward timestamp
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24492">FLINK-24492</a>]
- incorrect implicit type conversion between numeric and (var)char
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24506">FLINK-24506</a>]
- checkpoint directory is not configurable through the Flink
configuration passed into the StreamExecutionEnvironment
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24540">FLINK-24540</a>]
- Fix Resource leak due to Files.list
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24543">FLINK-24543</a>]
- Zookeeper connection issue causes inconsistent state in Flink
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24550">FLINK-24550</a>]
- Can not access job information from a standby jobmanager UI
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24551">FLINK-24551</a>]
- BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24552">FLINK-24552</a>]
- Ineffective buffer debloat configuration in randomized tests
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24563">FLINK-24563</a>]
- Comparing timstamp_ltz with random string throws NullPointerException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24596">FLINK-24596</a>]
- Bugs in sink.buffer-flush before upsert-kafka
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24597">FLINK-24597</a>]
- RocksdbStateBackend getKeysAndNamespaces would return duplicate data
when using MapState
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24600">FLINK-24600</a>]
- Duplicate 99th percentile displayed in checkpoint summary
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24608">FLINK-24608</a>]
- Sinks built with the unified sink framework do not receive
timestamps when used in Table API
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24613">FLINK-24613</a>]
- Documentation on orc supported data types is outdated
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24647">FLINK-24647</a>]
- ClusterUncaughtExceptionHandler does not log the exception
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24654">FLINK-24654</a>]
- NPE on RetractableTopNFunction when some records were cleared by
state ttl
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24662">FLINK-24662</a>]
- PyFlink sphinx check failed with &quot;node class
&#39;meta&#39; is already registered, its visitors will be
overridden&quot;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24667">FLINK-24667</a>]
- Channel state writer would fail the task directly if meeting
exception previously
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24676">FLINK-24676</a>]
- Schema does not match if explain insert statement with partial column
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24678">FLINK-24678</a>]
- Correct the metric name of map state contains latency
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24691">FLINK-24691</a>]
- FLINK SQL SUM() causes a precision error
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24704">FLINK-24704</a>]
- Exception occurs when the input record loses monotonicity on the
sort key field of UpdatableTopNFunction
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24706">FLINK-24706</a>]
- AkkaInvocationHandler silently ignores deserialization errors
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24708">FLINK-24708</a>]
- `ConvertToNotInOrInRule` has a bug which leads to wrong result
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24728">FLINK-24728</a>]
- Batch SQL file sink forgets to close the output stream
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24733">FLINK-24733</a>]
- Data loss in pulsar source when using shared mode
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24738">FLINK-24738</a>]
- Fail during announcing buffer size to released local channel
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24761">FLINK-24761</a>]
- Fix PartitionPruner code gen compile fail
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24773">FLINK-24773</a>]
- KafkaCommitter should fail on unknown Exception
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24777">FLINK-24777</a>]
- Processed (persisted) in-flight data description miss on Monitoring
Checkpointing page
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24789">FLINK-24789</a>]
- IllegalStateException with CheckpointCleaner being closed already
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24792">FLINK-24792</a>]
- OperatorCoordinatorSchedulerTest crashed JVM on AZP
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24835">FLINK-24835</a>]
- &quot;group by&quot; in the interval join will throw a
exception
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24846">FLINK-24846</a>]
- AsyncWaitOperator fails during stop-with-savepoint
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24858">FLINK-24858</a>]
- TypeSerializer version mismatch during eagerly restore
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24874">FLINK-24874</a>]
- Dropdown menu is not properly shown in UI
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24885">FLINK-24885</a>]
- ProcessElement Interface parameter Collector :
java.lang.NullPointerException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24919">FLINK-24919</a>]
- UnalignedCheckpointITCase hangs on Azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24922">FLINK-24922</a>]
- Fix spelling errors in the word &quot;parallism&quot;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24937">FLINK-24937</a>]
- &quot;kubernetes application HA test&quot; hangs on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24938">FLINK-24938</a>]
- Checkpoint cleaner is closed before checkpoints are discarded
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25022">FLINK-25022</a>]
- ClassLoader leak with ThreadLocals on the JM when submitting a job
through the REST API
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25067">FLINK-25067</a>]
- Correct the description of RocksDB&#39;s background threads
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25084">FLINK-25084</a>]
- Field names must be unique. Found duplicates
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25091">FLINK-25091</a>]
- Official website document FileSink orc compression attribute
reference error
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25096">FLINK-25096</a>]
- Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25126">FLINK-25126</a>]
- FlinkKafkaInternalProducer state is not reset if transaction
finalization fails
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25132">FLINK-25132</a>]
- KafkaSource cannot work with object-reusing DeserializationSchema
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25134">FLINK-25134</a>]
- Unused RetryRule in KafkaConsumerTestBase swallows retries
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25222">FLINK-25222</a>]
- Remove NetworkFailureProxy used for Kafka connector tests
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25271">FLINK-25271</a>]
- ApplicationDispatcherBootstrapITCase.
testDispatcherRecoversAfterLosingAndRegainingLeadership failed on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25294">FLINK-25294</a>]
- Incorrect cloudpickle import
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25375">FLINK-25375</a>]
- Update Log4j to 2.17.0
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25418">FLINK-25418</a>]
- The dir_cache is specified in the flink task. When there is no
network, you will still download the python third-party library
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25446">FLINK-25446</a>]
- Avoid sanity check on read bytes on DataInputStream#read(byte[])
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25468">FLINK-25468</a>]
- Local recovery fails if local state storage and RocksDB working
directory are not on the same volume
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25477">FLINK-25477</a>]
- The directory structure of the State Backends document is not
standardized
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25513">FLINK-25513</a>]
- CoFlatMapFunction requires both two flat_maps to yield something
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20443">FLINK-20443</a>]
- ContinuousProcessingTimeTrigger doesn&#39;t fire at the end of
the window
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21467">FLINK-21467</a>]
- Document possible recommended usage of
Bounded{One/Multi}Input.endInput and emphasize that they could be called
multiple times
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23519">FLINK-23519</a>]
- Aggregate State Backend Latency by State Level
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23798">FLINK-23798</a>]
- Avoid using reflection to get filter when partition filter is enabled
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23842">FLINK-23842</a>]
- Add log messages for reader registrations and split requests.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23914">FLINK-23914</a>]
- Make connector testing framework more verbose on test failure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24117">FLINK-24117</a>]
- Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and
ZooKeeperLeaderRetrievalDriver
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24148">FLINK-24148</a>]
- Add bloom filter policy option in RocksDBConfiguredOptions
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24382">FLINK-24382</a>]
- RecordsOut metric for sinks is inaccurate
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24437">FLINK-24437</a>]
- Remove unhandled exception handler from CuratorFramework before
closing it
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24460">FLINK-24460</a>]
- Rocksdb Iterator Error Handling Improvement
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24481">FLINK-24481</a>]
- Translate buffer debloat documenation to chinese
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24529">FLINK-24529</a>]
- flink sql job cannot use custom job name
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24631">FLINK-24631</a>]
- Avoiding directly use the labels as selector for deployment and
service
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24670">FLINK-24670</a>]
- Restructure unaligned checkpoints documentation page to
&quot;Checkpointing under back pressure&quot;
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24690">FLINK-24690</a>]
- Clarification of buffer size threshold calculation in
BufferDebloater
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24695">FLINK-24695</a>]
- Update how to configure unaligned checkpoints in the documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24739">FLINK-24739</a>]
- State requirements for Flink&#39;s application mode in the
documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24813">FLINK-24813</a>]
- Improve ImplicitTypeConversionITCase
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24880">FLINK-24880</a>]
- Error messages &quot;OverflowError: timeout value is too
large&quot; shown when executing PyFlink jobs
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24958">FLINK-24958</a>]
- correct the example and link for temporal table function
documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24987">FLINK-24987</a>]
- Enhance ExternalizedCheckpointCleanup enum
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25092">FLINK-25092</a>]
- Implement artifact cacher for Bash based Elasticsearch test
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24367">FLINK-24367</a>]
- Add a fallback AkkaRpcSystemLoader for tests in the IDE
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24445">FLINK-24445</a>]
- Move RPC System packaging to package phase
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24455">FLINK-24455</a>]
- FallbackAkkaRpcSystemLoader should check for maven errors
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24513">FLINK-24513</a>]
- AkkaRpcSystemLoader must be an ITCase
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24559">FLINK-24559</a>]
- flink-rpc-akka-loader does not bundle flink-rpc-akka
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24609">FLINK-24609</a>]
- flink-rpc-akka uses wrong Scala version property for
parser-combinators
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24859">FLINK-24859</a>]
- Document new File formats
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25472">FLINK-25472</a>]
- Update to Log4j 2.17.1
+</li>
+</ul>
+
+</description>
+<pubDate>Mon, 17 Jan 2022 09:00:00 +0100</pubDate>
+<link>https://flink.apache.org/news/2022/01/17/release-1.14.3.html</link>
+<guid isPermaLink="true">/news/2022/01/17/release-1.14.3.html</guid>
+</item>
+
+<item>
<title>Apache Flink ML 2.0.0 Release Announcement</title>
<description><p>The Apache Flink community is excited to announce the
release of Flink ML
2.0.0! Flink ML is a library that provides APIs and infrastructure for building
@@ -19805,156 +20123,5 @@ for a full reference of Flink’s metrics
system.</p>
<guid isPermaLink="true">/news/2019/02/25/release-1.6.4.html</guid>
</item>
-<item>
-<title>Apache Flink 1.7.2 Released</title>
-<description><p>The Apache Flink community released the second bugfix
version of the Apache Flink 1.7 series.</p>
-
-<p>This release includes more than 40 fixes and minor improvements for
Flink 1.7.1, covering several critical
-recovery issues as well as problems in the Flink streaming
connectors.</p>
-
-<p>The list below includes a detailed list of all fixes.
-We highly recommend all users to upgrade to Flink 1.7.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.7.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.7.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.7.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>
-
-<p>List of resolved issues:</p>
-
-<h2> Sub-task
-</h2>
-<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11179">FLINK-11179</a>]
- JoinCancelingITCase#testCancelSortMatchWhileDoingHeavySorting test
error
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11180">FLINK-11180</a>]
- ProcessFailureCancelingITCase#testCancelingOnProcessFailure
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11181">FLINK-11181</a>]
- SimpleRecoveryITCaseBase test error
-</li>
-</ul>
-
-<h2> Bug
-</h2>
-<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-10721">FLINK-10721</a>]
- Kafka discovery-loop exceptions may be swallowed
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-10761">FLINK-10761</a>]
- MetricGroup#getAllVariables can deadlock
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-10774">FLINK-10774</a>]
- connection leak when partition discovery is disabled and open throws
exception
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-10848">FLINK-10848</a>]
- Flink&#39;s Yarn ResourceManager can allocate too many excess
containers
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11046">FLINK-11046</a>]
- ElasticSearch6Connector cause thread blocked when index failed with
retry
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11071">FLINK-11071</a>]
- Dynamic proxy classes cannot be resolved when deserializing job graph
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11083">FLINK-11083</a>]
- CRowSerializerConfigSnapshot is not instantiable
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11084">FLINK-11084</a>]
- Incorrect ouput after two consecutive split and select
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11100">FLINK-11100</a>]
- Presto S3 FileSystem E2E test broken
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11119">FLINK-11119</a>]
- Incorrect Scala example for Table Function
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11134">FLINK-11134</a>]
- Invalid REST API request should not log the full exception in Flink
logs
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11145">FLINK-11145</a>]
- Fix Hadoop version handling in binary release script
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11151">FLINK-11151</a>]
- FileUploadHandler stops working if the upload directory is removed
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11168">FLINK-11168</a>]
- LargePlanTest times out on Travis
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11173">FLINK-11173</a>]
- Proctime attribute validation throws an incorrect exception message
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11187">FLINK-11187</a>]
- StreamingFileSink with S3 backend transient socket timeout issues
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11191">FLINK-11191</a>]
- Exception in code generation when ambiguous columns in
MATCH_RECOGNIZE
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11194">FLINK-11194</a>]
- missing Scala 2.12 build of HBase connector
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11201">FLINK-11201</a>]
- Document SBT dependency requirements when using MiniClusterResource
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11224">FLINK-11224</a>]
- Log is missing in scala-shell
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11227">FLINK-11227</a>]
- The DescriptorProperties contains some bounds checking errors
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11232">FLINK-11232</a>]
- Empty Start Time of sub-task on web dashboard
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11234">FLINK-11234</a>]
- ExternalTableCatalogBuilder unable to build a batch-only table
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11235">FLINK-11235</a>]
- Elasticsearch connector leaks threads if no connection could be
established
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11246">FLINK-11246</a>]
- Fix distinct AGG visibility issues
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11251">FLINK-11251</a>]
- Incompatible metric name on prometheus reporter
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11279">FLINK-11279</a>]
- Invalid week interval parsing in ExpressionParser
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11302">FLINK-11302</a>]
- FlinkS3FileSystem uses an incorrect path for temporary files.
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11389">FLINK-11389</a>]
- Incorrectly use job information when call
getSerializedTaskInformation in class TaskDeploymentDescriptor
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11419">FLINK-11419</a>]
- StreamingFileSink fails to recover after taskmanager failure
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11436">FLINK-11436</a>]
- Java deserialization failure of the AvroSerializer when used in an
old CompositeSerializers
-</li>
-</ul>
-
-<h2> New Feature
-</h2>
-<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-10457">FLINK-10457</a>]
- Support SequenceFile for StreamingFileSink
-</li>
-</ul>
-
-<h2> Improvement
-</h2>
-<ul>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-10910">FLINK-10910</a>]
- Harden Kubernetes e2e test
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11023">FLINK-11023</a>]
- Update LICENSE and NOTICE files for flink-connectors
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11079">FLINK-11079</a>]
- Skip deployment for flink-storm-examples
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11207">FLINK-11207</a>]
- Update Apache commons-compress from 1.4.1 to 1.18
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11216">FLINK-11216</a>]
- Back to top button is missing in the Joining document and is not
properly placed in the Process Function document
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11262">FLINK-11262</a>]
- Bump jython-standalone to 2.7.1
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11289">FLINK-11289</a>]
- Rework example module structure to account for licensing
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11304">FLINK-11304</a>]
- Typo in time attributes doc
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11331">FLINK-11331</a>]
- Fix errors in tableApi.md and functions.md
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11469">FLINK-11469</a>]
- fix Tuning Checkpoints and Large State doc
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11473">FLINK-11473</a>]
- Clarify Documenation on Latency Tracking
-</li>
-<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-11628">FLINK-11628</a>]
- Cache maven on travis
-</li>
-</ul>
-</description>
-<pubDate>Fri, 15 Feb 2019 13:00:00 +0100</pubDate>
-<link>https://flink.apache.org/news/2019/02/15/release-1.7.2.html</link>
-<guid isPermaLink="true">/news/2019/02/15/release-1.7.2.html</guid>
-</item>
-
</channel>
</rss>
diff --git a/content/blog/index.html b/content/blog/index.html
index 2a8f050..92d6f2d 100644
--- a/content/blog/index.html
+++ b/content/blog/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3 Release
Announcement</a></h2>
+
+ <p>17 Jan 2022
+ Thomas Weise (<a href="https://twitter.com/thweise";>@thweise</a>) &
Martijn Visser (<a
href="https://twitter.com/martijnvisser82";>@martijnvisser82</a>)</p>
+
+ <p>The Apache Flink community released the second bugfix version of the
Apache Flink 1.14 series.</p>
+
+ <p><a href="/news/2022/01/17/release-1.14.3.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML 2.0.0 Release
Announcement</a></h2>
<p>07 Jan 2022
@@ -321,21 +334,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2021/10/19/release-1.13.3.html">Apache Flink 1.13.3
Released</a></h2>
-
- <p>19 Oct 2021
- Chesnay Schepler </p>
-
- <p><p>The Apache Flink community released the third bugfix version of
the Apache Flink 1.13 series.</p>
-
-</p>
-
- <p><a href="/news/2021/10/19/release-1.13.3.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -368,6 +366,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page10/index.html b/content/blog/page10/index.html
index 9f2b4e1..880bc61 100644
--- a/content/blog/page10/index.html
+++ b/content/blog/page10/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/2019/06/05/flink-network-stack.html">A
Deep-Dive into Flink's Network Stack</a></h2>
+
+ <p>05 Jun 2019
+ Nico Kruber </p>
+
+ <p>Flink’s network stack is one of the core components that make up
Apache Flink's runtime module sitting at the core of every Flink job. In this
post, which is the first in a series of posts about the network stack, we look
at the abstractions exposed to the stream operators and detail their physical
implementation and various optimisations in Apache Flink.</p>
+
+ <p><a href="/2019/06/05/flink-network-stack.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/2019/05/19/state-ttl.html">State TTL in
Flink 1.8.0: How to Automatically Cleanup Application State in Apache
Flink</a></h2>
<p>19 May 2019
@@ -327,21 +340,6 @@ for more details.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2019/02/15/release-1.7.2.html">Apache Flink 1.7.2 Released</a></h2>
-
- <p>15 Feb 2019
- </p>
-
- <p><p>The Apache Flink community released the second bugfix version of
the Apache Flink 1.7 series.</p>
-
-</p>
-
- <p><a href="/news/2019/02/15/release-1.7.2.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -374,6 +372,16 @@ for more details.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page11/index.html b/content/blog/page11/index.html
index 88814e5..05703d1 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/2019/02/15/release-1.7.2.html">Apache Flink 1.7.2 Released</a></h2>
+
+ <p>15 Feb 2019
+ </p>
+
+ <p><p>The Apache Flink community released the second bugfix version of
the Apache Flink 1.7 series.</p>
+
+</p>
+
+ <p><a href="/news/2019/02/15/release-1.7.2.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2019/02/13/unified-batch-streaming-blink.html">Batch as a Special
Case of Streaming and Alibaba's contribution of Blink</a></h2>
<p>13 Feb 2019
@@ -335,21 +350,6 @@ Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2018/08/21/release-1.5.3.html">Apache Flink 1.5.3 Released</a></h2>
-
- <p>21 Aug 2018
- </p>
-
- <p><p>The Apache Flink community released the third bugfix version of
the Apache Flink 1.5 series.</p>
-
-</p>
-
- <p><a href="/news/2018/08/21/release-1.5.3.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -382,6 +382,16 @@ Please check the <a
href="https://issues.apache.org/jira/secure/ReleaseNote.jspa
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page12/index.html b/content/blog/page12/index.html
index 52e3b9f..7ce300f 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/2018/08/21/release-1.5.3.html">Apache Flink 1.5.3 Released</a></h2>
+
+ <p>21 Aug 2018
+ </p>
+
+ <p><p>The Apache Flink community released the third bugfix version of
the Apache Flink 1.5 series.</p>
+
+</p>
+
+ <p><a href="/news/2018/08/21/release-1.5.3.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2018/08/09/release-1.6.0.html">Apache Flink 1.6.0 Release
Announcement</a></h2>
<p>09 Aug 2018
@@ -331,19 +346,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2017/12/21/2017-year-in-review.html">Apache Flink in 2017: Year in
Review</a></h2>
-
- <p>21 Dec 2017
- Chris Ward (<a href="https://twitter.com/chrischinch";>@chrischinch</a>)
& Mike Winters (<a href="https://twitter.com/wints";>@wints</a>)</p>
-
- <p>As 2017 comes to a close, let's take a moment to look back on the
Flink community's great work during the past year.</p>
-
- <p><a href="/news/2017/12/21/2017-year-in-review.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -376,6 +378,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page13/index.html b/content/blog/page13/index.html
index 446a21f..547f587 100644
--- a/content/blog/page13/index.html
+++ b/content/blog/page13/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2017/12/21/2017-year-in-review.html">Apache Flink in 2017: Year in
Review</a></h2>
+
+ <p>21 Dec 2017
+ Chris Ward (<a href="https://twitter.com/chrischinch";>@chrischinch</a>)
& Mike Winters (<a href="https://twitter.com/wints";>@wints</a>)</p>
+
+ <p>As 2017 comes to a close, let's take a moment to look back on the
Flink community's great work during the past year.</p>
+
+ <p><a href="/news/2017/12/21/2017-year-in-review.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2017/12/12/release-1.4.0.html">Apache Flink 1.4.0 Release
Announcement</a></h2>
<p>12 Dec 2017
@@ -337,19 +350,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/03/29/table-sql-api-update.html">From Streams to Tables and
Back Again: An Update on Flink's Table & SQL API</a></h2>
-
- <p>29 Mar 2017 by Timo Walther (<a
href="https://twitter.com/";>@twalthr</a>)
- </p>
-
- <p><p>Broadening the user base and unifying batch & streaming with
relational APIs</p></p>
-
- <p><a href="/news/2017/03/29/table-sql-api-update.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -382,6 +382,16 @@ what’s coming in Flink 1.4.0 as well as a preview of what
the Flink community
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page14/index.html b/content/blog/page14/index.html
index 7667dce..7cfd096 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/2017/03/29/table-sql-api-update.html">From Streams to Tables and
Back Again: An Update on Flink's Table & SQL API</a></h2>
+
+ <p>29 Mar 2017 by Timo Walther (<a
href="https://twitter.com/";>@twalthr</a>)
+ </p>
+
+ <p><p>Broadening the user base and unifying batch & streaming with
relational APIs</p></p>
+
+ <p><a href="/news/2017/03/29/table-sql-api-update.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2017/03/23/release-1.1.5.html">Apache Flink 1.1.5 Released</a></h2>
<p>23 Mar 2017
@@ -331,20 +344,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/news/2016/05/24/stream-sql.html">Stream
Processing for Everyone with SQL and Apache Flink</a></h2>
-
- <p>24 May 2016 by Fabian Hueske (<a
href="https://twitter.com/";>@fhueske</a>)
- </p>
-
- <p><p>About six months ago, the Apache Flink community started an effort
to add a SQL interface for stream data analysis. SQL is <i>the</i> standard
language to access and process data. Everybody who occasionally analyzes data
is familiar with SQL. Consequently, a SQL interface for stream data processing
will make this technology accessible to a much wider audience. Moreover, SQL
support for streaming data will also enable new use cases such as interactive
and ad-hoc stream analysi [...]
-<p>In this blog post, we report on the current status, architectural design,
and future plans of the Apache Flink community to implement support for SQL as
a language for analyzing data streams.</p></p>
-
- <p><a href="/news/2016/05/24/stream-sql.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -377,6 +376,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page15/index.html b/content/blog/page15/index.html
index 7856864..7b1d8dc 100644
--- a/content/blog/page15/index.html
+++ b/content/blog/page15/index.html
@@ -201,6 +201,20 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a href="/news/2016/05/24/stream-sql.html">Stream
Processing for Everyone with SQL and Apache Flink</a></h2>
+
+ <p>24 May 2016 by Fabian Hueske (<a
href="https://twitter.com/";>@fhueske</a>)
+ </p>
+
+ <p><p>About six months ago, the Apache Flink community started an effort
to add a SQL interface for stream data analysis. SQL is <i>the</i> standard
language to access and process data. Everybody who occasionally analyzes data
is familiar with SQL. Consequently, a SQL interface for stream data processing
will make this technology accessible to a much wider audience. Moreover, SQL
support for streaming data will also enable new use cases such as interactive
and ad-hoc stream analysi [...]
+<p>In this blog post, we report on the current status, architectural design,
and future plans of the Apache Flink community to implement support for SQL as
a language for analyzing data streams.</p></p>
+
+ <p><a href="/news/2016/05/24/stream-sql.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2016/05/11/release-1.0.3.html">Flink 1.0.3 Released</a></h2>
<p>11 May 2016
@@ -329,20 +343,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2015/12/04/Introducing-windows.html">Introducing Stream Windows in
Apache Flink</a></h2>
-
- <p>04 Dec 2015 by Fabian Hueske (<a
href="https://twitter.com/";>@fhueske</a>)
- </p>
-
- <p><p>The data analysis space is witnessing an evolution from batch to
stream processing for many use cases. Although batch can be handled as a
special case of stream processing, analyzing never-ending streaming data often
requires a shift in the mindset and comes with its own terminology (for
example, “windowing” and “at-least-once”/”exactly-once” processing). This shift
and the new terminology can be quite confusing for people being new to the
space of stream processing. Apache F [...]
-<p>In this blog post, we discuss the concept of windows for stream processing,
present Flink's built-in windows, and explain its support for custom windowing
semantics.</p></p>
-
- <p><a href="/news/2015/12/04/Introducing-windows.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -375,6 +375,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page16/index.html b/content/blog/page16/index.html
index 04e9020..ea1de5d 100644
--- a/content/blog/page16/index.html
+++ b/content/blog/page16/index.html
@@ -201,6 +201,20 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2015/12/04/Introducing-windows.html">Introducing Stream Windows in
Apache Flink</a></h2>
+
+ <p>04 Dec 2015 by Fabian Hueske (<a
href="https://twitter.com/";>@fhueske</a>)
+ </p>
+
+ <p><p>The data analysis space is witnessing an evolution from batch to
stream processing for many use cases. Although batch can be handled as a
special case of stream processing, analyzing never-ending streaming data often
requires a shift in the mindset and comes with its own terminology (for
example, “windowing” and “at-least-once”/”exactly-once” processing). This shift
and the new terminology can be quite confusing for people being new to the
space of stream processing. Apache F [...]
+<p>In this blog post, we discuss the concept of windows for stream processing,
present Flink's built-in windows, and explain its support for custom windowing
semantics.</p></p>
+
+ <p><a href="/news/2015/12/04/Introducing-windows.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2015/11/27/release-0.10.1.html">Flink 0.10.1 released</a></h2>
<p>27 Nov 2015
@@ -338,26 +352,6 @@ vertex-centric or gather-sum-apply to Flink dataflows.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2015/04/13/release-0.9.0-milestone1.html">Announcing Flink
0.9.0-milestone1 preview release</a></h2>
-
- <p>13 Apr 2015
- </p>
-
- <p><p>The Apache Flink community is pleased to announce the availability
of
-the 0.9.0-milestone-1 release. The release is a preview of the
-upcoming 0.9.0 release. It contains many new features which will be
-available in the upcoming 0.9 release. Interested users are encouraged
-to try it out and give feedback. As the version number indicates, this
-release is a preview release that contains known issues.</p>
-
-</p>
-
- <p><a href="/news/2015/04/13/release-0.9.0-milestone1.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -390,6 +384,16 @@ release is a preview release that contains known
issues.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page17/index.html b/content/blog/page17/index.html
index 1f50c11..e8411dc 100644
--- a/content/blog/page17/index.html
+++ b/content/blog/page17/index.html
@@ -201,6 +201,26 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2015/04/13/release-0.9.0-milestone1.html">Announcing Flink
0.9.0-milestone1 preview release</a></h2>
+
+ <p>13 Apr 2015
+ </p>
+
+ <p><p>The Apache Flink community is pleased to announce the availability
of
+the 0.9.0-milestone-1 release. The release is a preview of the
+upcoming 0.9.0 release. It contains many new features which will be
+available in the upcoming 0.9 release. Interested users are encouraged
+to try it out and give feedback. As the version number indicates, this
+release is a preview release that contains known issues.</p>
+
+</p>
+
+ <p><a href="/news/2015/04/13/release-0.9.0-milestone1.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2015/04/07/march-in-flink.html">March 2015 in the Flink
community</a></h2>
<p>07 Apr 2015
@@ -340,21 +360,6 @@ and offers a new API including definition of flexible
windows.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2014/10/03/upcoming_events.html">Upcoming Events</a></h2>
-
- <p>03 Oct 2014
- </p>
-
- <p><p>We are happy to announce several upcoming Flink events both in
Europe and the US. Starting with a <strong>Flink hackathon in
Stockholm</strong> (Oct 8-9) and a talk about Flink at the <strong>Stockholm
Hadoop User Group</strong> (Oct 8). This is followed by the very first
<strong>Flink Meetup in Berlin</strong> (Oct 15). In the US, there will be two
Flink Meetup talks: the first one at the <strong>Pasadena Big Data User
Group</strong> (Oct 29) and the second one at <strong>Si [...]
-
-</p>
-
- <p><a href="/news/2014/10/03/upcoming_events.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -387,6 +392,16 @@ and offers a new API including definition of flexible
windows.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page18/index.html b/content/blog/page18/index.html
index e651a6f..870d5b4 100644
--- a/content/blog/page18/index.html
+++ b/content/blog/page18/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2014/10/03/upcoming_events.html">Upcoming Events</a></h2>
+
+ <p>03 Oct 2014
+ </p>
+
+ <p><p>We are happy to announce several upcoming Flink events both in
Europe and the US. Starting with a <strong>Flink hackathon in
Stockholm</strong> (Oct 8-9) and a talk about Flink at the <strong>Stockholm
Hadoop User Group</strong> (Oct 8). This is followed by the very first
<strong>Flink Meetup in Berlin</strong> (Oct 15). In the US, there will be two
Flink Meetup talks: the first one at the <strong>Pasadena Big Data User
Group</strong> (Oct 29) and the second one at <strong>Si [...]
+
+</p>
+
+ <p><a href="/news/2014/10/03/upcoming_events.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2014/09/26/release-0.6.1.html">Apache Flink 0.6.1 available</a></h2>
<p>26 Sep 2014
@@ -265,6 +280,16 @@ academic and open source project that Flink originates
from.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html
index 00b36ea..407187c 100644
--- a/content/blog/page2/index.html
+++ b/content/blog/page2/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2021/10/19/release-1.13.3.html">Apache Flink 1.13.3
Released</a></h2>
+
+ <p>19 Oct 2021
+ Chesnay Schepler </p>
+
+ <p><p>The Apache Flink community released the third bugfix version of
the Apache Flink 1.13 series.</p>
+
+</p>
+
+ <p><a href="/news/2021/10/19/release-1.13.3.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2021/09/29/release-1.14.0.html">Apache Flink 1.14.0 Release
Announcement</a></h2>
<p>29 Sep 2021
@@ -339,21 +354,6 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2021/05/28/release-1.13.1.html">Apache Flink 1.13.1
Released</a></h2>
-
- <p>28 May 2021
- Dawid Wysakowicz (<a
href="https://twitter.com/dwysakowicz";>@dwysakowicz</a>)</p>
-
- <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.13 series.</p>
-
-</p>
-
- <p><a href="/news/2021/05/28/release-1.13.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -386,6 +386,16 @@ This new release brings various improvements to the
StateFun runtime, a leaner w
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html
index c21e8df..59dc953 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/2021/05/28/release-1.13.1.html">Apache Flink 1.13.1
Released</a></h2>
+
+ <p>28 May 2021
+ Dawid Wysakowicz (<a
href="https://twitter.com/dwysakowicz";>@dwysakowicz</a>)</p>
+
+ <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.13 series.</p>
+
+</p>
+
+ <p><a href="/news/2021/05/28/release-1.13.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2021/05/21/release-1.12.4.html">Apache Flink 1.12.4
Released</a></h2>
<p>21 May 2021
@@ -329,21 +344,6 @@ to develop scalable, consistent, and elastic distributed
applications.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2021/01/19/release-1.12.1.html">Apache Flink 1.12.1
Released</a></h2>
-
- <p>19 Jan 2021
- Xintong Song </p>
-
- <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.12 series.</p>
-
-</p>
-
- <p><a href="/news/2021/01/19/release-1.12.1.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -376,6 +376,16 @@ to develop scalable, consistent, and elastic distributed
applications.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html
index 9740522..40b62c6 100644
--- a/content/blog/page4/index.html
+++ b/content/blog/page4/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2021/01/19/release-1.12.1.html">Apache Flink 1.12.1
Released</a></h2>
+
+ <p>19 Jan 2021
+ Xintong Song </p>
+
+ <p><p>The Apache Flink community released the first bugfix version of
the Apache Flink 1.12 series.</p>
+
+</p>
+
+ <p><a href="/news/2021/01/19/release-1.12.1.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a href="/2021/01/18/rocksdb.html">Using RocksDB
State Backend in Apache Flink: When and How</a></h2>
<p>18 Jan 2021
@@ -323,19 +338,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/10/13/stateful-serverless-internals.html">Stateful Functions
Internals: Behind the scenes of Stateful Serverless</a></h2>
-
- <p>13 Oct 2020
- Tzu-Li (Gordon) Tai (<a
href="https://twitter.com/tzulitai";>@tzulitai</a>)</p>
-
- <p>This blog post dives deep into the internals of the StateFun runtime,
taking a look at how it enables consistent and fault-tolerant stateful
serverless applications.</p>
-
- <p><a
href="/news/2020/10/13/stateful-serverless-internals.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -368,6 +370,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html
index 09da3a2..626159e 100644
--- a/content/blog/page5/index.html
+++ b/content/blog/page5/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/10/13/stateful-serverless-internals.html">Stateful Functions
Internals: Behind the scenes of Stateful Serverless</a></h2>
+
+ <p>13 Oct 2020
+ Tzu-Li (Gordon) Tai (<a
href="https://twitter.com/tzulitai";>@tzulitai</a>)</p>
+
+ <p>This blog post dives deep into the internals of the StateFun runtime,
taking a look at how it enables consistent and fault-tolerant stateful
serverless applications.</p>
+
+ <p><a
href="/news/2020/10/13/stateful-serverless-internals.html">Continue reading
»</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2020/09/28/release-statefun-2.2.0.html">Stateful Functions 2.2.0
Release Announcement</a></h2>
<p>28 Sep 2020
@@ -329,19 +342,6 @@ as well as increased observability for operational
purposes.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/07/30/demo-fraud-detection-3.html">Advanced Flink Application
Patterns Vol.3: Custom Window Processing</a></h2>
-
- <p>30 Jul 2020
- Alexander Fedulov (<a
href="https://twitter.com/alex_fedulov";>@alex_fedulov</a>)</p>
-
- <p>In this series of blog posts you will learn about powerful Flink
patterns for building streaming applications.</p>
-
- <p><a href="/news/2020/07/30/demo-fraud-detection-3.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -374,6 +374,16 @@ as well as increased observability for operational
purposes.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page6/index.html b/content/blog/page6/index.html
index ef72f78..3098079 100644
--- a/content/blog/page6/index.html
+++ b/content/blog/page6/index.html
@@ -201,6 +201,19 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/07/30/demo-fraud-detection-3.html">Advanced Flink Application
Patterns Vol.3: Custom Window Processing</a></h2>
+
+ <p>30 Jul 2020
+ Alexander Fedulov (<a
href="https://twitter.com/alex_fedulov";>@alex_fedulov</a>)</p>
+
+ <p>In this series of blog posts you will learn about powerful Flink
patterns for building streaming applications.</p>
+
+ <p><a href="/news/2020/07/30/demo-fraud-detection-3.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/2020/07/28/flink-sql-demo-building-e2e-streaming-application.html">Flink
SQL Demo: Building an End-to-End Streaming Application</a></h2>
<p>28 Jul 2020
@@ -335,21 +348,6 @@ and provide a tutorial for running Streaming ETL with
Flink on Zeppelin.</p>
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2020/06/09/release-statefun-2.1.0.html">Stateful Functions 2.1.0
Release Announcement</a></h2>
-
- <p>09 Jun 2020
- Marta Paes (<a href="https://twitter.com/morsapaes";>@morsapaes</a>)</p>
-
- <p><p>The Apache Flink community is happy to announce the release of
Stateful Functions (StateFun) 2.1.0! This release introduces new features
around state expiration and performance improvements for co-located
deployments, as well as other important changes that improve the stability and
testability of the project. As the community around StateFun grows, the release
cycle will follow this pattern of smaller and more frequent releases to
incorporate user feedback and allow for fast [...]
-
-</p>
-
- <p><a href="/news/2020/06/09/release-statefun-2.1.0.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -382,6 +380,16 @@ and provide a tutorial for running Streaming ETL with
Flink on Zeppelin.</p>
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page7/index.html b/content/blog/page7/index.html
index fa37408..24a11ad 100644
--- a/content/blog/page7/index.html
+++ b/content/blog/page7/index.html
@@ -201,6 +201,21 @@
<!-- Blog posts -->
<article>
+ <h2 class="blog-title"><a
href="/news/2020/06/09/release-statefun-2.1.0.html">Stateful Functions 2.1.0
Release Announcement</a></h2>
+
+ <p>09 Jun 2020
+ Marta Paes (<a href="https://twitter.com/morsapaes";>@morsapaes</a>)</p>
+
+ <p><p>The Apache Flink community is happy to announce the release of
Stateful Functions (StateFun) 2.1.0! This release introduces new features
around state expiration and performance improvements for co-located
deployments, as well as other important changes that improve the stability and
testability of the project. As the community around StateFun grows, the release
cycle will follow this pattern of smaller and more frequent releases to
incorporate user feedback and allow for fast [...]
+
+</p>
+
+ <p><a href="/news/2020/06/09/release-statefun-2.1.0.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2020/05/12/release-1.10.1.html">Apache Flink 1.10.1
Released</a></h2>
<p>12 May 2020
@@ -324,21 +339,6 @@ This release marks a big milestone: Stateful Functions 2.0
is not only an API up
<hr>
- <article>
- <h2 class="blog-title"><a
href="/features/2020/03/27/flink-for-data-warehouse.html">Flink as Unified
Engine for Modern Data Warehousing: Production-Ready Hive Integration</a></h2>
-
- <p>27 Mar 2020
- Bowen Li (<a href="https://twitter.com/Bowen__Li";>@Bowen__Li</a>)</p>
-
- <p><p>In this blog post, you will learn our motivation behind the
Flink-Hive integration, and how Flink 1.10 can help modernize your data
warehouse.</p>
-
-</p>
-
- <p><a href="/features/2020/03/27/flink-for-data-warehouse.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -371,6 +371,16 @@ This release marks a big milestone: Stateful Functions 2.0
is not only an API up
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page8/index.html b/content/blog/page8/index.html
index 0c2ecab..39bfecd 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="/features/2020/03/27/flink-for-data-warehouse.html">Flink as Unified
Engine for Modern Data Warehousing: Production-Ready Hive Integration</a></h2>
+
+ <p>27 Mar 2020
+ Bowen Li (<a href="https://twitter.com/Bowen__Li";>@Bowen__Li</a>)</p>
+
+ <p><p>In this blog post, you will learn our motivation behind the
Flink-Hive integration, and how Flink 1.10 can help modernize your data
warehouse.</p>
+
+</p>
+
+ <p><a href="/features/2020/03/27/flink-for-data-warehouse.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2020/03/24/demo-fraud-detection-2.html">Advanced Flink Application
Patterns Vol.2: Dynamic Updates of Application Logic</a></h2>
<p>24 Mar 2020
@@ -323,19 +338,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a
href="/news/2019/12/09/flink-kubernetes-kudo.html">Running Apache Flink on
Kubernetes with KUDO</a></h2>
-
- <p>09 Dec 2019
- Gerred Dillon </p>
-
- <p>A common use case for Apache Flink is streaming data analytics
together with Apache Kafka, which provides a pub/sub model and durability for
data streams. In this post, we demonstrate how to orchestrate Flink and Kafka
with KUDO.</p>
-
- <p><a href="/news/2019/12/09/flink-kubernetes-kudo.html">Continue
reading »</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -368,6 +370,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/blog/page9/index.html b/content/blog/page9/index.html
index 4eeb407..fbf0c30 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/12/09/flink-kubernetes-kudo.html">Running Apache Flink on
Kubernetes with KUDO</a></h2>
+
+ <p>09 Dec 2019
+ Gerred Dillon </p>
+
+ <p>A common use case for Apache Flink is streaming data analytics
together with Apache Kafka, which provides a pub/sub model and durability for
data streams. In this post, we demonstrate how to orchestrate Flink and Kafka
with KUDO.</p>
+
+ <p><a href="/news/2019/12/09/flink-kubernetes-kudo.html">Continue
reading »</a></p>
+ </article>
+
+ <hr>
+
+ <article>
<h2 class="blog-title"><a
href="/news/2019/11/25/query-pulsar-streams-using-apache-flink.html">How to
query Pulsar Streams using Apache Flink</a></h2>
<p>25 Nov 2019
@@ -326,19 +339,6 @@
<hr>
- <article>
- <h2 class="blog-title"><a href="/2019/06/05/flink-network-stack.html">A
Deep-Dive into Flink's Network Stack</a></h2>
-
- <p>05 Jun 2019
- Nico Kruber </p>
-
- <p>Flink’s network stack is one of the core components that make up
Apache Flink's runtime module sitting at the core of every Flink job. In this
post, which is the first in a series of posts about the network stack, we look
at the abstractions exposed to the stream operators and detail their physical
implementation and various optimisations in Apache Flink.</p>
-
- <p><a href="/2019/06/05/flink-network-stack.html">Continue reading
»</a></p>
- </article>
-
- <hr>
-
<!-- Pagination links -->
@@ -371,6 +371,16 @@
<ul id="markdown-toc">
+ <li><a href="/news/2022/01/17/release-1.14.3.html">Apache Flink 1.14.3
Release Announcement</a></li>
+
+
+
+
+
+
+
+
+
<li><a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></li>
diff --git a/content/downloads.html b/content/downloads.html
index 6e47145..251c85b 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-1142" id="markdown-toc-apache-flink-1142">Apache
Flink 1.14.2</a></li>
+ <li><a href="#apache-flink-1143" id="markdown-toc-apache-flink-1143">Apache
Flink 1.14.3</a></li>
<li><a href="#apache-flink-1135" id="markdown-toc-apache-flink-1135">Apache
Flink 1.13.5</a></li>
<li><a href="#apache-flink-1127" id="markdown-toc-apache-flink-1127">Apache
Flink 1.12.7</a></li>
<li><a href="#apache-flink-1116" id="markdown-toc-apache-flink-1116">Apache
Flink 1.11.6</a></li>
@@ -238,21 +238,21 @@ $( document ).ready(function() {
</div>
-<p>Apache Flink® 1.14.2 is our latest stable release.</p>
+<p>Apache Flink® 1.14.3 is our latest stable release.</p>
-<h2 id="apache-flink-1142">Apache Flink 1.14.2</h2>
+<h2 id="apache-flink-1143">Apache Flink 1.14.3</h2>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz";
class="ga-track" id="1142-download_211">Apache Flink 1.14.2 for Scala 2.11</a>
(<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz";
class="ga-track" id="1142-download_211">Apache Flink 1.14.3 for Scala 2.11</a>
(<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz";
class="ga-track" id="1142-download_212">Apache Flink 1.14.2 for Scala 2.12</a>
(<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz";
class="ga-track" id="1142-download_212">Apache Flink 1.14.3 for Scala 2.12</a>
(<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-src.tgz";
class="ga-track" id="1142-download-source">Apache Flink 1.14.2 Source
Release</a>
-(<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-src.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-src.tgz";
class="ga-track" id="1142-download-source">Apache Flink 1.14.3 Source
Release</a>
+(<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.sha512";>sha512</a>)
</p>
<h4 id="release-notes">Release Notes</h4>
@@ -397,17 +397,17 @@ main Flink release:</p>
<div class="highlight"><pre><code class="language-xml"><span
class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-java<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.2<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.2<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.2<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3>
@@ -472,6 +472,17 @@ The <code>statefun-flink-harness</code> dependency
includes a local execution en
<li>
+Flink 1.14.3 - 2022-01-17
+(<a
href="https://archive.apache.org/dist/flink/flink-1.14.3/flink-1.14.3-src.tgz";>Source</a>,
+<a href="https://archive.apache.org/dist/flink/flink-1.14.3";>Binaries</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.14";>Docs</a>,
+<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.14/api/java";>Javadocs</a>,
+<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.14/api/scala/index.html";>Scaladocs</a>)
+
+</li>
+
+<li>
+
Flink 1.14.2 - 2021-12-16
(<a
href="https://archive.apache.org/dist/flink/flink-1.14.2/flink-1.14.2-src.tgz";>Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.14.2";>Binaries</a>,
diff --git a/content/index.html b/content/index.html
index af61fd9..20e1220 100644
--- a/content/index.html
+++ b/content/index.html
@@ -365,6 +365,9 @@
<dl>
+ <dt> <a href="/news/2022/01/17/release-1.14.3.html">Apache Flink
1.14.3 Release Announcement</a></dt>
+ <dd>The Apache Flink community released the second bugfix version of
the Apache Flink 1.14 series.</dd>
+
<dt> <a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></dt>
<dd>The Apache Flink community is excited to announce the release of
Flink ML 2.0.0! This release involves a major refactor of the earlier Flink ML
library and introduces major features that extend the Flink ML API and the
iteration runtime, such as supporting stages with multi-input multi-output,
graph-based stage composition, and a new stream-batch unified iteration
library.</dd>
@@ -378,11 +381,6 @@
<dd><p>The Apache Flink community has released an emergency bugfix
version of Apache Flink Stateful Function 3.1.1.</p>
</dd>
-
- <dt> <a href="/news/2021/12/16/log4j-patch-releases.html">Apache Flink
Log4j emergency releases</a></dt>
- <dd><p>The Apache Flink community has released emergency bugfix
versions of Apache Flink for the 1.11, 1.12, 1.13 and 1.14 series.</p>
-
-</dd>
</dl>
diff --git a/content/news/2022/01/17/release-1.14.3.html
b/content/news/2022/01/17/release-1.14.3.html
new file mode 100644
index 0000000..bdaddbd
--- /dev/null
+++ b/content/news/2022/01/17/release-1.14.3.html
@@ -0,0 +1,566 @@
+<!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.14.3 Release Announcement</title>
+ <link rel="shortcut icon" href="/favicon.ico" type="image/x-icon">
+ <link rel="icon" href="/favicon.ico" type="image/x-icon">
+
+ <!-- Bootstrap -->
+ <link rel="stylesheet" href="/css/bootstrap.min.css">
+ <link rel="stylesheet" href="/css/flink.css">
+ <link rel="stylesheet" href="/css/syntax.css">
+
+ <!-- Blog RSS feed -->
+ <link href="/blog/feed.xml" rel="alternate" type="application/rss+xml"
title="Apache Flink Blog: RSS feed" />
+
+ <!-- jQuery (necessary for Bootstrap's JavaScript plugins) -->
+ <!-- We need to load Jquery in the header for custom google analytics
event tracking-->
+ <script src="/js/jquery.min.js"></script>
+
+ <!-- HTML5 shim and Respond.js for IE8 support of HTML5 elements and media
queries -->
+ <!-- WARNING: Respond.js doesn't work if you view the page via file:// -->
+ <!--[if lt IE 9]>
+ <script
src="https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";></script>
+ <script
src="https://oss.maxcdn.com/respond/1.4.2/respond.min.js";></script>
+ <![endif]-->
+ </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://nightlies.apache.org/flink/flink-docs-release-1.14//docs/try-flink/local_installation/";
target="_blank">With Flink <small><span class="glyphicon
glyphicon-new-window"></span></small></a></li>
+ <li><a
href="https://nightlies.apache.org/flink/flink-statefun-docs-release-3.1/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://nightlies.apache.org/flink/flink-docs-release-1.14";
target="_blank">Flink 1.14 (Latest stable release) <small><span
class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a
href="https://nightlies.apache.org/flink/flink-docs-master";
target="_blank">Flink Master (Latest Snapshot) <small><span class="glyphicon
glyphicon-new-window"></span></small></a></li>
+ <li><a
href="https://nightlies.apache.org/flink/flink-statefun-docs-release-3.1";
target="_blank">Flink Stateful Functions 3.1 (Latest stable release)
<small><span class="glyphicon glyphicon-new-window"></span></small></a></li>
+ <li><a
href="https://nightlies.apache.org/flink/flink-statefun-docs-master";
target="_blank">Flink Stateful Functions Master (Latest Snapshot) <small><span
class="glyphicon glyphicon-new-window"></span></small></a></li>
+ </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.14.3 Release Announcement</h1>
+ <p><i></i></p>
+
+ <article>
+ <p>17 Jan 2022 Thomas Weise (<a
href="https://twitter.com/thweise";>@thweise</a>) & Martijn Visser (<a
href="https://twitter.com/martijnvisser82";>@martijnvisser82</a>)</p>
+
+<p>The Apache Flink community released the second bugfix version of the Apache
Flink 1.14 series.
+The first bugfix release was 1.14.2, being an emergency release due to an
Apache Log4j Zero Day (CVE-2021-44228). Flink 1.14.1 was abandoned.
+That means that this Flink release is the first bugfix release of the Flink
1.14 series which contains bugfixes not related to the mentioned CVE.</p>
+
+<p>This release includes 164 fixes and minor improvements for Flink 1.14.0.
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=12351075&projectId=12315522";>JIRA</a>.</p>
+
+<p>We highly recommend all users to upgrade to Flink 1.14.3.</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.14.3<span
class="nt"></version></span>
+<span class="nt"></dependency></span>
+<span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
+<span class="nt"></dependency></span>
+<span class="nt"><dependency></span>
+ <span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
+ <span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
+ <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
+<span class="nt"></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.14.3
+</code></pre></div>
+
+<h2> Sub-task
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24355";>FLINK-24355</a>] -
Expose the flag for enabling checkpoints after tasks finish in the Web UI
+</li>
+</ul>
+
+<h2> Bug
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-15987";>FLINK-15987</a>] -
SELECT 1.0e0 / 0.0e0 throws NumberFormatException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-17914";>FLINK-17914</a>] -
HistoryServer deletes cached archives if archive listing fails
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-19142";>FLINK-19142</a>] -
Local recovery can be broken if slot hijacking happened during a full
restart
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20195";>FLINK-20195</a>] -
Jobs endpoint returns duplicated jobs
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20370";>FLINK-20370</a>] -
Result is wrong when sink primary key is not the same with query
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21289";>FLINK-21289</a>] -
Application mode ignores the pipeline.classpaths configuration
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21345";>FLINK-21345</a>] -
NullPointerException
LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22113";>FLINK-22113</a>] -
UniqueKey constraint is lost with multiple sources join in SQL
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-22954";>FLINK-22954</a>] -
Don't support consuming update and delete changes when use table
function that does not contain table field
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23614";>FLINK-23614</a>] -
The resulting scale of TRUNCATE(DECIMAL, ...) is not correct
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23704";>FLINK-23704</a>] -
FLIP-27 sources are not generating LatencyMarkers
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23827";>FLINK-23827</a>] -
Fix ModifiedMonotonicity inference for some node
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23919";>FLINK-23919</a>] -
PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for
Window TVF
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24156";>FLINK-24156</a>] -
BlobServer crashes due to SocketTimeoutException in Java 11
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24232";>FLINK-24232</a>] -
Archiving of suspended jobs prevents breaks subsequent archive attempts
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24291";>FLINK-24291</a>] -
Decimal precision is lost when deserializing in test cases
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24310";>FLINK-24310</a>] -
A bug in the BufferingSink example in the doc
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24315";>FLINK-24315</a>] -
Cannot rebuild watcher thread while the K8S API server is unavailable
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24318";>FLINK-24318</a>] -
Casting a number to boolean has different results between 'select'
fields and 'where' condition
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24331";>FLINK-24331</a>] -
PartiallyFinishedSourcesITCase fails with "No downstream received 0
from xxx;"
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24336";>FLINK-24336</a>] -
PyFlink TableEnvironment executes the SQL randomly MalformedURLException
with the configuration for 'pipeline.classpaths'
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24344";>FLINK-24344</a>] -
Handling of IOExceptions when triggering checkpoints doesn't cause job
failover
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24353";>FLINK-24353</a>] -
Bash scripts do not respect dynamic configurations when calculating memory
sizes
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24366";>FLINK-24366</a>] -
Unnecessary/misleading error message about failing restores when tasks are
already canceled.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24371";>FLINK-24371</a>] -
Support SinkWriter preCommit without the need of a committer
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24377";>FLINK-24377</a>] -
TM resource may not be properly released after heartbeat timeout
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24380";>FLINK-24380</a>] -
Flink should handle the state transition of the pod from Pending to Failed
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24381";>FLINK-24381</a>] -
Table API exceptions may leak sensitive configuration values
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24401";>FLINK-24401</a>] -
TM cannot exit after Metaspace OOM
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24407";>FLINK-24407</a>] -
Pulsar connector chinese document link to Pulsar document location
incorrectly.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24408";>FLINK-24408</a>] -
org.codehaus.janino.InternalCompilerException: Compiling
"StreamExecValues$200": Code of method
"nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class
"StreamExecValues$200" grows beyond 64 KB
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24409";>FLINK-24409</a>] -
Kafka topics with periods in their names generate a constant stream of
errors
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24431";>FLINK-24431</a>] -
[Kinesis][EFO] EAGER registration strategy does not work when job fails over
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24432";>FLINK-24432</a>] -
RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24465";>FLINK-24465</a>] -
Wrong javadoc and documentation for buffer timeout
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24467";>FLINK-24467</a>] -
Set min and max buffer size even if the difference less than threshold
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24468";>FLINK-24468</a>] -
NPE when notifyNewBufferSize
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24469";>FLINK-24469</a>] -
Incorrect calcualtion of the buffer size in case of channel data skew
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24480";>FLINK-24480</a>] -
EqualiserCodeGeneratorTest fails on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24488";>FLINK-24488</a>] -
KafkaRecordSerializationSchemaBuilder does not forward timestamp
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24492";>FLINK-24492</a>] -
incorrect implicit type conversion between numeric and (var)char
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24506";>FLINK-24506</a>] -
checkpoint directory is not configurable through the Flink configuration
passed into the StreamExecutionEnvironment
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24540";>FLINK-24540</a>] -
Fix Resource leak due to Files.list
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24543";>FLINK-24543</a>] -
Zookeeper connection issue causes inconsistent state in Flink
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24550";>FLINK-24550</a>] -
Can not access job information from a standby jobmanager UI
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24551";>FLINK-24551</a>] -
BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24552";>FLINK-24552</a>] -
Ineffective buffer debloat configuration in randomized tests
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24563";>FLINK-24563</a>] -
Comparing timstamp_ltz with random string throws NullPointerException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24596";>FLINK-24596</a>] -
Bugs in sink.buffer-flush before upsert-kafka
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24597";>FLINK-24597</a>] -
RocksdbStateBackend getKeysAndNamespaces would return duplicate data when
using MapState
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24600";>FLINK-24600</a>] -
Duplicate 99th percentile displayed in checkpoint summary
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24608";>FLINK-24608</a>] -
Sinks built with the unified sink framework do not receive timestamps when
used in Table API
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24613";>FLINK-24613</a>] -
Documentation on orc supported data types is outdated
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24647";>FLINK-24647</a>] -
ClusterUncaughtExceptionHandler does not log the exception
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24654";>FLINK-24654</a>] -
NPE on RetractableTopNFunction when some records were cleared by state ttl
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24662";>FLINK-24662</a>] -
PyFlink sphinx check failed with "node class 'meta' is already
registered, its visitors will be overridden"
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24667";>FLINK-24667</a>] -
Channel state writer would fail the task directly if meeting exception
previously
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24676";>FLINK-24676</a>] -
Schema does not match if explain insert statement with partial column
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24678";>FLINK-24678</a>] -
Correct the metric name of map state contains latency
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24691";>FLINK-24691</a>] -
FLINK SQL SUM() causes a precision error
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24704";>FLINK-24704</a>] -
Exception occurs when the input record loses monotonicity on the sort key
field of UpdatableTopNFunction
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24706";>FLINK-24706</a>] -
AkkaInvocationHandler silently ignores deserialization errors
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24708";>FLINK-24708</a>] -
`ConvertToNotInOrInRule` has a bug which leads to wrong result
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24728";>FLINK-24728</a>] -
Batch SQL file sink forgets to close the output stream
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24733";>FLINK-24733</a>] -
Data loss in pulsar source when using shared mode
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24738";>FLINK-24738</a>] -
Fail during announcing buffer size to released local channel
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24761";>FLINK-24761</a>] -
Fix PartitionPruner code gen compile fail
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24773";>FLINK-24773</a>] -
KafkaCommitter should fail on unknown Exception
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24777";>FLINK-24777</a>] -
Processed (persisted) in-flight data description miss on Monitoring
Checkpointing page
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24789";>FLINK-24789</a>] -
IllegalStateException with CheckpointCleaner being closed already
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24792";>FLINK-24792</a>] -
OperatorCoordinatorSchedulerTest crashed JVM on AZP
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24835";>FLINK-24835</a>] -
"group by" in the interval join will throw a exception
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24846";>FLINK-24846</a>] -
AsyncWaitOperator fails during stop-with-savepoint
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24858";>FLINK-24858</a>] -
TypeSerializer version mismatch during eagerly restore
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24874";>FLINK-24874</a>] -
Dropdown menu is not properly shown in UI
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24885";>FLINK-24885</a>] -
ProcessElement Interface parameter Collector :
java.lang.NullPointerException
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24919";>FLINK-24919</a>] -
UnalignedCheckpointITCase hangs on Azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24922";>FLINK-24922</a>] -
Fix spelling errors in the word "parallism"
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24937";>FLINK-24937</a>] -
"kubernetes application HA test" hangs on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24938";>FLINK-24938</a>] -
Checkpoint cleaner is closed before checkpoints are discarded
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25022";>FLINK-25022</a>] -
ClassLoader leak with ThreadLocals on the JM when submitting a job through
the REST API
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25067";>FLINK-25067</a>] -
Correct the description of RocksDB's background threads
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25084";>FLINK-25084</a>] -
Field names must be unique. Found duplicates
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25091";>FLINK-25091</a>] -
Official website document FileSink orc compression attribute reference error
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25096";>FLINK-25096</a>] -
Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25126";>FLINK-25126</a>] -
FlinkKafkaInternalProducer state is not reset if transaction finalization
fails
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25132";>FLINK-25132</a>] -
KafkaSource cannot work with object-reusing DeserializationSchema
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25134";>FLINK-25134</a>] -
Unused RetryRule in KafkaConsumerTestBase swallows retries
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25222";>FLINK-25222</a>] -
Remove NetworkFailureProxy used for Kafka connector tests
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25271";>FLINK-25271</a>] -
ApplicationDispatcherBootstrapITCase.
testDispatcherRecoversAfterLosingAndRegainingLeadership failed on azure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25294";>FLINK-25294</a>] -
Incorrect cloudpickle import
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25375";>FLINK-25375</a>] -
Update Log4j to 2.17.0
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25418";>FLINK-25418</a>] -
The dir_cache is specified in the flink task. When there is no network, you
will still download the python third-party library
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25446";>FLINK-25446</a>] -
Avoid sanity check on read bytes on DataInputStream#read(byte[])
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25468";>FLINK-25468</a>] -
Local recovery fails if local state storage and RocksDB working directory
are not on the same volume
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25477";>FLINK-25477</a>] -
The directory structure of the State Backends document is not standardized
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25513";>FLINK-25513</a>] -
CoFlatMapFunction requires both two flat_maps to yield something
+</li>
+</ul>
+
+<h2> Improvement
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-20443";>FLINK-20443</a>] -
ContinuousProcessingTimeTrigger doesn't fire at the end of the window
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-21467";>FLINK-21467</a>] -
Document possible recommended usage of Bounded{One/Multi}Input.endInput and
emphasize that they could be called multiple times
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23519";>FLINK-23519</a>] -
Aggregate State Backend Latency by State Level
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23798";>FLINK-23798</a>] -
Avoid using reflection to get filter when partition filter is enabled
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23842";>FLINK-23842</a>] -
Add log messages for reader registrations and split requests.
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-23914";>FLINK-23914</a>] -
Make connector testing framework more verbose on test failure
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24117";>FLINK-24117</a>] -
Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and
ZooKeeperLeaderRetrievalDriver
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24148";>FLINK-24148</a>] -
Add bloom filter policy option in RocksDBConfiguredOptions
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24382";>FLINK-24382</a>] -
RecordsOut metric for sinks is inaccurate
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24437";>FLINK-24437</a>] -
Remove unhandled exception handler from CuratorFramework before closing it
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24460";>FLINK-24460</a>] -
Rocksdb Iterator Error Handling Improvement
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24481";>FLINK-24481</a>] -
Translate buffer debloat documenation to chinese
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24529";>FLINK-24529</a>] -
flink sql job cannot use custom job name
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24631";>FLINK-24631</a>] -
Avoiding directly use the labels as selector for deployment and service
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24670";>FLINK-24670</a>] -
Restructure unaligned checkpoints documentation page to "Checkpointing
under back pressure"
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24690";>FLINK-24690</a>] -
Clarification of buffer size threshold calculation in BufferDebloater
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24695";>FLINK-24695</a>] -
Update how to configure unaligned checkpoints in the documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24739";>FLINK-24739</a>] -
State requirements for Flink's application mode in the documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24813";>FLINK-24813</a>] -
Improve ImplicitTypeConversionITCase
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24880";>FLINK-24880</a>] -
Error messages "OverflowError: timeout value is too large" shown
when executing PyFlink jobs
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24958";>FLINK-24958</a>] -
correct the example and link for temporal table function documentation
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24987";>FLINK-24987</a>] -
Enhance ExternalizedCheckpointCleanup enum
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25092";>FLINK-25092</a>] -
Implement artifact cacher for Bash based Elasticsearch test
+</li>
+</ul>
+
+<h2> Technical Debt
+</h2>
+<ul>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24367";>FLINK-24367</a>] -
Add a fallback AkkaRpcSystemLoader for tests in the IDE
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24445";>FLINK-24445</a>] -
Move RPC System packaging to package phase
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24455";>FLINK-24455</a>] -
FallbackAkkaRpcSystemLoader should check for maven errors
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24513";>FLINK-24513</a>] -
AkkaRpcSystemLoader must be an ITCase
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24559";>FLINK-24559</a>] -
flink-rpc-akka-loader does not bundle flink-rpc-akka
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24609";>FLINK-24609</a>] -
flink-rpc-akka uses wrong Scala version property for parser-combinators
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-24859";>FLINK-24859</a>] -
Document new File formats
+</li>
+<li>[<a
href="https://issues.apache.org/jira/browse/FLINK-25472";>FLINK-25472</a>] -
Update to Log4j 2.17.1
+</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 baa6315..68f61f0 100755
--- a/content/q/gradle-quickstart.sh
+++ b/content/q/gradle-quickstart.sh
@@ -41,7 +41,7 @@ function mkPackage() {
defaultProjectName="quickstart"
defaultOrganization="org.myorg.quickstart"
defaultVersion="0.1-SNAPSHOT"
-defaultFlinkVersion="${1:-1.14.2}"
+defaultFlinkVersion="${1:-1.14.3}"
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 e66bd81..bd618b1 100755
--- a/content/q/quickstart-scala.sh
+++ b/content/q/quickstart-scala.sh
@@ -24,7 +24,7 @@ PACKAGE=quickstart
mvn archetype:generate
\
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-scala \
- -DarchetypeVersion=${1:-1.14.2}
\
+ -DarchetypeVersion=${1:-1.14.3}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/content/q/quickstart.sh b/content/q/quickstart.sh
index 7121e2f..14e5379 100755
--- a/content/q/quickstart.sh
+++ b/content/q/quickstart.sh
@@ -24,7 +24,7 @@ PACKAGE=quickstart
mvn archetype:generate
\
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-java \
- -DarchetypeVersion=${1:-1.14.2}
\
+ -DarchetypeVersion=${1:-1.14.3}
\
-DgroupId=org.myorg.quickstart \
-DartifactId=$PACKAGE
\
-Dversion=0.1
\
diff --git a/content/q/sbt-quickstart.sh b/content/q/sbt-quickstart.sh
index 12751a5..1c5d849 100755
--- a/content/q/sbt-quickstart.sh
+++ b/content/q/sbt-quickstart.sh
@@ -42,7 +42,7 @@ defaultProjectName="Flink Project"
defaultOrganization="org.example"
defaultVersion="0.1-SNAPSHOT"
defaultScalaVersion="2.12.7"
-defaultFlinkVersion="1.14.2"
+defaultFlinkVersion="1.14.3"
echo "This script creates a Flink project using Scala and SBT."
diff --git a/content/zh/downloads.html b/content/zh/downloads.html
index 7afdac0..3ab646a 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-1142" id="markdown-toc-apache-flink-1142">Apache
Flink 1.14.2</a></li>
+ <li><a href="#apache-flink-1143" id="markdown-toc-apache-flink-1143">Apache
Flink 1.14.3</a></li>
<li><a href="#apache-flink-1135" id="markdown-toc-apache-flink-1135">Apache
Flink 1.13.5</a></li>
<li><a href="#apache-flink-1127" id="markdown-toc-apache-flink-1127">Apache
Flink 1.12.7</a></li>
<li><a href="#apache-flink-1116" id="markdown-toc-apache-flink-1116">Apache
Flink 1.11.6</a></li>
@@ -235,23 +235,23 @@ $( document ).ready(function() {
</div>
-<p>Apache Flink® 1.14.2 是我们最新的稳定版本。</p>
+<p>Apache Flink® 1.14.3 是我们最新的稳定版本。</p>
-<h2 id="apache-flink-1142">Apache Flink 1.14.2</h2>
+<h2 id="apache-flink-1143">Apache Flink 1.14.3</h2>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz";
class="ga-track" id="1142-download_211">Apache Flink 1.14.2 for Scala 2.11</a>
(<a href="
-
https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.11.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz";
class="ga-track" id="1142-download_211">Apache Flink 1.14.3 for Scala 2.11</a>
(<a href="
+
https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.11.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz";
class="ga-track" id="1142-download_212">Apache Flink 1.14.2 for Scala 2.12</a>
(<a href="
-
https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-bin-scala_2.12.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz";
class="ga-track" id="1142-download_212">Apache Flink 1.14.3 for Scala 2.12</a>
(<a href="
+
https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-bin-scala_2.12.tgz.sha512";>sha512</a>)
</p>
<p>
-<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.2/flink-1.14.2-src.tgz";
class="ga-track" id="1142-download-source">Apache Flink 1.14.2 Source
Release</a>
- (<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.2/flink-1.14.2-src.tgz.sha512";>sha512</a>)
+<a
href="https://www.apache.org/dyn/closer.lua/flink/flink-1.14.3/flink-1.14.3-src.tgz";
class="ga-track" id="1142-download-source">Apache Flink 1.14.3 Source
Release</a>
+ (<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.asc";>asc</a>,
<a
href="https://downloads.apache.org/flink/flink-1.14.3/flink-1.14.3-src.tgz.sha512";>sha512</a>)
</p>
<h4 id="section">发布说明</h4>
@@ -405,17 +405,17 @@
flink-docs-release-1.11/release-notes/flink-1.11.html">Flink 1.11 的发布说
<div class="highlight"><pre><code class="language-xml"><span
class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-java<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.2<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-streaming-java_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.2<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.flink<span
class="nt"></groupId></span>
<span class="nt"><artifactId></span>flink-clients_2.11<span
class="nt"></artifactId></span>
- <span class="nt"><version></span>1.14.2<span
class="nt"></version></span>
+ <span class="nt"><version></span>1.14.3<span
class="nt"></version></span>
<span class="nt"></dependency></span></code></pre></div>
<h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3>
@@ -480,6 +480,17 @@ The <code>statefun-flink-harness</code> dependency
includes a local execution en
<li>
+Flink 1.14.3 - 2022-01-17
+(<a
href="https://archive.apache.org/dist/flink/flink-1.14.3/flink-1.14.3-src.tgz";>Source</a>,
+<a href="https://archive.apache.org/dist/flink/flink-1.14.3";>Binaries</a>,
+<a href="https://nightlies.apache.org/flink/flink-docs-release-1.14";>Docs</a>,
+<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.14/api/java";>Javadocs</a>,
+<a
href="https://nightlies.apache.org/flink/flink-docs-release-1.14/api/scala/index.html";>Scaladocs</a>)
+
+</li>
+
+<li>
+
Flink 1.14.2 - 2021-12-16
(<a
href="https://archive.apache.org/dist/flink/flink-1.14.2/flink-1.14.2-src.tgz";>Source</a>,
<a href="https://archive.apache.org/dist/flink/flink-1.14.2";>Binaries</a>,
diff --git a/content/zh/index.html b/content/zh/index.html
index 33ec343..ad65b66 100644
--- a/content/zh/index.html
+++ b/content/zh/index.html
@@ -362,6 +362,9 @@
<dl>
+ <dt> <a href="/news/2022/01/17/release-1.14.3.html">Apache Flink
1.14.3 Release Announcement</a></dt>
+ <dd>The Apache Flink community released the second bugfix version of
the Apache Flink 1.14 series.</dd>
+
<dt> <a href="/news/2022/01/07/release-ml-2.0.0.html">Apache Flink ML
2.0.0 Release Announcement</a></dt>
<dd>The Apache Flink community is excited to announce the release of
Flink ML 2.0.0! This release involves a major refactor of the earlier Flink ML
library and introduces major features that extend the Flink ML API and the
iteration runtime, such as supporting stages with multi-input multi-output,
graph-based stage composition, and a new stream-batch unified iteration
library.</dd>
@@ -375,11 +378,6 @@
<dd><p>The Apache Flink community has released an emergency bugfix
version of Apache Flink Stateful Function 3.1.1.</p>
</dd>
-
- <dt> <a href="/news/2021/12/16/log4j-patch-releases.html">Apache Flink
Log4j emergency releases</a></dt>
- <dd><p>The Apache Flink community has released emergency bugfix
versions of Apache Flink for the 1.11, 1.12, 1.13 and 1.14 series.</p>
-
-</dd>
</dl>
