This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git
commit 29885ac237f36c99097346c97eaaf1ed88e33a90 Author: Xintong Song <[email protected]> AuthorDate: Fri Dec 18 19:05:41 2020 +0800 Regenerate website --- content/blog/feed.xml | 473 ++++++++++++++++----- content/blog/index.html | 40 +- content/blog/page10/index.html | 40 +- content/blog/page11/index.html | 40 +- content/blog/page12/index.html | 40 +- content/blog/page13/index.html | 40 +- content/blog/page14/index.html | 25 ++ content/blog/page2/index.html | 45 +- content/blog/page3/index.html | 43 +- content/blog/page4/index.html | 36 +- content/blog/page5/index.html | 36 +- content/blog/page6/index.html | 42 +- content/blog/page7/index.html | 46 ++- content/blog/page8/index.html | 42 +- content/blog/page9/index.html | 40 +- content/downloads.html | 25 +- content/index.html | 8 +- content/news/2020/12/18/release-1.11.3.html | 612 ++++++++++++++++++++++++++++ content/zh/downloads.html | 29 +- content/zh/index.html | 8 +- 20 files changed, 1384 insertions(+), 326 deletions(-) diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 6ae513e..a69e9b8 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -7,6 +7,375 @@ <atom:link href="https://flink.apache.org/blog/feed.xml"; rel="self" type="application/rss+xml" /> <item> +<title>Apache Flink 1.11.3 Released</title> +<description><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.11 series.</p> + +<p>This release includes 152 fixes and minor improvements for Flink 1.11.2. The list below includes a detailed list of all fixes and improvements.</p> + +<p>We highly recommend all users to upgrade to Flink 1.11.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.11.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.11.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.11.3<span class="nt">&lt;/version&gt;</span> +<span class="nt">&lt;/dependency&gt;</span></code></pre></div> + +<p>You can find the binaries on the updated <a href="/downloads.html">Downloads page</a>.</p> + +<p>List of resolved issues:</p> + +<h2> Sub-task +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17393">FLINK-17393</a>] - Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18604">FLINK-18604</a>] - HBase ConnectorDescriptor can not work in Table API +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18673">FLINK-18673</a>] - Calling ROW() in a UDF results in UnsupportedOperationException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18680">FLINK-18680</a>] - Improve RecordsWithSplitIds API +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18916">FLINK-18916</a>] - Add a &quot;Operations&quot; link(linked to dev/table/tableApi.md) under the &quot;Python API&quot; -&gt; &quot;User Guide&quot; -&gt; &quot;Table API&quot; section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18918">FLINK-18918</a>] - Add a &quot;Connectors&quot; document under the &quot;Python API&quot; -&gt; &quot;User Guide&quot; -&gt; &quot;Table API&quot; section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18922">FLINK-18922</a>] - Add a &quot;Catalogs&quot; link (linked to dev/table/catalogs.md) under the &quot;Python API&quot; -&gt; &quot;User Guide&quot; -&gt; &quot;Table API&quot; section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18926">FLINK-18926</a>] - Add a &quot;Environment Variables&quot; document under the &quot;Python API&quot; -&gt; &quot;User Guide&quot; -&gt; &quot;Table API&quot; section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19162">FLINK-19162</a>] - Allow Split Reader based sources to reuse record batches +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19205">FLINK-19205</a>] - SourceReaderContext should give access to Configuration and Hostbame +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20397">FLINK-20397</a>] - Pass checkpointId to OperatorCoordinator.resetToCheckpoint(). +</li> +</ul> + +<h2> Bug +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-9992">FLINK-9992</a>] - FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13733">FLINK-13733</a>] - FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15170">FLINK-15170</a>] - WebFrontendITCase.testCancelYarn fails on travis +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16246">FLINK-16246</a>] - Exclude &quot;SdkMBeanRegistrySupport&quot; from dynamically loaded AWS connectors +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16268">FLINK-16268</a>] - Failed to run rank over window with Hive built-in functions +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16768">FLINK-16768</a>] - HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17341">FLINK-17341</a>] - freeSlot in TaskExecutor.closeJobManagerConnection cause ConcurrentModificationException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17458">FLINK-17458</a>] - TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17677">FLINK-17677</a>] - FLINK_LOG_PREFIX recommended in docs is not always available +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17825">FLINK-17825</a>] - HA end-to-end gets killed due to timeout +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18128">FLINK-18128</a>] - CoordinatedSourceITCase.testMultipleSources gets stuck +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18196">FLINK-18196</a>] - flink throws `NullPointerException` when executeCheckpointing +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18222">FLINK-18222</a>] - &quot;Avro Confluent Schema Registry nightly end-to-end test&quot; unstable with &quot;Kafka cluster did not start after 120 seconds&quot; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18815">FLINK-18815</a>] - AbstractCloseableRegistryTest.testClose unstable +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18818">FLINK-18818</a>] - HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with &quot;java.io.IOException: The stream is closed&quot; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18836">FLINK-18836</a>] - Python UDTF doesn&#39;t work well when the return type isn&#39;t generator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18915">FLINK-18915</a>] - FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19022">FLINK-19022</a>] - AkkaRpcActor failed to start but no exception information +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19121">FLINK-19121</a>] - Avoid accessing HDFS frequently in HiveBulkWriterFactory +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19135">FLINK-19135</a>] - (Stream)ExecutionEnvironment.execute() should not throw ExecutionException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19138">FLINK-19138</a>] - Python UDF supports directly specifying input_types as DataTypes.ROW +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19140">FLINK-19140</a>] - Join with Table Function (UDTF) SQL example is incorrect +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19151">FLINK-19151</a>] - Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19154">FLINK-19154</a>] - Application mode deletes HA data in case of suspended ZooKeeper connection +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19170">FLINK-19170</a>] - Parameter naming error +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19201">FLINK-19201</a>] - PyFlink e2e tests is instable and failed with &quot;Connection broken: OSError&quot; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19227">FLINK-19227</a>] - The catalog is still created after opening failed in catalog registering +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19237">FLINK-19237</a>] - LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with &quot;NoResourceAvailableException: Could not allocate the required slot within slot request timeout&quot; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19244">FLINK-19244</a>] - CSV format can&#39;t deserialize null ROW field +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19250">FLINK-19250</a>] - SplitFetcherManager does not propagate errors correctly +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19253">FLINK-19253</a>] - SourceReaderTestBase.testAddSplitToExistingFetcher hangs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19258">FLINK-19258</a>] - Fix the wrong example of &quot;csv.line-delimiter&quot; in CSV documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19280">FLINK-19280</a>] - The option &quot;sink.buffer-flush.max-rows&quot; for JDBC can&#39;t be disabled by set to zero +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19281">FLINK-19281</a>] - LIKE cannot recognize full table path +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19291">FLINK-19291</a>] - Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19295">FLINK-19295</a>] - YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19300">FLINK-19300</a>] - Timer loss after restoring from savepoint +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19321">FLINK-19321</a>] - CollectSinkFunction does not define serialVersionUID +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19338">FLINK-19338</a>] - New source interface cannot unregister unregistered source +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19361">FLINK-19361</a>] - Make HiveCatalog thread safe +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19398">FLINK-19398</a>] - Hive connector fails with IllegalAccessError if submitted as usercode +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19401">FLINK-19401</a>] - Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19423">FLINK-19423</a>] - Fix ArrayIndexOutOfBoundsException when executing DELETE statement in JDBC upsert sink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19433">FLINK-19433</a>] - An Error example of FROM_UNIXTIME function in document +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19448">FLINK-19448</a>] - CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19535">FLINK-19535</a>] - SourceCoordinator should avoid fail job multiple times. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19557">FLINK-19557</a>] - Issue retrieving leader after zookeeper session reconnect +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19585">FLINK-19585</a>] - UnalignedCheckpointCompatibilityITCase.test:97-&gt;runAndTakeSavepoint: &quot;Not all required tasks are currently running.&quot; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19587">FLINK-19587</a>] - Error result when casting binary type as varchar +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19618">FLINK-19618</a>] - Broken link in docs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19629">FLINK-19629</a>] - Fix NullPointException when deserializing map field with null value for Avro format +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19675">FLINK-19675</a>] - The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19695">FLINK-19695</a>] - Writing Table with RowTime Column of type TIMESTAMP(3) to Kafka fails with ClassCastException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19717">FLINK-19717</a>] - SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19740">FLINK-19740</a>] - Error in to_pandas for table containing event time: class java.time.LocalDateTime cannot be cast to class java.sql.Timestamp +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19741">FLINK-19741</a>] - InternalTimeServiceManager fails to restore due to corrupt reads if there are other users of raw keyed state streams +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19748">FLINK-19748</a>] - KeyGroupRangeOffsets#KeyGroupOffsetsIterator should skip key groups that don&#39;t have a defined offset +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19750">FLINK-19750</a>] - Deserializer is not opened in Kafka consumer when restoring from state +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19755">FLINK-19755</a>] - Fix CEP documentation error of the example in &#39;After Match Strategy&#39; section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19775">FLINK-19775</a>] - SystemProcessingTimeServiceTest.testImmediateShutdown is instable +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19777">FLINK-19777</a>] - Fix NullPointException for WindowOperator.close() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19790">FLINK-19790</a>] - Writing MAP&lt;STRING, STRING&gt; to Kafka with JSON format produces incorrect data. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19806">FLINK-19806</a>] - Job may try to leave SUSPENDED state in ExecutionGraph#failJob() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19816">FLINK-19816</a>] - Flink restored from a wrong checkpoint (a very old one and not the last completed one) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19852">FLINK-19852</a>] - Managed memory released check can block IterativeTask +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19867">FLINK-19867</a>] - Validation fails for UDF that accepts var-args +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19894">FLINK-19894</a>] - Use iloc for positional slicing instead of direct slicing in from_pandas +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19901">FLINK-19901</a>] - Unable to exclude metrics variables for the last metrics reporter. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19906">FLINK-19906</a>] - Incorrect result when compare two binary fields +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19907">FLINK-19907</a>] - Channel state (upstream) can be restored after emission of new elements (watermarks) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19909">FLINK-19909</a>] - Flink application in attach mode could not terminate when the only job is canceled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19948">FLINK-19948</a>] - Calling NOW() function throws compile exception +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20013">FLINK-20013</a>] - BoundedBlockingSubpartition may leak network buffer if task is failed or canceled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20018">FLINK-20018</a>] - pipeline.cached-files option cannot escape &#39;:&#39; in path +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20033">FLINK-20033</a>] - Job fails when stopping JobMaster +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20050">FLINK-20050</a>] - SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20063">FLINK-20063</a>] - File Source requests an additional split on every restore. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20064">FLINK-20064</a>] - Broken links in the documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20065">FLINK-20065</a>] - UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20068">FLINK-20068</a>] - KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20069">FLINK-20069</a>] - docs_404_check doesn&#39;t work properly +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20076">FLINK-20076</a>] - DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles does not test the desired functionality +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20079">FLINK-20079</a>] - Modified UnalignedCheckpointITCase...MassivelyParallel fails +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20081">FLINK-20081</a>] - ExecutorNotifier should run handler in the main thread when receive an exception from the callable. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20143">FLINK-20143</a>] - use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20165">FLINK-20165</a>] - YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialized +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20175">FLINK-20175</a>] - Avro Confluent Registry SQL format does not support adding nullable columns +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20183">FLINK-20183</a>] - Fix the default PYTHONPATH is overwritten in client side +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20193">FLINK-20193</a>] - SourceCoordinator should catch exception thrown from SplitEnumerator.start() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20194">FLINK-20194</a>] - KafkaSourceFetcherManager.commitOffsets() should handle the case when there is no split fetcher. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20200">FLINK-20200</a>] - SQL Hints are not supported in &quot;Create View&quot; syntax +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20213">FLINK-20213</a>] - Partition commit is delayed when records keep coming +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20221">FLINK-20221</a>] - DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20222">FLINK-20222</a>] - The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20223">FLINK-20223</a>] - The RecreateOnResetOperatorCoordinator and SourceCoordinator executor thread should use the user class loader. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20243">FLINK-20243</a>] - Remove useless words in documents +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20262">FLINK-20262</a>] - Building flink-dist docker image does not work without python2 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20266">FLINK-20266</a>] - New Sources prevent JVM shutdown when running a job +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20270">FLINK-20270</a>] - Fix the regression of missing ExternallyInducedSource support in FLIP-27 Source. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20277">FLINK-20277</a>] - flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20284">FLINK-20284</a>] - Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20285">FLINK-20285</a>] - LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20333">FLINK-20333</a>] - Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20351">FLINK-20351</a>] - Execution.transitionState does not properly log slot location +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20382">FLINK-20382</a>] - Exception thrown from JobMaster.startScheduling() may be ignored. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20396">FLINK-20396</a>] - Add &quot;OperatorCoordinator.resetSubtask()&quot; to fix order problems of &quot;subtaskFailed()&quot; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20404">FLINK-20404</a>] - ZooKeeper quorum fails to start due to missing log4j library +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20413">FLINK-20413</a>] - Sources should add splits back in &quot;resetSubtask()&quot;, rather than in &quot;subtaskFailed()&quot;. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20418">FLINK-20418</a>] - NPE in IteratorSourceReader +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20442">FLINK-20442</a>] - Fix license documentation mistakes in flink-python.jar +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20492">FLINK-20492</a>] - The SourceOperatorStreamTask should implement cancelTask() and finishTask() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20554">FLINK-20554</a>] - The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI +</li> +</ul> + +<h2> New Feature +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19934">FLINK-19934</a>] - [FLIP-27 source] add new API: SplitEnumeratorContext.runInCoordinatorThread(Runnable) +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16753">FLINK-16753</a>] - Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18139">FLINK-18139</a>] - Unaligned checkpoints checks wrong channels for inflight data. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18500">FLINK-18500</a>] - Make the legacy planner exception more clear when resolving computed columns types for schema +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18545">FLINK-18545</a>] - Sql api cannot specify flink job name +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18715">FLINK-18715</a>] - add cpu usage metric of jobmanager/taskmanager +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19125">FLINK-19125</a>] - Avoid memory fragmentation when running flink docker image +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19193">FLINK-19193</a>] - Recommend stop-with-savepoint in upgrade guidelines +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19225">FLINK-19225</a>] - Improve code and logging in SourceReaderBase +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19245">FLINK-19245</a>] - Set default queue capacity for FLIP-27 source handover queue to 2 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19251">FLINK-19251</a>] - Avoid confusing queue handling in &quot;SplitReader.handleSplitsChanges()&quot; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19252">FLINK-19252</a>] - Jaas file created under io.tmp.dirs - folder not created if not exists +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19265">FLINK-19265</a>] - Simplify handling of &#39;NoMoreSplitsEvent&#39; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19339">FLINK-19339</a>] - Support Avro&#39;s unions with logical types +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19523">FLINK-19523</a>] - Hide sensitive command-line configurations +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19569">FLINK-19569</a>] - Upgrade ICU4J to 67.1+ +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19677">FLINK-19677</a>] - TaskManager takes abnormally long time to register with JobManager on Kubernetes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19698">FLINK-19698</a>] - Add close() method and onCheckpointComplete() to the Source. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19892">FLINK-19892</a>] - Replace __metaclass__ field with metaclass keyword +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20049">FLINK-20049</a>] - Simplify handling of &quot;request split&quot;. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20055">FLINK-20055</a>] - Datadog API Key exposed in Flink JobManager logs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20142">FLINK-20142</a>] - Update the document for CREATE TABLE LIKE that source table from different catalog is supported +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20152">FLINK-20152</a>] - Document which execution.target values are supported +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20156">FLINK-20156</a>] - JavaDocs of WatermarkStrategy.withTimestampAssigner are wrong wrt Java 8 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20169">FLINK-20169</a>] - Move emitting MAX_WATERMARK out of SourceOperator processing loop +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20207">FLINK-20207</a>] - Improve the error message printed when submitting the pyflink jobs via &#39;flink run&#39; +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20296">FLINK-20296</a>] - Explanation of keyBy was broken by find/replace of deprecated forms of keyBy +</li> +</ul> + +<h2> Test +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18725">FLINK-18725</a>] - &quot;Run Kubernetes test&quot; failed with &quot;30025: provided port is already allocated&quot; +</li> +</ul> + +<h2> Task +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20455">FLINK-20455</a>] - Add check to LicenseChecker for top level /LICENSE files in shaded jars +</li> +</ul> +</description> +<pubDate>Fri, 18 Dec 2020 01:00:00 +0100</pubDate> +<link>https://flink.apache.org/news/2020/12/18/release-1.11.3.html</link> +<guid isPermaLink="true">/news/2020/12/18/release-1.11.3.html</guid> +</item> + +<item> <title>Improvements in task scheduling for batch workloads in Apache Flink 1.12</title> <description><p>The Flink community has been working for some time on making Flink a <a href="https://flink.apache.org/news/2019/02/13/unified-batch-streaming-blink.html">truly unified batch and stream processing system</a>. @@ -18507,109 +18876,5 @@ enable the joining of a main, high-throughput stream with one more more inputs w <guid isPermaLink="true">/news/2016/12/19/2016-year-in-review.html</guid> </item> -<item> -<title>Apache Flink 1.1.3 Released</title> -<description><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.1. series.</p> - -<p>We recommend all users to upgrade to Flink 1.1.3.</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.1.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.10<span class="nt">&lt;/artifactId&gt;</span> - <span class="nt">&lt;version&gt;</span>1.1.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.10<span class="nt">&lt;/artifactId&gt;</span> - <span class="nt">&lt;version&gt;</span>1.1.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="http://flink.apache.org/downloads.html">Downloads page</a>.</p> - -<h2 id="note-for-rocksdb-backend-users">Note for RocksDB Backend Users</h2> - -<p>It is highly recommended to use the “fully async” mode for the RocksDB state backend. The “fully async” mode will most likely allow you to easily upgrade to Flink 1.2 (via <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/savepoints.html">savepoints</a>) when it is released. The “semi async” mode will no longer be supported by Flink 1.2.</p> - -<div class="highlight"><pre><code class="language-java"><span class="n">RocksDBStateBackend</span> <span class="n">backend</span> <span class="o">=</span> <span class="k">new</span> <span class="nf">RocksDBStateBackend</span><span class="o">(</span><span class="s">&quot;...&quot;</span><s [...] -<span class="n">backend</span><span class="o">.</span><span class="na">enableFullyAsyncSnapshots</span><span class="o">();</span></code></pre></div> - -<h2 id="release-notes---flink---version-113">Release Notes - Flink - Version 1.1.3</h2> - -<h2> Bug -</h2> -<ul> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-2662">FLINK-2662</a>] - CompilerException: &quot;Bug: Plan generation for Unions picked a ship strategy between binary plan operators.&quot; -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4311">FLINK-4311</a>] - TableInputFormat fails when reused on next split -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4329">FLINK-4329</a>] - Fix Streaming File Source Timestamps/Watermarks Handling -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4485">FLINK-4485</a>] - Finished jobs in yarn session fill /tmp filesystem -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4513">FLINK-4513</a>] - Kafka connector documentation refers to Flink 1.1-SNAPSHOT -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4514">FLINK-4514</a>] - ExpiredIteratorException in Kinesis Consumer on long catch-ups to head of stream -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4540">FLINK-4540</a>] - Detached job execution may prevent cluster shutdown -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4544">FLINK-4544</a>] - TaskManager metrics are vulnerable to custom JMX bean installation -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4566">FLINK-4566</a>] - ProducerFailedException does not properly preserve Exception causes -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4588">FLINK-4588</a>] - Fix Merging of Covering Window in MergingWindowSet -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4589">FLINK-4589</a>] - Fix Merging of Covering Window in MergingWindowSet -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4616">FLINK-4616</a>] - Kafka consumer doesn&#39;t store last emmited watermarks per partition in state -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4618">FLINK-4618</a>] - FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4619">FLINK-4619</a>] - JobManager does not answer to client when restore from savepoint fails -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4636">FLINK-4636</a>] - AbstractCEPPatternOperator fails to restore state -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4640">FLINK-4640</a>] - Serialization of the initialValue of a Fold on WindowedStream fails -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4651">FLINK-4651</a>] - Re-register processing time timers at the WindowOperator upon recovery. -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4663">FLINK-4663</a>] - Flink JDBCOutputFormat logs wrong WARN message -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4672">FLINK-4672</a>] - TaskManager accidentally decorates Kill messages -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4677">FLINK-4677</a>] - Jars with no job executions produces NullPointerException in ClusterClient -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4702">FLINK-4702</a>] - Kafka consumer must commit offsets asynchronously -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4727">FLINK-4727</a>] - Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4732">FLINK-4732</a>] - Maven junction plugin security threat -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4777">FLINK-4777</a>] - ContinuousFileMonitoringFunction may throw IOException when files are moved -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4788">FLINK-4788</a>] - State backend class cannot be loaded, because fully qualified name converted to lower-case -</li> -</ul> - -<h2> Improvement -</h2> -<ul> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4396">FLINK-4396</a>] - GraphiteReporter class not found at startup of jobmanager -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4574">FLINK-4574</a>] - Strengthen fetch interval implementation in Kinesis consumer -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-4723">FLINK-4723</a>] - Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer -</li> -</ul> -</description> -<pubDate>Wed, 12 Oct 2016 11:00:00 +0200</pubDate> -<link>https://flink.apache.org/news/2016/10/12/release-1.1.3.html</link> -<guid isPermaLink="true">/news/2016/10/12/release-1.1.3.html</guid> -</item> - </channel> </rss> diff --git a/content/blog/index.html b/content/blog/index.html index 1e969ee..af006a7 100644 --- a/content/blog/index.html +++ b/content/blog/index.html @@ -196,6 +196,21 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></h2> + + <p>18 Dec 2020 + Xintong Song (<a href="https://twitter.com/xtsong";>@xtsong</a>)</p> + + <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.11 series.</p> + +</p> + + <p><a href="/news/2020/12/18/release-1.11.3.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></h2> <p>15 Dec 2020 @@ -322,21 +337,6 @@ as well as increased observability for operational purposes.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2020/08/25/release-1.10.2.html">Apache Flink 1.10.2 Released</a></h2> - - <p>25 Aug 2020 - Zhu Zhu (<a href="https://twitter.com/zhuzhv";>@zhuzhv</a>)</p> - - <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.10 series.</p> - -</p> - - <p><a href="/news/2020/08/25/release-1.10.2.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -369,6 +369,16 @@ as well as increased observability for operational purposes.</p> <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page10/index.html b/content/blog/page10/index.html index 32c9468..15fa96e 100644 --- a/content/blog/page10/index.html +++ b/content/blog/page10/index.html @@ -196,6 +196,21 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2017/06/23/release-1.3.1.html">Apache Flink 1.3.1 Released</a></h2> + + <p>23 Jun 2017 + </p> + + <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.3 series.</p> + +</p> + + <p><a href="/news/2017/06/23/release-1.3.1.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2017/06/01/release-1.3.0.html">Apache Flink 1.3.0 Release Announcement</a></h2> <p>01 Jun 2017 by Robert Metzger (<a href="https://twitter.com/";>@rmetzger_</a>) @@ -323,21 +338,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2016/10/12/release-1.1.3.html">Apache Flink 1.1.3 Released</a></h2> - - <p>12 Oct 2016 - </p> - - <p><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.1. series.</p> - -</p> - - <p><a href="/news/2016/10/12/release-1.1.3.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -370,6 +370,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page11/index.html b/content/blog/page11/index.html index 7aaa3c2..5b788b2 100644 --- a/content/blog/page11/index.html +++ b/content/blog/page11/index.html @@ -196,6 +196,21 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2016/10/12/release-1.1.3.html">Apache Flink 1.1.3 Released</a></h2> + + <p>12 Oct 2016 + </p> + + <p><p>The Apache Flink community released the next bugfix version of the Apache Flink 1.1. series.</p> + +</p> + + <p><a href="/news/2016/10/12/release-1.1.3.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2016/09/05/release-1.1.2.html">Apache Flink 1.1.2 Released</a></h2> <p>05 Sep 2016 @@ -327,21 +342,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2016/04/06/release-1.0.1.html">Flink 1.0.1 Released</a></h2> - - <p>06 Apr 2016 - </p> - - <p><p>Today, the Flink community released Flink version <strong>1.0.1</strong>, the first bugfix release of the 1.0 series.</p> - -</p> - - <p><a href="/news/2016/04/06/release-1.0.1.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -374,6 +374,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page12/index.html b/content/blog/page12/index.html index 1c69a74..ca9e8c6 100644 --- a/content/blog/page12/index.html +++ b/content/blog/page12/index.html @@ -196,6 +196,21 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2016/04/06/release-1.0.1.html">Flink 1.0.1 Released</a></h2> + + <p>06 Apr 2016 + </p> + + <p><p>Today, the Flink community released Flink version <strong>1.0.1</strong>, the first bugfix release of the 1.0 series.</p> + +</p> + + <p><a href="/news/2016/04/06/release-1.0.1.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2016/03/08/release-1.0.0.html">Announcing Apache Flink 1.0.0</a></h2> <p>08 Mar 2016 @@ -328,21 +343,6 @@ Apache Flink started.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2015/09/01/release-0.9.1.html">Apache Flink 0.9.1 available</a></h2> - - <p>01 Sep 2015 - </p> - - <p><p>The Flink community is happy to announce that Flink 0.9.1 is now available.</p> - -</p> - - <p><a href="/news/2015/09/01/release-0.9.1.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -375,6 +375,16 @@ Apache Flink started.</p> <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page13/index.html b/content/blog/page13/index.html index ddd2df2..cabec0f 100644 --- a/content/blog/page13/index.html +++ b/content/blog/page13/index.html @@ -196,6 +196,21 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2015/09/01/release-0.9.1.html">Apache Flink 0.9.1 available</a></h2> + + <p>01 Sep 2015 + </p> + + <p><p>The Flink community is happy to announce that Flink 0.9.1 is now available.</p> + +</p> + + <p><a href="/news/2015/09/01/release-0.9.1.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2015/08/24/introducing-flink-gelly.html">Introducing Gelly: Graph Processing with Apache Flink</a></h2> <p>24 Aug 2015 @@ -340,21 +355,6 @@ and offers a new API including definition of flexible windows.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2015/02/04/january-in-flink.html">January 2015 in the Flink community</a></h2> - - <p>04 Feb 2015 - </p> - - <p><p>Happy 2015! Here is a (hopefully digestible) summary of what happened last month in the Flink community.</p> - -</p> - - <p><a href="/news/2015/02/04/january-in-flink.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -387,6 +387,16 @@ and offers a new API including definition of flexible windows.</p> <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page14/index.html b/content/blog/page14/index.html index fb5ff49..dcb7033 100644 --- a/content/blog/page14/index.html +++ b/content/blog/page14/index.html @@ -196,6 +196,21 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2015/02/04/january-in-flink.html">January 2015 in the Flink community</a></h2> + + <p>04 Feb 2015 + </p> + + <p><p>Happy 2015! Here is a (hopefully digestible) summary of what happened last month in the Flink community.</p> + +</p> + + <p><a href="/news/2015/02/04/january-in-flink.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2015/01/21/release-0.8.html">Apache Flink 0.8.0 available</a></h2> <p>21 Jan 2015 @@ -335,6 +350,16 @@ academic and open source project that Flink originates from.</p> <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html index b0e466a..84e03eb 100644 --- a/content/blog/page2/index.html +++ b/content/blog/page2/index.html @@ -196,6 +196,21 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2020/08/25/release-1.10.2.html">Apache Flink 1.10.2 Released</a></h2> + + <p>25 Aug 2020 + Zhu Zhu (<a href="https://twitter.com/zhuzhv";>@zhuzhv</a>)</p> + + <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.10 series.</p> + +</p> + + <p><a href="/news/2020/08/25/release-1.10.2.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2020/08/20/flink-docker.html">The State of Flink on Docker</a></h2> <p>20 Aug 2020 @@ -318,26 +333,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2020/07/14/application-mode.html">Application Deployment in Flink: Current State and the new Application Mode</a></h2> - - <p>14 Jul 2020 - Kostas Kloudas (<a href="https://twitter.com/kkloudas";>@kkloudas</a>)</p> - - <p><p>With the rise of stream processing and real-time analytics as a critical tool for modern -businesses, an increasing number of organizations build platforms with Apache Flink at their -core and offer it internally as a service. Many talks with related topics from companies -like <a href="https://www.youtube.com/watch?v=VX3S9POGAdU";>Uber</a>, <a href="https://www.youtube.com/watch?v=VX3S9POGAdU";>Netflix</a> -and <a href="https://www.youtube.com/watch?v=cH9UdK0yYjc";>Alibaba</a> in the latest editions of Flink Forward further -illustrate this trend.</p> - -</p> - - <p><a href="/news/2020/07/14/application-mode.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -370,6 +365,16 @@ illustrate this trend.</p> <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html index 4fdca48..e6fc1e8 100644 --- a/content/blog/page3/index.html +++ b/content/blog/page3/index.html @@ -196,6 +196,26 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2020/07/14/application-mode.html">Application Deployment in Flink: Current State and the new Application Mode</a></h2> + + <p>14 Jul 2020 + Kostas Kloudas (<a href="https://twitter.com/kkloudas";>@kkloudas</a>)</p> + + <p><p>With the rise of stream processing and real-time analytics as a critical tool for modern +businesses, an increasing number of organizations build platforms with Apache Flink at their +core and offer it internally as a service. Many talks with related topics from companies +like <a href="https://www.youtube.com/watch?v=VX3S9POGAdU";>Uber</a>, <a href="https://www.youtube.com/watch?v=VX3S9POGAdU";>Netflix</a> +and <a href="https://www.youtube.com/watch?v=cH9UdK0yYjc";>Alibaba</a> in the latest editions of Flink Forward further +illustrate this trend.</p> + +</p> + + <p><a href="/news/2020/07/14/application-mode.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2020/07/06/release-1.11.0.html">Apache Flink 1.11.0 Release Announcement</a></h2> <p>06 Jul 2020 @@ -325,19 +345,6 @@ and provide a tutorial for running Streaming ETL with Flink on Zeppelin.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2020/04/21/memory-management-improvements-flink-1.10.html">Memory Management Improvements with Apache Flink 1.10</a></h2> - - <p>21 Apr 2020 - Andrey Zagrebin </p> - - <p>This post discusses the recent changes to the memory model of the Task Managers and configuration options for your Flink applications in Flink 1.10.</p> - - <p><a href="/news/2020/04/21/memory-management-improvements-flink-1.10.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -370,6 +377,16 @@ and provide a tutorial for running Streaming ETL with Flink on Zeppelin.</p> <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html index 2cff05b..6847f49 100644 --- a/content/blog/page4/index.html +++ b/content/blog/page4/index.html @@ -196,6 +196,19 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2020/04/21/memory-management-improvements-flink-1.10.html">Memory Management Improvements with Apache Flink 1.10</a></h2> + + <p>21 Apr 2020 + Andrey Zagrebin </p> + + <p>This post discusses the recent changes to the memory model of the Task Managers and configuration options for your Flink applications in Flink 1.10.</p> + + <p><a href="/news/2020/04/21/memory-management-improvements-flink-1.10.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2020/04/15/flink-serialization-tuning-vol-1.html">Flink Serialization Tuning Vol. 1: Choosing your Serializer — if you can</a></h2> <p>15 Apr 2020 @@ -319,19 +332,6 @@ This release marks a big milestone: Stateful Functions 2.0 is not only an API up <hr> - <article> - <h2 class="blog-title"><a href="/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html">A Guide for Unit Testing in Apache Flink</a></h2> - - <p>07 Feb 2020 - Kartik Khare (<a href="https://twitter.com/khare_khote";>@khare_khote</a>)</p> - - <p>This post provides a detailed guide for unit testing of Apache Flink applications.</p> - - <p><a href="/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -364,6 +364,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/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html index f613d55..fca6bbf 100644 --- a/content/blog/page5/index.html +++ b/content/blog/page5/index.html @@ -196,6 +196,19 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html">A Guide for Unit Testing in Apache Flink</a></h2> + + <p>07 Feb 2020 + Kartik Khare (<a href="https://twitter.com/khare_khote";>@khare_khote</a>)</p> + + <p>This post provides a detailed guide for unit testing of Apache Flink applications.</p> + + <p><a href="/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2020/01/30/release-1.9.2.html">Apache Flink 1.9.2 Released</a></h2> <p>30 Jan 2020 @@ -320,19 +333,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2019/09/10/community-update.html">Flink Community Update - September'19</a></h2> - - <p>10 Sep 2019 - Marta Paes (<a href="https://twitter.com/morsapaes";>@morsapaes</a>)</p> - - <p>This has been an exciting, fast-paced year for the Apache Flink community. But with over 10k messages across the mailing lists, 3k Jira tickets and 2k pull requests, it is not easy to keep up with the latest state of the project. Plus everything happening around it. With that in mind, we want to bring back regular community updates to the Flink blog.</p> - - <p><a href="/news/2019/09/10/community-update.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -365,6 +365,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page6/index.html b/content/blog/page6/index.html index 23ddcef..16ae2c9 100644 --- a/content/blog/page6/index.html +++ b/content/blog/page6/index.html @@ -196,6 +196,19 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2019/09/10/community-update.html">Flink Community Update - September'19</a></h2> + + <p>10 Sep 2019 + Marta Paes (<a href="https://twitter.com/morsapaes";>@morsapaes</a>)</p> + + <p>This has been an exciting, fast-paced year for the Apache Flink community. But with over 10k messages across the mailing lists, 3k Jira tickets and 2k pull requests, it is not easy to keep up with the latest state of the project. Plus everything happening around it. With that in mind, we want to bring back regular community updates to the Flink blog.</p> + + <p><a href="/news/2019/09/10/community-update.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2019/08/22/release-1.9.0.html">Apache Flink 1.9.0 Release Announcement</a></h2> <p>22 Aug 2019 @@ -319,25 +332,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></h2> - - <p>09 Apr 2019 - Aljoscha Krettek (<a href="https://twitter.com/aljoscha";>@aljoscha</a>)</p> - - <p><p>The Apache Flink community is pleased to announce Apache Flink 1.8.0. The -latest release includes more than 420 resolved issues and some exciting -additions to Flink that we describe in the following sections of this post. -Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274";>complete changelog</a> -for more details.</p> - -</p> - - <p><a href="/news/2019/04/09/release-1.8.0.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -370,6 +364,16 @@ for more details.</p> <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page7/index.html b/content/blog/page7/index.html index 49b17dc..83796c8 100644 --- a/content/blog/page7/index.html +++ b/content/blog/page7/index.html @@ -196,6 +196,25 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2019/04/09/release-1.8.0.html">Apache Flink 1.8.0 Release Announcement</a></h2> + + <p>09 Apr 2019 + Aljoscha Krettek (<a href="https://twitter.com/aljoscha";>@aljoscha</a>)</p> + + <p><p>The Apache Flink community is pleased to announce Apache Flink 1.8.0. The +latest release includes more than 420 resolved issues and some exciting +additions to Flink that we describe in the following sections of this post. +Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12344274";>complete changelog</a> +for more details.</p> + +</p> + + <p><a href="/news/2019/04/09/release-1.8.0.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/features/2019/03/11/prometheus-monitoring.html">Flink and Prometheus: Cloud-native monitoring of streaming applications</a></h2> <p>11 Mar 2019 @@ -322,23 +341,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2018/11/30/release-1.7.0.html">Apache Flink 1.7.0 Release Announcement</a></h2> - - <p>30 Nov 2018 - Till Rohrmann (<a href="https://twitter.com/stsffap";>@stsffap</a>)</p> - - <p><p>The Apache Flink community is pleased to announce Apache Flink 1.7.0. -The latest release includes more than 420 resolved issues and some exciting additions to Flink that we describe in the following sections of this post. -Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12343585";>complete changelog</a> for more details.</p> - -</p> - - <p><a href="/news/2018/11/30/release-1.7.0.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -371,6 +373,16 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page8/index.html b/content/blog/page8/index.html index 1acd8ac..064c724 100644 --- a/content/blog/page8/index.html +++ b/content/blog/page8/index.html @@ -196,6 +196,23 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2018/11/30/release-1.7.0.html">Apache Flink 1.7.0 Release Announcement</a></h2> + + <p>30 Nov 2018 + Till Rohrmann (<a href="https://twitter.com/stsffap";>@stsffap</a>)</p> + + <p><p>The Apache Flink community is pleased to announce Apache Flink 1.7.0. +The latest release includes more than 420 resolved issues and some exciting additions to Flink that we describe in the following sections of this post. +Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12343585";>complete changelog</a> for more details.</p> + +</p> + + <p><a href="/news/2018/11/30/release-1.7.0.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2018/10/29/release-1.6.2.html">Apache Flink 1.6.2 Released</a></h2> <p>29 Oct 2018 @@ -330,21 +347,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2018/03/15/release-1.3.3.html">Apache Flink 1.3.3 Released</a></h2> - - <p>15 Mar 2018 - </p> - - <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.3 series.</p> - -</p> - - <p><a href="/news/2018/03/15/release-1.3.3.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -377,6 +379,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/blog/page9/index.html b/content/blog/page9/index.html index f394315..08515c1 100644 --- a/content/blog/page9/index.html +++ b/content/blog/page9/index.html @@ -196,6 +196,21 @@ <!-- Blog posts --> <article> + <h2 class="blog-title"><a href="/news/2018/03/15/release-1.3.3.html">Apache Flink 1.3.3 Released</a></h2> + + <p>15 Mar 2018 + </p> + + <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.3 series.</p> + +</p> + + <p><a href="/news/2018/03/15/release-1.3.3.html">Continue reading »</a></p> + </article> + + <hr> + + <article> <h2 class="blog-title"><a href="/news/2018/03/08/release-1.4.2.html">Apache Flink 1.4.2 Released</a></h2> <p>08 Mar 2018 @@ -327,21 +342,6 @@ what’s coming in Flink 1.4.0 as well as a preview of what the Flink community <hr> - <article> - <h2 class="blog-title"><a href="/news/2017/06/23/release-1.3.1.html">Apache Flink 1.3.1 Released</a></h2> - - <p>23 Jun 2017 - </p> - - <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.3 series.</p> - -</p> - - <p><a href="/news/2017/06/23/release-1.3.1.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -374,6 +374,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/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></li> + + + + + + + + + <li><a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></li> diff --git a/content/downloads.html b/content/downloads.html index 4711ad2..52f8196 100644 --- a/content/downloads.html +++ b/content/downloads.html @@ -208,7 +208,7 @@ $( document ).ready(function() { <div class="page-toc"> <ul id="markdown-toc"> <li><a href="#apache-flink-1120" id="markdown-toc-apache-flink-1120">Apache Flink 1.12.0</a></li> - <li><a href="#apache-flink-1112" id="markdown-toc-apache-flink-1112">Apache Flink 1.11.2</a></li> + <li><a href="#apache-flink-1113" id="markdown-toc-apache-flink-1113">Apache Flink 1.11.3</a></li> <li><a href="#apache-flink-stateful-functions-221" id="markdown-toc-apache-flink-stateful-functions-221">Apache Flink Stateful Functions 2.2.1</a></li> <li><a href="#additional-components" id="markdown-toc-additional-components">Additional Components</a></li> <li><a href="#verifying-hashes-and-signatures" id="markdown-toc-verifying-hashes-and-signatures">Verifying Hashes and Signatures</a></li> @@ -261,25 +261,25 @@ file system connector), please check out the <a href="https://ci.apache.org/proj <hr /> -<h2 id="apache-flink-1112">Apache Flink 1.11.2</h2> +<h2 id="apache-flink-1113">Apache Flink 1.11.3</h2> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.11.tgz"; class="ga-track" id="1112-download_211">Apache Flink 1.11.2 for Scala 2.11</a> (<a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.11.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.11.tgz.sha512";>sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.11.tgz"; class="ga-track" id="1113-download_211">Apache Flink 1.11.3 for Scala 2.11</a> (<a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.11.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.11.tgz.sha512";>sha512</a>) </p> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.12.tgz"; class="ga-track" id="1112-download_212">Apache Flink 1.11.2 for Scala 2.12</a> (<a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.12.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.12.tgz.sha512";>sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.12.tgz"; class="ga-track" id="1113-download_212">Apache Flink 1.11.3 for Scala 2.12</a> (<a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.12.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.12.tgz.sha512";>sha512</a>) </p> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.2/flink-1.11.2-src.tgz"; class="ga-track" id="1112-download-source">Apache Flink 1.11.2 Source Release</a> -(<a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-src.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-src.tgz.sha512";>sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.3/flink-1.11.3-src.tgz"; class="ga-track" id="1113-download-source">Apache Flink 1.11.3 Source Release</a> +(<a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-src.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-src.tgz.sha512";>sha512</a>) </p> <h4 id="optional-components-1">Optional components</h4> <p> -<a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.2/flink-avro-1.11.2.jar"; class="ga-track" id="1112-sql-format-avro">Avro SQL Format</a> (<a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.2/flink-avro-1.11.2.jar.asc";>asc</a>, <a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.2/flink-avro-1.11.2.jar.sha1";>sha1</a>) +<a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.3/flink-avro-1.11.3.jar"; class="ga-track" id="1113-sql-format-avro">Avro SQL Format</a> (<a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.3/flink-avro-1.11.3.jar.asc";>asc</a>, <a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.3/flink-avro-1.11.3.jar.sha1";>sha1</a>) </p> <h4 id="release-notes-1">Release Notes</h4> @@ -406,6 +406,17 @@ Flink 1.12.0 - 2020-12-08 <li> +Flink 1.11.3 - 2020-12-18 +(<a href="https://archive.apache.org/dist/flink/flink-1.11.3/flink-1.11.3-src.tgz";>Source</a>, +<a href="https://archive.apache.org/dist/flink/flink-1.11.3";>Binaries</a>, +<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11";>Docs</a>, +<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11/api/java";>Javadocs</a>, +<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11/api/scala/index.html";>Scaladocs</a>) + +</li> + +<li> + Flink 1.11.2 - 2020-09-17 (<a href="https://archive.apache.org/dist/flink/flink-1.11.2/flink-1.11.2-src.tgz";>Source</a>, <a href="https://archive.apache.org/dist/flink/flink-1.11.2";>Binaries</a>, diff --git a/content/index.html b/content/index.html index 4be46cf..765251a 100644 --- a/content/index.html +++ b/content/index.html @@ -568,6 +568,11 @@ <dl> + <dt> <a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></dt> + <dd><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.11 series.</p> + +</dd> + <dt> <a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></dt> <dd>In this blogpost, we’ll take a closer look at how far the community has come in improving task scheduling for batch workloads, why this matters and what you can expect in Flink 1.12 with the new pipelined region scheduler.</dd> @@ -581,9 +586,6 @@ <dt> <a href="/2020/10/15/from-aligned-to-unaligned-checkpoints-part-1.html">From Aligned to Unaligned Checkpoints - Part 1: Checkpoints, Alignment, and Backpressure</a></dt> <dd>Apache Flink’s checkpoint-based fault tolerance mechanism is one of its defining features. Because of that design, Flink unifies batch and stream processing, can easily scale to both very small and extremely large scenarios and provides support for many operational features. In this post we recap the original checkpointing process in Flink, its core properties and issues under backpressure.</dd> - - <dt> <a href="/news/2020/10/13/stateful-serverless-internals.html">Stateful Functions Internals: Behind the scenes of Stateful Serverless</a></dt> - <dd>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.</dd> </dl> diff --git a/content/news/2020/12/18/release-1.11.3.html b/content/news/2020/12/18/release-1.11.3.html new file mode 100644 index 0000000..202302e --- /dev/null +++ b/content/news/2020/12/18/release-1.11.3.html @@ -0,0 +1,612 @@ +<!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.11.3 Released</title> + <link rel="shortcut icon" href="/favicon.ico" type="image/x-icon"> + <link rel="icon" href="/favicon.ico" type="image/x-icon"> + + <!-- Bootstrap --> + <link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.4.1/css/bootstrap.min.css";> + <link rel="stylesheet" href="/css/flink.css"> + <link rel="stylesheet" href="/css/syntax.css"> + + <!-- Blog RSS feed --> + <link href="/blog/feed.xml" rel="alternate" type="application/rss+xml" title="Apache Flink Blog: RSS feed" /> + + <!-- jQuery (necessary for Bootstrap's JavaScript plugins) --> + <!-- We need to load Jquery in the header for custom google analytics event tracking--> + <script src="/js/jquery.min.js"></script> + + <!-- HTML5 shim and Respond.js for IE8 support of HTML5 elements and media queries --> + <!-- WARNING: Respond.js doesn't work if you view the page via file:// --> + <!--[if lt IE 9]> + <script src="https://oss.maxcdn.com/html5shiv/3.7.2/html5shiv.min.js";></script> + <script src="https://oss.maxcdn.com/respond/1.4.2/respond.min.js";></script> + <![endif]--> + </head> + <body> + + + <!-- Main content. --> + <div class="container"> + <div class="row"> + + + <div id="sidebar" class="col-sm-3"> + + +<!-- Top navbar. --> + <nav class="navbar navbar-default"> + <!-- The logo. --> + <div class="navbar-header"> + <button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#bs-example-navbar-collapse-1"> + <span class="icon-bar"></span> + <span class="icon-bar"></span> + <span class="icon-bar"></span> + </button> + <div class="navbar-logo"> + <a href="/"> + <img alt="Apache Flink" src="/img/flink-header-logo.svg" width="147px" height="73px"> + </a> + </div> + </div><!-- /.navbar-header --> + + <!-- The navigation links. --> + <div class="collapse navbar-collapse" id="bs-example-navbar-collapse-1"> + <ul class="nav navbar-nav navbar-main"> + + <!-- First menu section explains visitors what Flink is --> + + <!-- What is Stream Processing? --> + <!-- + <li><a href="/streamprocessing1.html">What is Stream Processing?</a></li> + --> + + <!-- What is Flink? --> + <li><a href="/flink-architecture.html">What is Apache Flink?</a></li> + + + + <!-- What is Stateful Functions? --> + + <li><a href="/stateful-functions.html">What is Stateful Functions?</a></li> + + <!-- Use cases --> + <li><a href="/usecases.html">Use Cases</a></li> + + <!-- Powered by --> + <li><a href="/poweredby.html">Powered By</a></li> + + + + <!-- Second menu section aims to support Flink users --> + + <!-- Downloads --> + <li><a href="/downloads.html">Downloads</a></li> + + <!-- Getting Started --> + <li class="dropdown"> + <a class="dropdown-toggle" data-toggle="dropdown" href="#">Getting Started<span class="caret"></span></a> + <ul class="dropdown-menu"> + <li><a href="https://ci.apache.org/projects/flink/flink-docs-release-1.12/try-flink/index.html"; target="_blank">With Flink <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + <li><a href="https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/getting-started/project-setup.html"; target="_blank">With Flink Stateful Functions <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + <li><a href="/training.html">Training Course</a></li> + </ul> + </li> + + <!-- Documentation --> + <li class="dropdown"> + <a class="dropdown-toggle" data-toggle="dropdown" href="#">Documentation<span class="caret"></span></a> + <ul class="dropdown-menu"> + <li><a href="https://ci.apache.org/projects/flink/flink-docs-release-1.12"; target="_blank">Flink 1.12 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + <li><a href="https://ci.apache.org/projects/flink/flink-docs-master"; target="_blank">Flink Master (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + <li><a href="https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2"; target="_blank">Flink Stateful Functions 2.2 (Latest stable release) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + <li><a href="https://ci.apache.org/projects/flink/flink-statefun-docs-master"; target="_blank">Flink Stateful Functions Master (Latest Snapshot) <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + </ul> + </li> + + <!-- getting help --> + <li><a href="/gettinghelp.html">Getting Help</a></li> + + <!-- Blog --> + <li class="active"><a href="/blog/"><b>Flink Blog</b></a></li> + + + <!-- Flink-packages --> + <li> + <a href="https://flink-packages.org"; target="_blank">flink-packages.org <small><span class="glyphicon glyphicon-new-window"></span></small></a> + </li> + + + <!-- Third menu section aim to support community and contributors --> + + <!-- Community --> + <li><a href="/community.html">Community & Project Info</a></li> + + <!-- Roadmap --> + <li><a href="/roadmap.html">Roadmap</a></li> + + <!-- Contribute --> + <li><a href="/contributing/how-to-contribute.html">How to Contribute</a></li> + + + <!-- GitHub --> + <li> + <a href="https://github.com/apache/flink"; target="_blank">Flink on GitHub <small><span class="glyphicon glyphicon-new-window"></span></small></a> + </li> + + + + <!-- Language Switcher --> + <li> + + + <!-- link to the Chinese home page when current is blog page --> + <a href="/zh">中文版</a> + + + </li> + + </ul> + + <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> + + <hr /> + + <li><a href="https://apache.org"; target="_blank">Apache Software Foundation <small><span class="glyphicon glyphicon-new-window"></span></small></a></li> + + <li> + <style> + .smalllinks:link { + display: inline-block !important; background: none; padding-top: 0px; padding-bottom: 0px; padding-right: 0px; min-width: 75px; + } + </style> + + <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.11.3 Released</h1> + <p><i></i></p> + + <article> + <p>18 Dec 2020 Xintong Song (<a href="https://twitter.com/xtsong";>@xtsong</a>)</p> + +<p>The Apache Flink community released the third bugfix version of the Apache Flink 1.11 series.</p> + +<p>This release includes 152 fixes and minor improvements for Flink 1.11.2. The list below includes a detailed list of all fixes and improvements.</p> + +<p>We highly recommend all users to upgrade to Flink 1.11.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.11.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.11.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.11.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> + +<p>List of resolved issues:</p> + +<h2> Sub-task +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17393";>FLINK-17393</a>] - Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18604";>FLINK-18604</a>] - HBase ConnectorDescriptor can not work in Table API +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18673";>FLINK-18673</a>] - Calling ROW() in a UDF results in UnsupportedOperationException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18680";>FLINK-18680</a>] - Improve RecordsWithSplitIds API +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18916";>FLINK-18916</a>] - Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" -> "Table API" section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18918";>FLINK-18918</a>] - Add a "Connectors" document under the "Python API" -> "User Guide" -> "Table API" section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18922";>FLINK-18922</a>] - Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" -> "Table API" section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18926";>FLINK-18926</a>] - Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19162";>FLINK-19162</a>] - Allow Split Reader based sources to reuse record batches +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19205";>FLINK-19205</a>] - SourceReaderContext should give access to Configuration and Hostbame +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20397";>FLINK-20397</a>] - Pass checkpointId to OperatorCoordinator.resetToCheckpoint(). +</li> +</ul> + +<h2> Bug +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-9992";>FLINK-9992</a>] - FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13733";>FLINK-13733</a>] - FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-15170";>FLINK-15170</a>] - WebFrontendITCase.testCancelYarn fails on travis +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16246";>FLINK-16246</a>] - Exclude "SdkMBeanRegistrySupport" from dynamically loaded AWS connectors +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16268";>FLINK-16268</a>] - Failed to run rank over window with Hive built-in functions +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16768";>FLINK-16768</a>] - HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17341";>FLINK-17341</a>] - freeSlot in TaskExecutor.closeJobManagerConnection cause ConcurrentModificationException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17458";>FLINK-17458</a>] - TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17677";>FLINK-17677</a>] - FLINK_LOG_PREFIX recommended in docs is not always available +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-17825";>FLINK-17825</a>] - HA end-to-end gets killed due to timeout +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18128";>FLINK-18128</a>] - CoordinatedSourceITCase.testMultipleSources gets stuck +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18196";>FLINK-18196</a>] - flink throws `NullPointerException` when executeCheckpointing +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18222";>FLINK-18222</a>] - "Avro Confluent Schema Registry nightly end-to-end test" unstable with "Kafka cluster did not start after 120 seconds" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18815";>FLINK-18815</a>] - AbstractCloseableRegistryTest.testClose unstable +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18818";>FLINK-18818</a>] - HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18836";>FLINK-18836</a>] - Python UDTF doesn't work well when the return type isn't generator +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18915";>FLINK-18915</a>] - FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19022";>FLINK-19022</a>] - AkkaRpcActor failed to start but no exception information +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19121";>FLINK-19121</a>] - Avoid accessing HDFS frequently in HiveBulkWriterFactory +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19135";>FLINK-19135</a>] - (Stream)ExecutionEnvironment.execute() should not throw ExecutionException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19138";>FLINK-19138</a>] - Python UDF supports directly specifying input_types as DataTypes.ROW +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19140";>FLINK-19140</a>] - Join with Table Function (UDTF) SQL example is incorrect +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19151";>FLINK-19151</a>] - Flink does not normalize container resource with correct configurations when Yarn FairScheduler is used +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19154";>FLINK-19154</a>] - Application mode deletes HA data in case of suspended ZooKeeper connection +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19170";>FLINK-19170</a>] - Parameter naming error +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19201";>FLINK-19201</a>] - PyFlink e2e tests is instable and failed with "Connection broken: OSError" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19227";>FLINK-19227</a>] - The catalog is still created after opening failed in catalog registering +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19237";>FLINK-19237</a>] - LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed with "NoResourceAvailableException: Could not allocate the required slot within slot request timeout" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19244";>FLINK-19244</a>] - CSV format can't deserialize null ROW field +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19250";>FLINK-19250</a>] - SplitFetcherManager does not propagate errors correctly +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19253";>FLINK-19253</a>] - SourceReaderTestBase.testAddSplitToExistingFetcher hangs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19258";>FLINK-19258</a>] - Fix the wrong example of "csv.line-delimiter" in CSV documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19280";>FLINK-19280</a>] - The option "sink.buffer-flush.max-rows" for JDBC can't be disabled by set to zero +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19281";>FLINK-19281</a>] - LIKE cannot recognize full table path +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19291";>FLINK-19291</a>] - Fix exception for AvroSchemaConverter#convertToSchema when RowType contains multiple row fields +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19295";>FLINK-19295</a>] - YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19300";>FLINK-19300</a>] - Timer loss after restoring from savepoint +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19321";>FLINK-19321</a>] - CollectSinkFunction does not define serialVersionUID +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19338";>FLINK-19338</a>] - New source interface cannot unregister unregistered source +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19361";>FLINK-19361</a>] - Make HiveCatalog thread safe +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19398";>FLINK-19398</a>] - Hive connector fails with IllegalAccessError if submitted as usercode +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19401";>FLINK-19401</a>] - Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19423";>FLINK-19423</a>] - Fix ArrayIndexOutOfBoundsException when executing DELETE statement in JDBC upsert sink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19433";>FLINK-19433</a>] - An Error example of FROM_UNIXTIME function in document +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19448";>FLINK-19448</a>] - CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19535";>FLINK-19535</a>] - SourceCoordinator should avoid fail job multiple times. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19557";>FLINK-19557</a>] - Issue retrieving leader after zookeeper session reconnect +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19585";>FLINK-19585</a>] - UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running." +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19587";>FLINK-19587</a>] - Error result when casting binary type as varchar +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19618";>FLINK-19618</a>] - Broken link in docs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19629";>FLINK-19629</a>] - Fix NullPointException when deserializing map field with null value for Avro format +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19675";>FLINK-19675</a>] - The plan of is incorrect when Calc contains WHERE clause, composite fields access and Python UDF at the same time +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19695";>FLINK-19695</a>] - Writing Table with RowTime Column of type TIMESTAMP(3) to Kafka fails with ClassCastException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19717";>FLINK-19717</a>] - SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19740";>FLINK-19740</a>] - Error in to_pandas for table containing event time: class java.time.LocalDateTime cannot be cast to class java.sql.Timestamp +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19741";>FLINK-19741</a>] - InternalTimeServiceManager fails to restore due to corrupt reads if there are other users of raw keyed state streams +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19748";>FLINK-19748</a>] - KeyGroupRangeOffsets#KeyGroupOffsetsIterator should skip key groups that don't have a defined offset +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19750";>FLINK-19750</a>] - Deserializer is not opened in Kafka consumer when restoring from state +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19755";>FLINK-19755</a>] - Fix CEP documentation error of the example in 'After Match Strategy' section +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19775";>FLINK-19775</a>] - SystemProcessingTimeServiceTest.testImmediateShutdown is instable +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19777";>FLINK-19777</a>] - Fix NullPointException for WindowOperator.close() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19790";>FLINK-19790</a>] - Writing MAP<STRING, STRING> to Kafka with JSON format produces incorrect data. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19806";>FLINK-19806</a>] - Job may try to leave SUSPENDED state in ExecutionGraph#failJob() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19816";>FLINK-19816</a>] - Flink restored from a wrong checkpoint (a very old one and not the last completed one) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19852";>FLINK-19852</a>] - Managed memory released check can block IterativeTask +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19867";>FLINK-19867</a>] - Validation fails for UDF that accepts var-args +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19894";>FLINK-19894</a>] - Use iloc for positional slicing instead of direct slicing in from_pandas +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19901";>FLINK-19901</a>] - Unable to exclude metrics variables for the last metrics reporter. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19906";>FLINK-19906</a>] - Incorrect result when compare two binary fields +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19907";>FLINK-19907</a>] - Channel state (upstream) can be restored after emission of new elements (watermarks) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19909";>FLINK-19909</a>] - Flink application in attach mode could not terminate when the only job is canceled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19948";>FLINK-19948</a>] - Calling NOW() function throws compile exception +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20013";>FLINK-20013</a>] - BoundedBlockingSubpartition may leak network buffer if task is failed or canceled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20018";>FLINK-20018</a>] - pipeline.cached-files option cannot escape ':' in path +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20033";>FLINK-20033</a>] - Job fails when stopping JobMaster +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20050";>FLINK-20050</a>] - SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20063";>FLINK-20063</a>] - File Source requests an additional split on every restore. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20064";>FLINK-20064</a>] - Broken links in the documentation +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20065";>FLINK-20065</a>] - UnalignedCheckpointCompatibilityITCase.test failed with AskTimeoutException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20068";>FLINK-20068</a>] - KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20069";>FLINK-20069</a>] - docs_404_check doesn't work properly +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20076";>FLINK-20076</a>] - DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles does not test the desired functionality +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20079";>FLINK-20079</a>] - Modified UnalignedCheckpointITCase...MassivelyParallel fails +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20081";>FLINK-20081</a>] - ExecutorNotifier should run handler in the main thread when receive an exception from the callable. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20143";>FLINK-20143</a>] - use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20165";>FLINK-20165</a>] - YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialized +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20175";>FLINK-20175</a>] - Avro Confluent Registry SQL format does not support adding nullable columns +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20183";>FLINK-20183</a>] - Fix the default PYTHONPATH is overwritten in client side +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20193";>FLINK-20193</a>] - SourceCoordinator should catch exception thrown from SplitEnumerator.start() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20194";>FLINK-20194</a>] - KafkaSourceFetcherManager.commitOffsets() should handle the case when there is no split fetcher. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20200";>FLINK-20200</a>] - SQL Hints are not supported in "Create View" syntax +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20213";>FLINK-20213</a>] - Partition commit is delayed when records keep coming +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20221";>FLINK-20221</a>] - DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20222";>FLINK-20222</a>] - The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20223";>FLINK-20223</a>] - The RecreateOnResetOperatorCoordinator and SourceCoordinator executor thread should use the user class loader. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20243";>FLINK-20243</a>] - Remove useless words in documents +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20262";>FLINK-20262</a>] - Building flink-dist docker image does not work without python2 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20266";>FLINK-20266</a>] - New Sources prevent JVM shutdown when running a job +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20270";>FLINK-20270</a>] - Fix the regression of missing ExternallyInducedSource support in FLIP-27 Source. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20277";>FLINK-20277</a>] - flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20284";>FLINK-20284</a>] - Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20285";>FLINK-20285</a>] - LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20333";>FLINK-20333</a>] - Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20351";>FLINK-20351</a>] - Execution.transitionState does not properly log slot location +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20382";>FLINK-20382</a>] - Exception thrown from JobMaster.startScheduling() may be ignored. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20396";>FLINK-20396</a>] - Add "OperatorCoordinator.resetSubtask()" to fix order problems of "subtaskFailed()" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20404";>FLINK-20404</a>] - ZooKeeper quorum fails to start due to missing log4j library +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20413";>FLINK-20413</a>] - Sources should add splits back in "resetSubtask()", rather than in "subtaskFailed()". +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20418";>FLINK-20418</a>] - NPE in IteratorSourceReader +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20442";>FLINK-20442</a>] - Fix license documentation mistakes in flink-python.jar +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20492";>FLINK-20492</a>] - The SourceOperatorStreamTask should implement cancelTask() and finishTask() +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20554";>FLINK-20554</a>] - The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI +</li> +</ul> + +<h2> New Feature +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19934";>FLINK-19934</a>] - [FLIP-27 source] add new API: SplitEnumeratorContext.runInCoordinatorThread(Runnable) +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-16753";>FLINK-16753</a>] - Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18139";>FLINK-18139</a>] - Unaligned checkpoints checks wrong channels for inflight data. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18500";>FLINK-18500</a>] - Make the legacy planner exception more clear when resolving computed columns types for schema +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18545";>FLINK-18545</a>] - Sql api cannot specify flink job name +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18715";>FLINK-18715</a>] - add cpu usage metric of jobmanager/taskmanager +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19125";>FLINK-19125</a>] - Avoid memory fragmentation when running flink docker image +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19193";>FLINK-19193</a>] - Recommend stop-with-savepoint in upgrade guidelines +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19225";>FLINK-19225</a>] - Improve code and logging in SourceReaderBase +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19245";>FLINK-19245</a>] - Set default queue capacity for FLIP-27 source handover queue to 2 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19251";>FLINK-19251</a>] - Avoid confusing queue handling in "SplitReader.handleSplitsChanges()" +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19252";>FLINK-19252</a>] - Jaas file created under io.tmp.dirs - folder not created if not exists +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19265";>FLINK-19265</a>] - Simplify handling of 'NoMoreSplitsEvent' +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19339";>FLINK-19339</a>] - Support Avro's unions with logical types +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19523";>FLINK-19523</a>] - Hide sensitive command-line configurations +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19569";>FLINK-19569</a>] - Upgrade ICU4J to 67.1+ +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19677";>FLINK-19677</a>] - TaskManager takes abnormally long time to register with JobManager on Kubernetes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19698";>FLINK-19698</a>] - Add close() method and onCheckpointComplete() to the Source. +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-19892";>FLINK-19892</a>] - Replace __metaclass__ field with metaclass keyword +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20049";>FLINK-20049</a>] - Simplify handling of "request split". +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20055";>FLINK-20055</a>] - Datadog API Key exposed in Flink JobManager logs +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20142";>FLINK-20142</a>] - Update the document for CREATE TABLE LIKE that source table from different catalog is supported +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20152";>FLINK-20152</a>] - Document which execution.target values are supported +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20156";>FLINK-20156</a>] - JavaDocs of WatermarkStrategy.withTimestampAssigner are wrong wrt Java 8 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20169";>FLINK-20169</a>] - Move emitting MAX_WATERMARK out of SourceOperator processing loop +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20207";>FLINK-20207</a>] - Improve the error message printed when submitting the pyflink jobs via 'flink run' +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20296";>FLINK-20296</a>] - Explanation of keyBy was broken by find/replace of deprecated forms of keyBy +</li> +</ul> + +<h2> Test +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-18725";>FLINK-18725</a>] - "Run Kubernetes test" failed with "30025: provided port is already allocated" +</li> +</ul> + +<h2> Task +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-20455";>FLINK-20455</a>] - Add check to LicenseChecker for top level /LICENSE files in shaded jars +</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-2019 <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="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.4/js/bootstrap.min.js";></script> + <script src="https://cdnjs.cloudflare.com/ajax/libs/jquery.matchHeight/0.7.0/jquery.matchHeight-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/zh/downloads.html b/content/zh/downloads.html index 9767638..9ff13dd 100644 --- a/content/zh/downloads.html +++ b/content/zh/downloads.html @@ -206,7 +206,7 @@ $( document ).ready(function() { <div class="page-toc"> <ul id="markdown-toc"> <li><a href="#apache-flink-1120" id="markdown-toc-apache-flink-1120">Apache Flink 1.12.0</a></li> - <li><a href="#apache-flink-1112" id="markdown-toc-apache-flink-1112">Apache Flink 1.11.2</a></li> + <li><a href="#apache-flink-1113" id="markdown-toc-apache-flink-1113">Apache Flink 1.11.3</a></li> <li><a href="#section-4" id="markdown-toc-section-4">额外组件</a></li> <li><a href="#section-5" id="markdown-toc-section-5">验证哈希和签名</a></li> <li><a href="#maven-" id="markdown-toc-maven-">Maven 依赖</a></li> @@ -253,27 +253,27 @@ Hadoop 文件系统的 connector ），请查看 <a href="https://ci.apache.org/ <p>如果你计划从以前的版本升级 Flink，请查看 <a href="https://ci.apache.org/projects/flink/ flink-docs-release-1.12/release-notes/flink-1.12.html">Flink 1.12 的发布说明</a>。</p> -<h2 id="apache-flink-1112">Apache Flink 1.11.2</h2> +<h2 id="apache-flink-1113">Apache Flink 1.11.3</h2> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.11.tgz"; class="ga-track" id="1112-download_211">Apache Flink 1.11.2 for Scala 2.11</a> (<a href=" - https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.11.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.11.tgz.sha512";>sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.11.tgz"; class="ga-track" id="1113-download_211">Apache Flink 1.11.3 for Scala 2.11</a> (<a href=" + https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.11.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.11.tgz.sha512";>sha512</a>) </p> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.12.tgz"; class="ga-track" id="1112-download_212">Apache Flink 1.11.2 for Scala 2.12</a> (<a href=" - https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.12.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.12.tgz.sha512";>sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.12.tgz"; class="ga-track" id="1113-download_212">Apache Flink 1.11.3 for Scala 2.12</a> (<a href=" + https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.12.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-bin-scala_2.12.tgz.sha512";>sha512</a>) </p> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.2/flink-1.11.2-src.tgz"; class="ga-track" id="1112-download-source">Apache Flink 1.11.2 Source Release</a> - (<a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-src.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.2/flink-1.11.2-src.tgz.sha512";>sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.11.3/flink-1.11.3-src.tgz"; class="ga-track" id="1113-download-source">Apache Flink 1.11.3 Source Release</a> + (<a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-src.tgz.asc";>asc</a>, <a href="https://downloads.apache.org/flink/flink-1.11.3/flink-1.11.3-src.tgz.sha512";>sha512</a>) </p> <h4 id="section-2">可选组件</h4> <p> -<a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.2/flink-avro-1.11.2.jar"; class="ga-track" id="1112-sql-format-avro">Avro SQL Format</a> (<a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.2/flink-avro-1.11.2.jar.asc";>asc</a>, <a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.2/flink-avro-1.11.2.jar.sha1";>sha1</a>) +<a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.3/flink-avro-1.11.3.jar"; class="ga-track" id="1113-sql-format-avro">Avro SQL Format</a> (<a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.3/flink-avro-1.11.3.jar.asc";>asc</a>, <a href="https://repo.maven.apache.org/maven2/org/apache/flink/flink-avro/1.11.3/flink-avro-1.11.3.jar.sha1";>sha1</a>) </p> <h4 id="section-3">发布说明</h4> @@ -363,6 +363,17 @@ Flink 1.12.0 - 2020-12-08 <li> +Flink 1.11.3 - 2020-12-18 +(<a href="https://archive.apache.org/dist/flink/flink-1.11.3/flink-1.11.3-src.tgz";>Source</a>, +<a href="https://archive.apache.org/dist/flink/flink-1.11.3";>Binaries</a>, +<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11";>Docs</a>, +<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11/api/java";>Javadocs</a>, +<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11/api/scala/index.html";>Scaladocs</a>) + +</li> + +<li> + Flink 1.11.2 - 2020-09-17 (<a href="https://archive.apache.org/dist/flink/flink-1.11.2/flink-1.11.2-src.tgz";>Source</a>, <a href="https://archive.apache.org/dist/flink/flink-1.11.2";>Binaries</a>, diff --git a/content/zh/index.html b/content/zh/index.html index 8b6329e..3414f11 100644 --- a/content/zh/index.html +++ b/content/zh/index.html @@ -565,6 +565,11 @@ <dl> + <dt> <a href="/news/2020/12/18/release-1.11.3.html">Apache Flink 1.11.3 Released</a></dt> + <dd><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.11 series.</p> + +</dd> + <dt> <a href="/2020/12/15/pipelined-region-sheduling.html">Improvements in task scheduling for batch workloads in Apache Flink 1.12</a></dt> <dd>In this blogpost, we’ll take a closer look at how far the community has come in improving task scheduling for batch workloads, why this matters and what you can expect in Flink 1.12 with the new pipelined region scheduler.</dd> @@ -578,9 +583,6 @@ <dt> <a href="/2020/10/15/from-aligned-to-unaligned-checkpoints-part-1.html">From Aligned to Unaligned Checkpoints - Part 1: Checkpoints, Alignment, and Backpressure</a></dt> <dd>Apache Flink’s checkpoint-based fault tolerance mechanism is one of its defining features. Because of that design, Flink unifies batch and stream processing, can easily scale to both very small and extremely large scenarios and provides support for many operational features. In this post we recap the original checkpointing process in Flink, its core properties and issues under backpressure.</dd> - - <dt> <a href="/news/2020/10/13/stateful-serverless-internals.html">Stateful Functions Internals: Behind the scenes of Stateful Serverless</a></dt> - <dd>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.</dd> </dl>
