This is an automated email from the ASF dual-hosted git repository. danderson pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git
The following commit(s) were added to refs/heads/asf-site by this push: new dd81767ff rebuild website dd81767ff is described below commit dd81767ff4d7b7272d3fd35ae4db08db8ea986aa Author: David Anderson <da...@alpinegizmo.com> AuthorDate: Thu Jul 7 18:01:21 2022 -0400 rebuild website --- content/blog/feed.xml | 412 +++++++++--------- content/blog/index.html | 38 +- content/blog/page10/index.html | 40 +- content/blog/page11/index.html | 40 +- content/blog/page12/index.html | 40 +- content/blog/page13/index.html | 42 +- content/blog/page14/index.html | 45 +- content/blog/page15/index.html | 43 +- content/blog/page16/index.html | 40 +- content/blog/page17/index.html | 42 +- content/blog/page18/index.html | 40 +- content/blog/page19/index.html | 45 +- content/blog/page2/index.html | 38 +- content/blog/{page13 => page20}/index.html | 164 +------- content/blog/page3/index.html | 40 +- content/blog/page4/index.html | 40 +- content/blog/page5/index.html | 38 +- content/blog/page6/index.html | 40 +- content/blog/page7/index.html | 40 +- content/blog/page8/index.html | 38 +- content/blog/page9/index.html | 38 +- content/downloads.html | 29 +- content/index.html | 6 +- .../2022/07/06/release-1.15.1.html} | 458 +++++++++------------ content/q/gradle-quickstart.sh | 2 +- content/q/quickstart-scala.sh | 2 +- content/q/quickstart.sh | 2 +- content/q/sbt-quickstart.sh | 2 +- content/zh/downloads.html | 31 +- content/zh/index.html | 6 +- 30 files changed, 940 insertions(+), 941 deletions(-) diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 475d3abcb..2e1395481 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xml @@ -6,6 +6,193 @@ <link>https://flink.apache.org/blog</link> <atom:link href="https://flink.apache.org/blog/feed.xml" rel="self" type="application/rss+xml" /> +<item> +<title>Apache Flink 1.15.1 Release Announcement</title> +<description><p>The Apache Flink Community is pleased to announce the first bug fix release of the Flink 1.15 series.</p> + +<p>This release includes 62 bug fixes, vulnerability fixes, and minor improvements for Flink 1.15. +Below you will find a list of all bugfixes and improvements (excluding improvements to the build infrastructure and build stability). For a complete list of all changes see: +<a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&amp;version=12351546">JIRA</a>.</p> + +<p>We highly recommend all users upgrade to Flink 1.15.1.</p> + +<h1 id="release-artifacts">Release Artifacts</h1> + +<h2 id="maven-dependencies">Maven Dependencies</h2> + +<div class="highlight"><pre><code class="language-xml"><span class="nt">&lt;dependency&gt;</span> + <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span> + <span class="nt">&lt;artifactId&gt;</span>flink-java<span class="nt">&lt;/artifactId&gt;</span> + <span class="nt">&lt;version&gt;</span>1.15.1<span class="nt">&lt;/version&gt;</span> +<span class="nt">&lt;/dependency&gt;</span> +<span class="nt">&lt;dependency&gt;</span> + <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span> + <span class="nt">&lt;artifactId&gt;</span>flink-streaming-java<span class="nt">&lt;/artifactId&gt;</span> + <span class="nt">&lt;version&gt;</span>1.15.1<span class="nt">&lt;/version&gt;</span> +<span class="nt">&lt;/dependency&gt;</span> +<span class="nt">&lt;dependency&gt;</span> + <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span> + <span class="nt">&lt;artifactId&gt;</span>flink-clients<span class="nt">&lt;/artifactId&gt;</span> + <span class="nt">&lt;version&gt;</span>1.15.1<span class="nt">&lt;/version&gt;</span> +<span class="nt">&lt;/dependency&gt;</span></code></pre></div> + +<h2 id="binaries">Binaries</h2> + +<p>You can find the binaries on the updated <a href="/downloads.html">Downloads page</a>.</p> + +<h2 id="docker-images">Docker Images</h2> + +<ul> + <li><a href="https://hub.docker.com/_/flink?tab=tags&amp;page=1&amp;name=1.15.1">library/flink</a> (official images)</li> + <li><a href="https://hub.docker.com/r/apache/flink/tags?page=1&amp;name=1.15.1">apache/flink</a> (ASF repository)</li> +</ul> + +<h2 id="pypi">PyPi</h2> + +<ul> + <li><a href="https://pypi.org/project/apache-flink/1.15.1/">apache-flink==1.15.1</a></li> +</ul> + +<h1 id="release-notes">Release Notes</h1> + +<p>The community is aware of two issues that were introduced with 1.15.0 that remain unresolved. Efforts are underway to fix these issues for Flink 1.15.2:</p> + +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28060">FLINK-28060</a>] - Kafka commit on checkpointing fails repeatedly after a broker restart +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28322">FLINK-28322</a>] - DataStreamScanProvider's new method is not compatible +</li> +</ul> + +<h2> Bug +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22984">FLINK-22984</a>] - UnsupportedOperationException when using Python UDF to generate watermark +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-24491">FLINK-24491</a>] - ExecutionGraphInfo may not be archived when the dispatcher terminates +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-24735">FLINK-24735</a>] - SQL client crashes with `Cannot add expression of different type to set` +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26645">FLINK-26645</a>] - Pulsar Source subscribe to a single topic partition will consume all partitions from that topic +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27041">FLINK-27041</a>] - KafkaSource in batch mode failing if any topic partition is empty +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27140">FLINK-27140</a>] - Move JobResultStore dirty entry creation into ioExecutor +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27174">FLINK-27174</a>] - Non-null check for bootstrapServers field is incorrect in KafkaSink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27218">FLINK-27218</a>] - Serializer in OperatorState has not been updated when new Serializers are NOT incompatible +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27223">FLINK-27223</a>] - State access doesn&#39;t work as expected when cache size is set to 0 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27247">FLINK-27247</a>] - ScalarOperatorGens.numericCasting is not compatible with legacy behavior +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27255">FLINK-27255</a>] - Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27282">FLINK-27282</a>] - Fix the bug of wrong positions mapping in RowCoder +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27367">FLINK-27367</a>] - SQL CAST between INT and DATE is broken +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27368">FLINK-27368</a>] - SQL CAST(&#39; 1 &#39; as BIGINT) returns wrong result +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27409">FLINK-27409</a>] - Cleanup stale slot allocation record when the resource requirement of a job is empty +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27418">FLINK-27418</a>] - Flink SQL TopN result is wrong +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27420">FLINK-27420</a>] - Suspended SlotManager fails to re-register metrics when started again +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27465">FLINK-27465</a>] - AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27487">FLINK-27487</a>] - KafkaMetricWrappers do incorrect cast +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27545">FLINK-27545</a>] - Update examples in PyFlink shell +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27563">FLINK-27563</a>] - Resource Providers - Yarn doc page has minor display error +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27606">FLINK-27606</a>] - CompileException when using UDAF with merge() method +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27676">FLINK-27676</a>] - Output records from on_timer are behind the triggering watermark in PyFlink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27683">FLINK-27683</a>] - Insert into (column1, column2) Values(.....) fails with SQL hints +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27711">FLINK-27711</a>] - Correct the typo of set_topics_pattern by changing it to set_topic_pattern for Pulsar Connector +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27733">FLINK-27733</a>] - Rework on_timer output behind watermark bug fix +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27734">FLINK-27734</a>] - Not showing checkpoint interval properly in WebUI when checkpoint is disabled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27760">FLINK-27760</a>] - NPE is thrown when executing PyFlink jobs in batch mode +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27762">FLINK-27762</a>] - Kafka WakeupException during handling splits changes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27797">FLINK-27797</a>] - PythonTableUtils.getCollectionInputFormat cannot correctly handle None values +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27848">FLINK-27848</a>] - ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27881">FLINK-27881</a>] - The key(String) in PulsarMessageBuilder returns null +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27890">FLINK-27890</a>] - SideOutputExample.java fails +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27910">FLINK-27910</a>] - FileSink not enforcing rolling policy if started from scratch +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27933">FLINK-27933</a>] - Savepoint status cannot be queried from standby jobmanager +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27955">FLINK-27955</a>] - PyFlink installation failure on Windows OS +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27999">FLINK-27999</a>] - NoSuchMethodError when using Hive 3 dialect +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28018">FLINK-28018</a>] - the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28019">FLINK-28019</a>] - Error in RetractableTopNFunction when retracting a stale record with state ttl enabled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28114">FLINK-28114</a>] - The path of the Python client interpreter could not point to an archive file in distributed file system +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-24586">FLINK-24586</a>] - SQL functions should return STRING instead of VARCHAR(2000) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26788">FLINK-26788</a>] - AbstractDeserializationSchema should add cause when throwing a FlinkRuntimeException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26909">FLINK-26909</a>] - Allow setting parallelism to -1 from CLI +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27064">FLINK-27064</a>] - Centralize ArchUnit rules for production code +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27480">FLINK-27480</a>] - KafkaSources sharing the groupId might lead to InstanceAlreadyExistException warning +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27534">FLINK-27534</a>] - Apply scalafmt to 1.15 branch +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27776">FLINK-27776</a>] - Throw exception when UDAF used in sliding window does not implement merge method in PyFlink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27935">FLINK-27935</a>] - Add Pyflink example of create temporary view document +</li> +</ul> + +<h2> Technical Debt +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-25694">FLINK-25694</a>] - Upgrade Presto to resolve GSON/Alluxio Vulnerability +</li> +</ul> + +<h2> Sub-task +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26052">FLINK-26052</a>] - Update chinese documentation regarding FLIP-203 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26588">FLINK-26588</a>] - Translate the new SQL CAST documentation to Chinese +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27382">FLINK-27382</a>] - Make Job mode wait with cluster shutdown until the cleanup is done +</li> +</ul> +</description> +<pubDate>Wed, 06 Jul 2022 10:00:00 +0200</pubDate> +<link>https://flink.apache.org/news/2022/07/06/release-1.15.1.html</link> +<guid isPermaLink="true">/news/2022/07/06/release-1.15.1.html</guid> +</item> + <item> <title>Apache Flink 1.14.5 Release Announcement</title> <description><p>The Apache Flink Community is pleased to announce another bug fix release for Flink 1.14.</p> @@ -20067,230 +20254,5 @@ Transaction{timestamp=1563395831000, origin=1, target='3', amount=160}} <guid isPermaLink="true">/news/2019/11/25/query-pulsar-streams-using-apache-flink.html</guid> </item> -<item> -<title>Apache Flink 1.9.1 Released</title> -<description><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.9 series.</p> - -<p>This release includes 96 fixes and minor improvements for Flink 1.9.0. The list below includes a detailed list of all fixes and improvements.</p> - -<p>We highly recommend all users to upgrade to Flink 1.9.1.</p> - -<p>Updated Maven dependencies:</p> - -<div class="highlight"><pre><code class="language-xml"><span class="nt">&lt;dependency&gt;</span> - <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span> - <span class="nt">&lt;artifactId&gt;</span>flink-java<span class="nt">&lt;/artifactId&gt;</span> - <span class="nt">&lt;version&gt;</span>1.9.1<span class="nt">&lt;/version&gt;</span> -<span class="nt">&lt;/dependency&gt;</span> -<span class="nt">&lt;dependency&gt;</span> - <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span> - <span class="nt">&lt;artifactId&gt;</span>flink-streaming-java_2.11<span class="nt">&lt;/artifactId&gt;</span> - <span class="nt">&lt;version&gt;</span>1.9.1<span class="nt">&lt;/version&gt;</span> -<span class="nt">&lt;/dependency&gt;</span> -<span class="nt">&lt;dependency&gt;</span> - <span class="nt">&lt;groupId&gt;</span>org.apache.flink<span class="nt">&lt;/groupId&gt;</span> - <span class="nt">&lt;artifactId&gt;</span>flink-clients_2.11<span class="nt">&lt;/artifactId&gt;</span> - <span class="nt">&lt;version&gt;</span>1.9.1<span class="nt">&lt;/version&gt;</span> -<span class="nt">&lt;/dependency&gt;</span></code></pre></div> - -<p>You can find the binaries on the updated <a href="/downloads.html">Downloads page</a>.</p> - -<p>List of resolved issues:</p> - -<h2> Bug -</h2> -<ul> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-11630">FLINK-11630</a>] - TaskExecutor does not wait for Task termination when terminating itself -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13490">FLINK-13490</a>] - Fix if one column value is null when reading JDBC, the following values are all null -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13941">FLINK-13941</a>] - Prevent data-loss by not cleaning up small part files from S3. -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-12501">FLINK-12501</a>] - AvroTypeSerializer does not work with types generated by avrohugger -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13386">FLINK-13386</a>] - Fix some frictions in the new default Web UI -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13526">FLINK-13526</a>] - Switching to a non existing catalog or database crashes sql-client -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13568">FLINK-13568</a>] - DDL create table doesn&#39;t allow STRING data type -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13805">FLINK-13805</a>] - Bad Error Message when TaskManager is lost -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13806">FLINK-13806</a>] - Metric Fetcher floods the JM log with errors when TM is lost -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14010">FLINK-14010</a>] - Dispatcher &amp; JobManagers don&#39;t give up leadership when AM is shut down -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14145">FLINK-14145</a>] - CompletedCheckpointStore#getLatestCheckpoint(true) returns wrong checkpoint -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13059">FLINK-13059</a>] - Cassandra Connector leaks Semaphore on Exception and hangs on close -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13534">FLINK-13534</a>] - Unable to query Hive table with decimal column -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13562">FLINK-13562</a>] - Throws exception when FlinkRelMdColumnInterval meets two stage stream group aggregate -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13563">FLINK-13563</a>] - TumblingGroupWindow should implement toString method -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13564">FLINK-13564</a>] - Throw exception if constant with YEAR TO MONTH resolution was used for group windows -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13588">FLINK-13588</a>] - StreamTask.handleAsyncException throws away the exception cause -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13653">FLINK-13653</a>] - ResultStore should avoid using RowTypeInfo when creating a result -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13711">FLINK-13711</a>] - Hive array values not properly displayed in SQL CLI -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13737">FLINK-13737</a>] - flink-dist should add provided dependency on flink-examples-table -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13738">FLINK-13738</a>] - Fix NegativeArraySizeException in LongHybridHashTable -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13742">FLINK-13742</a>] - Fix code generation when aggregation contains both distinct aggregate with and without filter -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13760">FLINK-13760</a>] - Fix hardcode Scala version dependency in hive connector -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13761">FLINK-13761</a>] - `SplitStream` should be deprecated because `SplitJavaStream` is deprecated -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13789">FLINK-13789</a>] - Transactional Id Generation fails due to user code impacting formatting string -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13823">FLINK-13823</a>] - Incorrect debug log in CompileUtils -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13825">FLINK-13825</a>] - The original plugins dir is not restored after e2e test run -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13831">FLINK-13831</a>] - Free Slots / All Slots display error -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13887">FLINK-13887</a>] - Ensure defaultInputDependencyConstraint to be non-null when setting it in ExecutionConfig -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13897">FLINK-13897</a>] - OSS FS NOTICE file is placed in wrong directory -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13933">FLINK-13933</a>] - Hive Generic UDTF can not be used in table API both stream and batch mode -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13936">FLINK-13936</a>] - NOTICE-binary is outdated -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13966">FLINK-13966</a>] - Jar sorting in collect_license_files.sh is locale dependent -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14009">FLINK-14009</a>] - Cron jobs broken due to verifying incorrect NOTICE-binary file -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14049">FLINK-14049</a>] - Update error message for failed partition updates to include task name -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14076">FLINK-14076</a>] - &#39;ClassNotFoundException: KafkaException&#39; on Flink v1.9 w/ checkpointing -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14107">FLINK-14107</a>] - Kinesis consumer record emitter deadlock under event time alignment -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14119">FLINK-14119</a>] - Clean idle state for RetractableTopNFunction -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14139">FLINK-14139</a>] - Fix potential memory leak of rest server when using session/standalone cluster -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14140">FLINK-14140</a>] - The Flink Logo Displayed in Flink Python Shell is Broken -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14150">FLINK-14150</a>] - Unnecessary __pycache__ directories appears in pyflink.zip -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14288">FLINK-14288</a>] - Add Py4j NOTICE for source release -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13892">FLINK-13892</a>] - HistoryServerTest failed on Travis -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14043">FLINK-14043</a>] - SavepointMigrationTestBase is super slow -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-12164">FLINK-12164</a>] - JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-9900">FLINK-9900</a>] - Fix unstable test ZooKeeperHighAvailabilityITCase#testRestoreBehaviourWithFaultyStateHandles -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13484">FLINK-13484</a>] - ConnectedComponents end-to-end test instable with NoResourceAvailableException -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13489">FLINK-13489</a>] - Heavy deployment end-to-end test fails on Travis with TM heartbeat timeout -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13514">FLINK-13514</a>] - StreamTaskTest.testAsyncCheckpointingConcurrentCloseAfterAcknowledge unstable -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13530">FLINK-13530</a>] - AbstractServerTest failed on Travis -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13585">FLINK-13585</a>] - Fix sporadical deallock in TaskAsyncCallTest#testSetsUserCodeClassLoader() -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13599">FLINK-13599</a>] - Kinesis end-to-end test failed on Travis -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13663">FLINK-13663</a>] - SQL Client end-to-end test for modern Kafka failed on Travis -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13688">FLINK-13688</a>] - HiveCatalogUseBlinkITCase.testBlinkUdf constantly failed -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13739">FLINK-13739</a>] - BinaryRowTest.testWriteString() fails in some environments -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13746">FLINK-13746</a>] - Elasticsearch (v2.3.5) sink end-to-end test fails on Travis -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13769">FLINK-13769</a>] - BatchFineGrainedRecoveryITCase.testProgram failed on Travis -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13807">FLINK-13807</a>] - Flink-avro unit tests fails if the character encoding in the environment is not default to UTF-8 -</li> -</ul> - -<h2> Improvement -</h2> -<ul> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13965">FLINK-13965</a>] - Keep hasDeprecatedKeys and deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-9941">FLINK-9941</a>] - Flush in ScalaCsvOutputFormat before close method -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13336">FLINK-13336</a>] - Remove the legacy batch fault tolerance page and redirect it to the new task failure recovery page -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13380">FLINK-13380</a>] - Improve the usability of Flink session cluster on Kubernetes -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13819">FLINK-13819</a>] - Introduce RpcEndpoint State -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13845">FLINK-13845</a>] - Drop all the content of removed &quot;Checkpointed&quot; interface -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13957">FLINK-13957</a>] - Log dynamic properties on job submission -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13967">FLINK-13967</a>] - Generate full binary licensing via collect_license_files.sh -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13968">FLINK-13968</a>] - Add travis check for the correctness of the binary licensing -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13449">FLINK-13449</a>] - Add ARM architecture to MemoryArchitecture -</li> -</ul> - -<h2> Documentation -</h2> -<ul> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13105">FLINK-13105</a>] - Add documentation for blink planner&#39;s built-in functions -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13277">FLINK-13277</a>] - add documentation of Hive source/sink -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13354">FLINK-13354</a>] - Add documentation for how to use blink planner -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13355">FLINK-13355</a>] - Add documentation for Temporal Table Join in blink planner -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13356">FLINK-13356</a>] - Add documentation for TopN and Deduplication in blink planner -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13359">FLINK-13359</a>] - Add documentation for DDL introduction -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13362">FLINK-13362</a>] - Add documentation for Kafka &amp; ES &amp; FileSystem DDL -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13363">FLINK-13363</a>] - Add documentation for streaming aggregate performance tunning. -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13706">FLINK-13706</a>] - add documentation of how to use Hive functions in Flink -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13942">FLINK-13942</a>] - Add Overview page for Getting Started section -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13863">FLINK-13863</a>] - Update Operations Playground to Flink 1.9.0 -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13937">FLINK-13937</a>] - Fix wrong hive dependency version in documentation -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13830">FLINK-13830</a>] - The Document about Cluster on yarn have some problems -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-14160">FLINK-14160</a>] - Extend Operations Playground with --backpressure option -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13388">FLINK-13388</a>] - Update UI screenshots in the documentation to the new default Web Frontend -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13415">FLINK-13415</a>] - Document how to use hive connector in scala shell -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13517">FLINK-13517</a>] - Restructure Hive Catalog documentation -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13643">FLINK-13643</a>] - Document the workaround for users with a different minor Hive version -</li> -<li>[<a href="https://issues.apache.org/jira/browse/FLINK-13757">FLINK-13757</a>] - Fix wrong description of "IS NOT TRUE" function documentation -</li> -</ul> - -</description> -<pubDate>Fri, 18 Oct 2019 14:00:00 +0200</pubDate> -<link>https://flink.apache.org/news/2019/10/18/release-1.9.1.html</link> -<guid isPermaLink="true">/news/2019/10/18/release-1.9.1.html</guid> -</item> - </channel> </rss> diff --git a/content/blog/index.html b/content/blog/index.html index a780be55a..1514e2372 100644 --- a/content/blog/index.html +++ b/content/blog/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></h2> + + <p>06 Jul 2022 + David Anderson (<a href="https://twitter.com/alpinegizmo">@alpinegizmo</a>)</p> + + <p>The Apache Flink Community is pleased to announce a bug fix release for Flink 1.15.</p> + + <p><a href="/news/2022/07/06/release-1.15.1.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></h2> @@ -359,19 +372,6 @@ We are now proud to announce the first production ready release of the operator <hr> - <article> - <h2 class="blog-title"><a href="/2022/05/06/restore-modes.html">Improvements to Flink operations: Snapshots Ownership and Savepoint Formats</a></h2> - - <p>06 May 2022 - Dawid Wysakowicz (<a href="https://twitter.com/dwysakowicz">@dwysakowicz</a>) & Daisy Tsang </p> - - <p>This post will outline the journey of improving snapshotting in past releases and the upcoming improvements in Flink 1.15, which includes making it possible to take savepoints in the native state backend specific format as well as clarifying snapshots ownership.</p> - - <p><a href="/2022/05/06/restore-modes.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -382,7 +382,7 @@ We are now proud to announce the first production ready release of the operator </li> <li> - <span class="page_number ">Page: 1 of 19</span> + <span class="page_number ">Page: 1 of 20</span> </li> <li> @@ -404,6 +404,16 @@ We are now proud to announce the first production ready release of the operator <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page10/index.html b/content/blog/page10/index.html index 90d4787ca..717a886c3 100644 --- a/content/blog/page10/index.html +++ b/content/blog/page10/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/ecosystem/2020/02/22/apache-beam-how-beam-runs-on-top-of-flink.html">Apache Beam: How Beam Runs on Top of Flink</a></h2> + + <p>22 Feb 2020 + Maximilian Michels (<a href="https://twitter.com/stadtlegende">@stadtlegende</a>) & Markos Sfikas (<a href="https://twitter.com/MarkSfik">@MarkSfik</a>)</p> + + <p>This blog post discusses the reasons to use Flink together with Beam for your stream processing needs and takes a closer look at how Flink works with Beam under the hood.</p> + + <p><a href="/ecosystem/2020/02/22/apache-beam-how-beam-runs-on-top-of-flink.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2020/02/20/ddl.html">No Java Required: Configuring Sources and Sinks in SQL</a></h2> @@ -359,21 +372,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2019/10/18/release-1.9.1.html">Apache Flink 1.9.1 Released</a></h2> - - <p>18 Oct 2019 - Jark Wu (<a href="https://twitter.com/JarkWu">@JarkWu</a>)</p> - - <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.9 series.</p> - -</p> - - <p><a href="/news/2019/10/18/release-1.9.1.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -384,7 +382,7 @@ </li> <li> - <span class="page_number ">Page: 10 of 19</span> + <span class="page_number ">Page: 10 of 20</span> </li> <li> @@ -406,6 +404,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page11/index.html b/content/blog/page11/index.html index c1324a6e1..4d41b1ec9 100644 --- a/content/blog/page11/index.html +++ b/content/blog/page11/index.html @@ -236,6 +236,21 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2019/10/18/release-1.9.1.html">Apache Flink 1.9.1 Released</a></h2> + + <p>18 Oct 2019 + Jark Wu (<a href="https://twitter.com/JarkWu">@JarkWu</a>)</p> + + <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.9 series.</p> + +</p> + + <p><a href="/news/2019/10/18/release-1.9.1.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/feature/2019/09/13/state-processor-api.html">The State Processor API: How to Read, write and modify the state of Flink applications</a></h2> @@ -360,19 +375,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/2019/05/14/temporal-tables.html">Flux capacitor, huh? Temporal Tables and Joins in Streaming SQL</a></h2> - - <p>14 May 2019 - Marta Paes (<a href="https://twitter.com/morsapaes">@morsapaes</a>)</p> - - <p>Apache Flink natively supports temporal table joins since the 1.7 release for straightforward temporal data handling. In this blog post, we provide an overview of how this new concept can be leveraged for effective point-in-time analysis in streaming scenarios.</p> - - <p><a href="/2019/05/14/temporal-tables.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -383,7 +385,7 @@ </li> <li> - <span class="page_number ">Page: 11 of 19</span> + <span class="page_number ">Page: 11 of 20</span> </li> <li> @@ -405,6 +407,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page12/index.html b/content/blog/page12/index.html index fd4b5be22..5eb5cb29c 100644 --- a/content/blog/page12/index.html +++ b/content/blog/page12/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/2019/05/14/temporal-tables.html">Flux capacitor, huh? Temporal Tables and Joins in Streaming SQL</a></h2> + + <p>14 May 2019 + Marta Paes (<a href="https://twitter.com/morsapaes">@morsapaes</a>)</p> + + <p>Apache Flink natively supports temporal table joins since the 1.7 release for straightforward temporal data handling. In this blog post, we provide an overview of how this new concept can be leveraged for effective point-in-time analysis in streaming scenarios.</p> + + <p><a href="/2019/05/14/temporal-tables.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/2019/05/03/pulsar-flink.html">When Flink & Pulsar Come Together</a></h2> @@ -365,21 +378,6 @@ for more details.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2018/12/26/release-1.5.6.html">Apache Flink 1.5.6 Released</a></h2> - - <p>26 Dec 2018 - </p> - - <p><p>The Apache Flink community released the sixth and last bugfix version of the Apache Flink 1.5 series.</p> - -</p> - - <p><a href="/news/2018/12/26/release-1.5.6.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -390,7 +388,7 @@ for more details.</p> </li> <li> - <span class="page_number ">Page: 12 of 19</span> + <span class="page_number ">Page: 12 of 20</span> </li> <li> @@ -412,6 +410,16 @@ for more details.</p> <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page13/index.html b/content/blog/page13/index.html index 24b09a912..74a46d98f 100644 --- a/content/blog/page13/index.html +++ b/content/blog/page13/index.html @@ -236,6 +236,21 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2018/12/26/release-1.5.6.html">Apache Flink 1.5.6 Released</a></h2> + + <p>26 Dec 2018 + </p> + + <p><p>The Apache Flink community released the sixth and last bugfix version of the Apache Flink 1.5 series.</p> + +</p> + + <p><a href="/news/2018/12/26/release-1.5.6.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2018/12/22/release-1.6.3.html">Apache Flink 1.6.3 Released</a></h2> @@ -373,21 +388,6 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa <hr> - <article> - <h2 class="blog-title"><a href="/news/2018/07/31/release-1.5.2.html">Apache Flink 1.5.2 Released</a></h2> - - <p>31 Jul 2018 - </p> - - <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.5 series.</p> - -</p> - - <p><a href="/news/2018/07/31/release-1.5.2.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -398,7 +398,7 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa </li> <li> - <span class="page_number ">Page: 13 of 19</span> + <span class="page_number ">Page: 13 of 20</span> </li> <li> @@ -420,6 +420,16 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page14/index.html b/content/blog/page14/index.html index 35305adc3..b8a09e286 100644 --- a/content/blog/page14/index.html +++ b/content/blog/page14/index.html @@ -236,6 +236,21 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2018/07/31/release-1.5.2.html">Apache Flink 1.5.2 Released</a></h2> + + <p>31 Jul 2018 + </p> + + <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.5 series.</p> + +</p> + + <p><a href="/news/2018/07/31/release-1.5.2.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2018/07/12/release-1.5.1.html">Apache Flink 1.5.1 Released</a></h2> @@ -367,24 +382,6 @@ for more detail.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2017/11/22/release-1.4-and-1.5-timeline.html">Looking Ahead to Apache Flink 1.4.0 and 1.5.0</a></h2> - - <p>22 Nov 2017 - Stephan Ewen (<a href="https://twitter.com/StephanEwen">@StephanEwen</a>), Aljoscha Krettek (<a href="https://twitter.com/aljoscha">@aljoscha</a>), & Mike Winters (<a href="https://twitter.com/wints">@wints</a>)</p> - - <p><p>The Apache Flink 1.4.0 release is on track to happen in the next couple of weeks, and for all of the -readers out there who haven’t been following the release discussion on <a href="http://flink.apache.org/community.html#mailing-lists">Flink’s developer mailing -list</a>, we’d like to provide some details on -what’s coming in Flink 1.4.0 as well as a preview of what the Flink community will save for 1.5.0.</p> - -</p> - - <p><a href="/news/2017/11/22/release-1.4-and-1.5-timeline.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -395,7 +392,7 @@ what’s coming in Flink 1.4.0 as well as a preview of what the Flink community </li> <li> - <span class="page_number ">Page: 14 of 19</span> + <span class="page_number ">Page: 14 of 20</span> </li> <li> @@ -417,6 +414,16 @@ what’s coming in Flink 1.4.0 as well as a preview of what the Flink community <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page15/index.html b/content/blog/page15/index.html index 834c22a19..3b67cede1 100644 --- a/content/blog/page15/index.html +++ b/content/blog/page15/index.html @@ -236,6 +236,24 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2017/11/22/release-1.4-and-1.5-timeline.html">Looking Ahead to Apache Flink 1.4.0 and 1.5.0</a></h2> + + <p>22 Nov 2017 + Stephan Ewen (<a href="https://twitter.com/StephanEwen">@StephanEwen</a>), Aljoscha Krettek (<a href="https://twitter.com/aljoscha">@aljoscha</a>), & Mike Winters (<a href="https://twitter.com/wints">@wints</a>)</p> + + <p><p>The Apache Flink 1.4.0 release is on track to happen in the next couple of weeks, and for all of the +readers out there who haven’t been following the release discussion on <a href="http://flink.apache.org/community.html#mailing-lists">Flink’s developer mailing +list</a>, we’d like to provide some details on +what’s coming in Flink 1.4.0 as well as a preview of what the Flink community will save for 1.5.0.</p> + +</p> + + <p><a href="/news/2017/11/22/release-1.4-and-1.5-timeline.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2017/08/05/release-1.3.2.html">Apache Flink 1.3.2 Released</a></h2> @@ -366,19 +384,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2017/02/06/release-1.2.0.html">Announcing Apache Flink 1.2.0</a></h2> - - <p>06 Feb 2017 by Robert Metzger - </p> - - <p><p>The Apache Flink community is excited to announce the 1.2.0 release.</p></p> - - <p><a href="/news/2017/02/06/release-1.2.0.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -389,7 +394,7 @@ </li> <li> - <span class="page_number ">Page: 15 of 19</span> + <span class="page_number ">Page: 15 of 20</span> </li> <li> @@ -411,6 +416,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page16/index.html b/content/blog/page16/index.html index 7ed96aa2b..ed090ddfd 100644 --- a/content/blog/page16/index.html +++ b/content/blog/page16/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2017/02/06/release-1.2.0.html">Announcing Apache Flink 1.2.0</a></h2> + + <p>06 Feb 2017 by Robert Metzger + </p> + + <p><p>The Apache Flink community is excited to announce the 1.2.0 release.</p></p> + + <p><a href="/news/2017/02/06/release-1.2.0.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2016/12/21/release-1.1.4.html">Apache Flink 1.1.4 Released</a></h2> @@ -368,21 +381,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2016/04/22/release-1.0.2.html">Flink 1.0.2 Released</a></h2> - - <p>22 Apr 2016 - </p> - - <p><p>Today, the Flink community released Flink version <strong>1.0.2</strong>, the second bugfix release of the 1.0 series.</p> - -</p> - - <p><a href="/news/2016/04/22/release-1.0.2.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -393,7 +391,7 @@ </li> <li> - <span class="page_number ">Page: 16 of 19</span> + <span class="page_number ">Page: 16 of 20</span> </li> <li> @@ -415,6 +413,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page17/index.html b/content/blog/page17/index.html index af34d634b..703848350 100644 --- a/content/blog/page17/index.html +++ b/content/blog/page17/index.html @@ -236,6 +236,21 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2016/04/22/release-1.0.2.html">Flink 1.0.2 Released</a></h2> + + <p>22 Apr 2016 + </p> + + <p><p>Today, the Flink community released Flink version <strong>1.0.2</strong>, the second bugfix release of the 1.0 series.</p> + +</p> + + <p><a href="/news/2016/04/22/release-1.0.2.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2016/04/14/flink-forward-announce.html">Flink Forward 2016 Call for Submissions Is Now Open</a></h2> @@ -364,21 +379,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2015/11/16/release-0.10.0.html">Announcing Apache Flink 0.10.0</a></h2> - - <p>16 Nov 2015 - </p> - - <p><p>The Apache Flink community is pleased to announce the availability of the 0.10.0 release. The community put significant effort into improving and extending Apache Flink since the last release, focusing on data stream processing and operational features. About 80 contributors provided bug fixes, improvements, and new features such that in total more than 400 JIRA issues could be resolved.</p> - -</p> - - <p><a href="/news/2015/11/16/release-0.10.0.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -389,7 +389,7 @@ </li> <li> - <span class="page_number ">Page: 17 of 19</span> + <span class="page_number ">Page: 17 of 20</span> </li> <li> @@ -411,6 +411,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page18/index.html b/content/blog/page18/index.html index 68bdf3e47..13ec68390 100644 --- a/content/blog/page18/index.html +++ b/content/blog/page18/index.html @@ -236,6 +236,21 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2015/11/16/release-0.10.0.html">Announcing Apache Flink 0.10.0</a></h2> + + <p>16 Nov 2015 + </p> + + <p><p>The Apache Flink community is pleased to announce the availability of the 0.10.0 release. The community put significant effort into improving and extending Apache Flink since the last release, focusing on data stream processing and operational features. About 80 contributors provided bug fixes, improvements, and new features such that in total more than 400 JIRA issues could be resolved.</p> + +</p> + + <p><a href="/news/2015/11/16/release-0.10.0.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2015/09/16/off-heap-memory.html">Off-heap Memory in Apache Flink and the curious JIT compiler</a></h2> @@ -379,19 +394,6 @@ release is a preview release that contains known issues.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html">Peeking into Apache Flink's Engine Room</a></h2> - - <p>13 Mar 2015 by Fabian Hüske (<a href="https://twitter.com/">@fhueske</a>) - </p> - - <p>Joins are prevalent operations in many data processing applications. Most data processing systems feature APIs that make joining data sets very easy. However, the internal algorithms for join processing are much more involved – especially if large data sets need to be efficiently handled. In this blog post, we cut through Apache Flink’s layered architecture and take a look at its internals with a focus on how it handles joins.</p> - - <p><a href="/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -402,7 +404,7 @@ release is a preview release that contains known issues.</p> </li> <li> - <span class="page_number ">Page: 18 of 19</span> + <span class="page_number ">Page: 18 of 20</span> </li> <li> @@ -424,6 +426,16 @@ release is a preview release that contains known issues.</p> <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page19/index.html b/content/blog/page19/index.html index 498f136e6..d9c383e62 100644 --- a/content/blog/page19/index.html +++ b/content/blog/page19/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html">Peeking into Apache Flink's Engine Room</a></h2> + + <p>13 Mar 2015 by Fabian Hüske (<a href="https://twitter.com/">@fhueske</a>) + </p> + + <p>Joins are prevalent operations in many data processing applications. Most data processing systems feature APIs that make joining data sets very easy. However, the internal algorithms for join processing are much more involved – especially if large data sets need to be efficiently handled. In this blog post, we cut through Apache Flink’s layered architecture and take a look at its internals with a focus on how it handles joins.</p> + + <p><a href="/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2015/03/02/february-2015-in-flink.html">February 2015 in the Flink community</a></h2> @@ -378,24 +391,6 @@ and offers a new API including definition of flexible windows.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2014/08/26/release-0.6.html">Apache Flink 0.6 available</a></h2> - - <p>26 Aug 2014 - </p> - - <p><p>We are happy to announce the availability of Flink 0.6. This is the -first release of the system inside the Apache Incubator and under the -name Flink. Releases up to 0.5 were under the name Stratosphere, the -academic and open source project that Flink originates from.</p> - -</p> - - <p><a href="/news/2014/08/26/release-0.6.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -406,11 +401,11 @@ academic and open source project that Flink originates from.</p> </li> <li> - <span class="page_number ">Page: 19 of 19</span> + <span class="page_number ">Page: 19 of 20</span> </li> <li> - <span>Next</span> + <a href="/blog/page20" class="next">Next</a> </li> </ul> @@ -428,6 +423,16 @@ academic and open source project that Flink originates from.</p> <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page2/index.html b/content/blog/page2/index.html index be8c5c885..00cebd007 100644 --- a/content/blog/page2/index.html +++ b/content/blog/page2/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/2022/05/06/restore-modes.html">Improvements to Flink operations: Snapshots Ownership and Savepoint Formats</a></h2> + + <p>06 May 2022 + Dawid Wysakowicz (<a href="https://twitter.com/dwysakowicz">@dwysakowicz</a>) & Daisy Tsang </p> + + <p>This post will outline the journey of improving snapshotting in past releases and the upcoming improvements in Flink 1.15, which includes making it possible to take savepoints in the native state backend specific format as well as clarifying snapshots ownership.</p> + + <p><a href="/2022/05/06/restore-modes.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2022/05/05/1.15-announcement.html">Announcing the Release of Apache Flink 1.15</a></h2> @@ -364,19 +377,6 @@ This new release brings various improvements to the StateFun runtime, a leaner w <hr> - <article> - <h2 class="blog-title"><a href="/2022/01/04/scheduler-performance-part-two.html">How We Improved Scheduler Performance for Large-scale Jobs - Part Two</a></h2> - - <p>04 Jan 2022 - Zhilong Hong , Zhu Zhu , Daisy Tsang , & Till Rohrmann (<a href="https://twitter.com/stsffap">@stsffap</a>)</p> - - <p>Part one of this blog post briefly introduced the optimizations we’ve made to improve the performance of the scheduler; compared to Flink 1.12, the time cost and memory usage of scheduling large-scale jobs in Flink 1.14 is significantly reduced. In part two, we will elaborate on the details of these optimizations.</p> - - <p><a href="/2022/01/04/scheduler-performance-part-two.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -387,7 +387,7 @@ This new release brings various improvements to the StateFun runtime, a leaner w </li> <li> - <span class="page_number ">Page: 2 of 19</span> + <span class="page_number ">Page: 2 of 20</span> </li> <li> @@ -409,6 +409,16 @@ This new release brings various improvements to the StateFun runtime, a leaner w <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page13/index.html b/content/blog/page20/index.html similarity index 90% copy from content/blog/page13/index.html copy to content/blog/page20/index.html index 24b09a912..eeddfe706 100644 --- a/content/blog/page13/index.html +++ b/content/blog/page20/index.html @@ -237,153 +237,19 @@ <!-- Blog posts --> <article> - <h2 class="blog-title"><a href="/news/2018/12/22/release-1.6.3.html">Apache Flink 1.6.3 Released</a></h2> + <h2 class="blog-title"><a href="/news/2014/08/26/release-0.6.html">Apache Flink 0.6 available</a></h2> - <p>22 Dec 2018 + <p>26 Aug 2014 </p> - <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.6 series.</p> + <p><p>We are happy to announce the availability of Flink 0.6. This is the +first release of the system inside the Apache Incubator and under the +name Flink. Releases up to 0.5 were under the name Stratosphere, the +academic and open source project that Flink originates from.</p> </p> - <p><a href="/news/2018/12/22/release-1.6.3.html">Continue reading »</a></p> - </article> - - <hr> - - <article> - <h2 class="blog-title"><a href="/news/2018/12/21/release-1.7.1.html">Apache Flink 1.7.1 Released</a></h2> - - <p>21 Dec 2018 - </p> - - <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.7 series.</p> - -</p> - - <p><a href="/news/2018/12/21/release-1.7.1.html">Continue reading »</a></p> - </article> - - <hr> - - <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 - </p> - - <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.6 series.</p> - -</p> - - <p><a href="/news/2018/10/29/release-1.6.2.html">Continue reading »</a></p> - </article> - - <hr> - - <article> - <h2 class="blog-title"><a href="/news/2018/10/29/release-1.5.5.html">Apache Flink 1.5.5 Released</a></h2> - - <p>29 Oct 2018 - </p> - - <p><p>The Apache Flink community released the fifth bugfix version of the Apache Flink 1.5 series.</p> - -</p> - - <p><a href="/news/2018/10/29/release-1.5.5.html">Continue reading »</a></p> - </article> - - <hr> - - <article> - <h2 class="blog-title"><a href="/news/2018/09/20/release-1.6.1.html">Apache Flink 1.6.1 Released</a></h2> - - <p>20 Sep 2018 - </p> - - <p><p>The Apache Flink community released the first bugfix version of the Apache Flink 1.6 series.</p> - -</p> - - <p><a href="/news/2018/09/20/release-1.6.1.html">Continue reading »</a></p> - </article> - - <hr> - - <article> - <h2 class="blog-title"><a href="/news/2018/09/20/release-1.5.4.html">Apache Flink 1.5.4 Released</a></h2> - - <p>20 Sep 2018 - </p> - - <p><p>The Apache Flink community released the fourth bugfix version of the Apache Flink 1.5 series.</p> - -</p> - - <p><a href="/news/2018/09/20/release-1.5.4.html">Continue reading »</a></p> - </article> - - <hr> - - <article> - <h2 class="blog-title"><a href="/news/2018/08/21/release-1.5.3.html">Apache Flink 1.5.3 Released</a></h2> - - <p>21 Aug 2018 - </p> - - <p><p>The Apache Flink community released the third bugfix version of the Apache Flink 1.5 series.</p> - -</p> - - <p><a href="/news/2018/08/21/release-1.5.3.html">Continue reading »</a></p> - </article> - - <hr> - - <article> - <h2 class="blog-title"><a href="/news/2018/08/09/release-1.6.0.html">Apache Flink 1.6.0 Release Announcement</a></h2> - - <p>09 Aug 2018 - Till Rohrmann (<a href="https://twitter.com/stsffap">@stsffap</a>)</p> - - <p><p>The Apache Flink community is proud to announce the 1.6.0 release. Over the past 2 months, the Flink community has worked hard to resolve more than 360 issues. Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12342760">complete changelog</a> for more details.</p> - -</p> - - <p><a href="/news/2018/08/09/release-1.6.0.html">Continue reading »</a></p> - </article> - - <hr> - - <article> - <h2 class="blog-title"><a href="/news/2018/07/31/release-1.5.2.html">Apache Flink 1.5.2 Released</a></h2> - - <p>31 Jul 2018 - </p> - - <p><p>The Apache Flink community released the second bugfix version of the Apache Flink 1.5 series.</p> - -</p> - - <p><a href="/news/2018/07/31/release-1.5.2.html">Continue reading »</a></p> + <p><a href="/news/2014/08/26/release-0.6.html">Continue reading »</a></p> </article> <hr> @@ -394,15 +260,15 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa <ul class="pager"> <li> - <a href="/blog/page12" class="previous">Previous</a> + <a href="/blog/page19" class="previous">Previous</a> </li> <li> - <span class="page_number ">Page: 13 of 19</span> + <span class="page_number ">Page: 20 of 20</span> </li> <li> - <a href="/blog/page14" class="next">Next</a> + <span>Next</span> </li> </ul> @@ -420,6 +286,16 @@ Please check the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html index b20713860..bd4a2258a 100644 --- a/content/blog/page3/index.html +++ b/content/blog/page3/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/2022/01/04/scheduler-performance-part-two.html">How We Improved Scheduler Performance for Large-scale Jobs - Part Two</a></h2> + + <p>04 Jan 2022 + Zhilong Hong , Zhu Zhu , Daisy Tsang , & Till Rohrmann (<a href="https://twitter.com/stsffap">@stsffap</a>)</p> + + <p>Part one of this blog post briefly introduced the optimizations we’ve made to improve the performance of the scheduler; compared to Flink 1.12, the time cost and memory usage of scheduling large-scale jobs in Flink 1.14 is significantly reduced. In part two, we will elaborate on the details of these optimizations.</p> + + <p><a href="/2022/01/04/scheduler-performance-part-two.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/2022/01/04/scheduler-performance-part-one.html">How We Improved Scheduler Performance for Large-scale Jobs - Part One</a></h2> @@ -359,21 +372,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/2021/09/07/connector-table-sql-api-part2.html">Implementing a custom source connector for Table API and SQL - Part Two </a></h2> - - <p>07 Sep 2021 - Ingo Buerk & Daisy Tsang </p> - - <p><p>In <a href="/2021/09/07/connector-table-sql-api-part1">part one</a> of this tutorial, you learned how to build a custom source connector for Flink. In part two, you will learn how to integrate the connector with a test email inbox through the IMAP protocol and filter out emails using Flink SQL.</p> - -</p> - - <p><a href="/2021/09/07/connector-table-sql-api-part2.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -384,7 +382,7 @@ </li> <li> - <span class="page_number ">Page: 3 of 19</span> + <span class="page_number ">Page: 3 of 20</span> </li> <li> @@ -406,6 +404,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page4/index.html b/content/blog/page4/index.html index 5f6eaf9f6..57348fa52 100644 --- a/content/blog/page4/index.html +++ b/content/blog/page4/index.html @@ -236,6 +236,21 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/2021/09/07/connector-table-sql-api-part2.html">Implementing a custom source connector for Table API and SQL - Part Two </a></h2> + + <p>07 Sep 2021 + Ingo Buerk & Daisy Tsang </p> + + <p><p>In <a href="/2021/09/07/connector-table-sql-api-part1">part one</a> of this tutorial, you learned how to build a custom source connector for Flink. In part two, you will learn how to integrate the connector with a test email inbox through the IMAP protocol and filter out emails using Flink SQL.</p> + +</p> + + <p><a href="/2021/09/07/connector-table-sql-api-part2.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/2021/09/07/connector-table-sql-api-part1.html">Implementing a Custom Source Connector for Table API and SQL - Part One </a></h2> @@ -377,19 +392,6 @@ This new release brings various improvements to the StateFun runtime, a leaner w <hr> - <article> - <h2 class="blog-title"><a href="/2021/05/06/reactive-mode.html">Scaling Flink automatically with Reactive Mode</a></h2> - - <p>06 May 2021 - Robert Metzger (<a href="https://twitter.com/rmetzger_">@rmetzger_</a>)</p> - - <p>Apache Flink 1.13 introduced Reactive Mode, a big step forward in Flink's ability to dynamically adjust to changing workloads, reducing resource utilization and overall costs. This blog post showcases how to use this new feature on Kubernetes, including some lessons learned.</p> - - <p><a href="/2021/05/06/reactive-mode.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -400,7 +402,7 @@ This new release brings various improvements to the StateFun runtime, a leaner w </li> <li> - <span class="page_number ">Page: 4 of 19</span> + <span class="page_number ">Page: 4 of 20</span> </li> <li> @@ -422,6 +424,16 @@ This new release brings various improvements to the StateFun runtime, a leaner w <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page5/index.html b/content/blog/page5/index.html index 661d17951..b2d227bf8 100644 --- a/content/blog/page5/index.html +++ b/content/blog/page5/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/2021/05/06/reactive-mode.html">Scaling Flink automatically with Reactive Mode</a></h2> + + <p>06 May 2021 + Robert Metzger (<a href="https://twitter.com/rmetzger_">@rmetzger_</a>)</p> + + <p>Apache Flink 1.13 introduced Reactive Mode, a big step forward in Flink's ability to dynamically adjust to changing workloads, reducing resource utilization and overall costs. This blog post showcases how to use this new feature on Kubernetes, including some lessons learned.</p> + + <p><a href="/2021/05/06/reactive-mode.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2021/05/03/release-1.13.0.html">Apache Flink 1.13.0 Release Announcement</a></h2> @@ -365,19 +378,6 @@ to develop scalable, consistent, and elastic distributed applications.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2021/01/11/batch-fine-grained-fault-tolerance.html">Exploring fine-grained recovery of bounded data sets on Flink</a></h2> - - <p>11 Jan 2021 - Robert Metzger (<a href="https://twitter.com/rmetzger_">@rmetzger_</a>)</p> - - <p>Apache Flink 1.9 introduced fine-grained recovery through FLIP-1. The Flink APIs that are made for bounded workloads benefit from this change by individually recovering failed operators, re-using results from the previous processing step. This blog post gives an overview over these changes and evaluates their effectiveness.</p> - - <p><a href="/news/2021/01/11/batch-fine-grained-fault-tolerance.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -388,7 +388,7 @@ to develop scalable, consistent, and elastic distributed applications.</p> </li> <li> - <span class="page_number ">Page: 5 of 19</span> + <span class="page_number ">Page: 5 of 20</span> </li> <li> @@ -410,6 +410,16 @@ to develop scalable, consistent, and elastic distributed applications.</p> <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page6/index.html b/content/blog/page6/index.html index 4af1387f4..f700b5f46 100644 --- a/content/blog/page6/index.html +++ b/content/blog/page6/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2021/01/11/batch-fine-grained-fault-tolerance.html">Exploring fine-grained recovery of bounded data sets on Flink</a></h2> + + <p>11 Jan 2021 + Robert Metzger (<a href="https://twitter.com/rmetzger_">@rmetzger_</a>)</p> + + <p>Apache Flink 1.9 introduced fine-grained recovery through FLIP-1. The Flink APIs that are made for bounded workloads benefit from this change by individually recovering failed operators, re-using results from the previous processing step. This blog post gives an overview over these changes and evaluates their effectiveness.</p> + + <p><a href="/news/2021/01/11/batch-fine-grained-fault-tolerance.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/2021/01/07/pulsar-flink-connector-270.html">What's New in the Pulsar Flink Connector 2.7.0</a></h2> @@ -365,21 +378,6 @@ as well as increased observability for operational purposes.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2020/09/17/release-1.11.2.html">Apache Flink 1.11.2 Released</a></h2> - - <p>17 Sep 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.11 series.</p> - -</p> - - <p><a href="/news/2020/09/17/release-1.11.2.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -390,7 +388,7 @@ as well as increased observability for operational purposes.</p> </li> <li> - <span class="page_number ">Page: 6 of 19</span> + <span class="page_number ">Page: 6 of 20</span> </li> <li> @@ -412,6 +410,16 @@ as well as increased observability for operational purposes.</p> <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page7/index.html b/content/blog/page7/index.html index 95c7c68fa..8568e66b5 100644 --- a/content/blog/page7/index.html +++ b/content/blog/page7/index.html @@ -236,6 +236,21 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2020/09/17/release-1.11.2.html">Apache Flink 1.11.2 Released</a></h2> + + <p>17 Sep 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.11 series.</p> + +</p> + + <p><a href="/news/2020/09/17/release-1.11.2.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2020/09/04/community-update.html">Flink Community Update - August'20</a></h2> @@ -357,19 +372,6 @@ <hr> - <article> - <h2 class="blog-title"><a href="/news/2020/07/27/community-update.html">Flink Community Update - July'20</a></h2> - - <p>27 Jul 2020 - Marta Paes (<a href="https://twitter.com/morsapaes">@morsapaes</a>)</p> - - <p>As July draws to an end, we look back at a monthful of activity in the Flink community, including two releases (!) and some work around improving the first-time contribution experience in the project. Also, events are starting to pick up again, so we've put together a list of some great events you can (virtually) attend in August!</p> - - <p><a href="/news/2020/07/27/community-update.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -380,7 +382,7 @@ </li> <li> - <span class="page_number ">Page: 7 of 19</span> + <span class="page_number ">Page: 7 of 20</span> </li> <li> @@ -402,6 +404,16 @@ <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page8/index.html b/content/blog/page8/index.html index 912189773..39c3d0c45 100644 --- a/content/blog/page8/index.html +++ b/content/blog/page8/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2020/07/27/community-update.html">Flink Community Update - July'20</a></h2> + + <p>27 Jul 2020 + Marta Paes (<a href="https://twitter.com/morsapaes">@morsapaes</a>)</p> + + <p>As July draws to an end, we look back at a monthful of activity in the Flink community, including two releases (!) and some work around improving the first-time contribution experience in the project. Also, events are starting to pick up again, so we've put together a list of some great events you can (virtually) attend in August!</p> + + <p><a href="/news/2020/07/27/community-update.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/2020/07/23/catalogs.html">Sharing is caring - Catalogs in Flink SQL</a></h2> @@ -375,19 +388,6 @@ and provide a tutorial for running Streaming ETL with Flink on Zeppelin.</p> <hr> - <article> - <h2 class="blog-title"><a href="/news/2020/05/07/community-update.html">Flink Community Update - May'20</a></h2> - - <p>07 May 2020 - Marta Paes (<a href="https://twitter.com/morsapaes">@morsapaes</a>)</p> - - <p>Can you smell it? It’s release month! This time around, we’re warming up for Flink 1.11 and peeping back to the past month in the Flink community — with the release of Stateful Functions 2.0, a new self-paced Flink training and some efforts to improve the Flink documentation experience.</p> - - <p><a href="/news/2020/05/07/community-update.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -398,7 +398,7 @@ and provide a tutorial for running Streaming ETL with Flink on Zeppelin.</p> </li> <li> - <span class="page_number ">Page: 8 of 19</span> + <span class="page_number ">Page: 8 of 20</span> </li> <li> @@ -420,6 +420,16 @@ and provide a tutorial for running Streaming ETL with Flink on Zeppelin.</p> <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/blog/page9/index.html b/content/blog/page9/index.html index f174f0d87..fa0a577fd 100644 --- a/content/blog/page9/index.html +++ b/content/blog/page9/index.html @@ -236,6 +236,19 @@ <div class="col-sm-8"> <!-- Blog posts --> + <article> + <h2 class="blog-title"><a href="/news/2020/05/07/community-update.html">Flink Community Update - May'20</a></h2> + + <p>07 May 2020 + Marta Paes (<a href="https://twitter.com/morsapaes">@morsapaes</a>)</p> + + <p>Can you smell it? It’s release month! This time around, we’re warming up for Flink 1.11 and peeping back to the past month in the Flink community — with the release of Stateful Functions 2.0, a new self-paced Flink training and some efforts to improve the Flink documentation experience.</p> + + <p><a href="/news/2020/05/07/community-update.html">Continue reading »</a></p> + </article> + + <hr> + <article> <h2 class="blog-title"><a href="/news/2020/05/04/season-of-docs.html">Applying to Google Season of Docs 2020</a></h2> @@ -360,19 +373,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="/ecosystem/2020/02/22/apache-beam-how-beam-runs-on-top-of-flink.html">Apache Beam: How Beam Runs on Top of Flink</a></h2> - - <p>22 Feb 2020 - Maximilian Michels (<a href="https://twitter.com/stadtlegende">@stadtlegende</a>) & Markos Sfikas (<a href="https://twitter.com/MarkSfik">@MarkSfik</a>)</p> - - <p>This blog post discusses the reasons to use Flink together with Beam for your stream processing needs and takes a closer look at how Flink works with Beam under the hood.</p> - - <p><a href="/ecosystem/2020/02/22/apache-beam-how-beam-runs-on-top-of-flink.html">Continue reading »</a></p> - </article> - - <hr> - <!-- Pagination links --> @@ -383,7 +383,7 @@ This release marks a big milestone: Stateful Functions 2.0 is not only an API up </li> <li> - <span class="page_number ">Page: 9 of 19</span> + <span class="page_number ">Page: 9 of 20</span> </li> <li> @@ -405,6 +405,16 @@ This release marks a big milestone: Stateful Functions 2.0 is not only an API up <ul id="markdown-toc"> + <li><a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></li> + + + + + + + + + <li><a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></li> diff --git a/content/downloads.html b/content/downloads.html index c4be4a8c6..f0ac94c13 100644 --- a/content/downloads.html +++ b/content/downloads.html @@ -236,7 +236,7 @@ <div class="page-toc"> <ul id="markdown-toc"> - <li><a href="#apache-flink-1150" id="markdown-toc-apache-flink-1150">Apache Flink 1.15.0</a></li> + <li><a href="#apache-flink-1151" id="markdown-toc-apache-flink-1151">Apache Flink 1.15.1</a></li> <li><a href="#apache-flink-1145" id="markdown-toc-apache-flink-1145">Apache Flink 1.14.5</a></li> <li><a href="#apache-flink-1136" id="markdown-toc-apache-flink-1136">Apache Flink 1.13.6</a></li> <li><a href="#apache-flink-1127" id="markdown-toc-apache-flink-1127">Apache Flink 1.12.7</a></li> @@ -269,17 +269,17 @@ </div> -<p>Apache Flink® 1.15.0 is our latest stable release.</p> +<p>Apache Flink® 1.15.1 is our latest stable release.</p> -<h2 id="apache-flink-1150">Apache Flink 1.15.0</h2> +<h2 id="apache-flink-1151">Apache Flink 1.15.1</h2> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz" id="1150-download_212">Apache Flink 1.15.0 for Scala 2.12</a> (<a href="https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz.sha512">sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz" id="1151-download_212">Apache Flink 1.15.1 for Scala 2.12</a> (<a href="https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz.sha512">sha512</a>) </p> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.15.0/flink-1.15.0-src.tgz" id="1150-download-source">Apache Flink 1.15.0 Source Release</a> -(<a href="https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-src.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-src.tgz.sha512">sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.15.1/flink-1.15.1-src.tgz" id="1151-download-source">Apache Flink 1.15.1 Source Release</a> +(<a href="https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-src.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-src.tgz.sha512">sha512</a>) </p> <h4 id="release-notes">Release Notes</h4> @@ -494,17 +494,17 @@ main Flink release:</p> <div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> <span class="nt"><artifactId></span>flink-java<span class="nt"></artifactId></span> - <span class="nt"><version></span>1.15.0<span class="nt"></version></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> <span class="nt"></dependency></span> <span class="nt"><dependency></span> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> <span class="nt"><artifactId></span>flink-streaming-java_2.11<span class="nt"></artifactId></span> - <span class="nt"><version></span>1.15.0<span class="nt"></version></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> <span class="nt"></dependency></span> <span class="nt"><dependency></span> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> <span class="nt"><artifactId></span>flink-clients_2.11<span class="nt"></artifactId></span> - <span class="nt"><version></span>1.15.0<span class="nt"></version></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> <span class="nt"></dependency></span></code></pre></div> <h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3> @@ -579,6 +579,17 @@ The <code>statefun-flink-harness</code> dependency includes a local execution en <li> +Flink 1.15.1 - 2022-07-06 +(<a href="https://archive.apache.org/dist/flink/flink-1.15.1/flink-1.15.1-src.tgz">Source</a>, +<a href="https://archive.apache.org/dist/flink/flink-1.15.1">Binaries</a>, +<a href="https://nightlies.apache.org/flink/flink-docs-release-1.15">Docs</a>, +<a href="https://nightlies.apache.org/flink/flink-docs-release-1.15/api/java">Javadocs</a>, +<a href="https://nightlies.apache.org/flink/flink-docs-release-1.15/api/scala/index.html">Scaladocs</a>) + +</li> + +<li> + Flink 1.15.0 - 2022-05-05 (<a href="https://archive.apache.org/dist/flink/flink-1.15.0/flink-1.15.0-src.tgz">Source</a>, <a href="https://archive.apache.org/dist/flink/flink-1.15.0">Binaries</a>, diff --git a/content/index.html b/content/index.html index 3947ce37f..4770cf587 100644 --- a/content/index.html +++ b/content/index.html @@ -401,6 +401,9 @@ <dl> + <dt> <a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></dt> + <dd>The Apache Flink Community is pleased to announce a bug fix release for Flink 1.15.</dd> + <dt> <a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></dt> <dd>The Apache Flink Community is pleased to announce another bug fix release for Flink 1.14.</dd> @@ -415,9 +418,6 @@ We are now proud to announce the first production ready release of the operator <dt> <a href="/2022/05/30/changelog-state-backend.html">Improving speed and stability of checkpointing with generic log-based incremental checkpoints</a></dt> <dd>This post describes the mechanism introduced in Flink 1.15 that continuously uploads state changes to a durable storage while performing materialization in the background</dd> - - <dt> <a href="/2022/05/23/latency-part2.html">Getting into Low-Latency Gears with Apache Flink - Part Two</a></dt> - <dd>This multi-part series of blog post presents a collection of low-latency techniques in Flink. Following with part one, Part two continues with a few more techniques that optimize latency directly.</dd> </dl> diff --git a/content/index.html b/content/news/2022/07/06/release-1.15.1.html similarity index 50% copy from content/index.html copy to content/news/2022/07/06/release-1.15.1.html index 3947ce37f..1bd6130bb 100644 --- a/content/index.html +++ b/content/news/2022/07/06/release-1.15.1.html @@ -5,7 +5,7 @@ <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: Stateful Computations over Data Streams</title> + <title>Apache Flink: Apache Flink 1.15.1 Release Announcement</title> <link rel="shortcut icon" href="/favicon.ico" type="image/x-icon"> <link rel="icon" href="/favicon.ico" type="image/x-icon"> @@ -149,7 +149,7 @@ <li><a href="/gettinghelp.html">Getting Help</a></li> <!-- Blog --> - <li><a href="/blog/"><b>Flink Blog</b></a></li> + <li class="active"><a href="/blog/"><b>Flink Blog</b></a></li> <!-- Flink-packages --> @@ -181,7 +181,8 @@ <li> - <a href="/zh/">中文版</a> + <!-- link to the Chinese home page when current is blog page --> + <a href="/zh">中文版</a> </li> @@ -229,260 +230,213 @@ </div> <div class="col-sm-9"> <div class="row-fluid"> - - <div class="col-sm-12"> - <p class="lead"> - <strong>Apache Flink<sup>®</sup> — Stateful Computations over Data Streams</strong> - </p> - </div> - -<div class="col-sm-12"> - <hr /> -</div> - -</div> - -<!-- High-level architecture figure --> - -<div class="row front-graphic"> - <hr /> - <img src="/img/flink-home-graphic.png" width="800px" /> -</div> - -<!-- Feature grid --> - -<!-- -<div class="row"> <div class="col-sm-12"> - <hr /> - <h2><a href="/features.html">Features</a></h2> - </div> -</div> ---> -<div class="row"> - <div class="col-sm-4"> - <div class="panel panel-default"> - <div class="panel-heading"> - <span class="glyphicon glyphicon-th"></span> <b>All streaming use cases</b> - </div> - <div class="panel-body"> - <ul style="font-size: small;"> - <li>Event-driven Applications</li> - <li>Stream & Batch Analytics</li> - <li>Data Pipelines & ETL</li> - </ul> - <a href="/usecases.html">Learn more</a> - </div> - </div> - </div> - <div class="col-sm-4"> - <div class="panel panel-default"> - <div class="panel-heading"> - <span class="glyphicon glyphicon-ok"></span> <b>Guaranteed correctness</b> - </div> - <div class="panel-body"> - <ul style="font-size: small;"> - <li>Exactly-once state consistency</li> - <li>Event-time processing</li> - <li>Sophisticated late data handling</li> - </ul> - <a href="/flink-applications.html#building-blocks-for-streaming-applications">Learn more</a> - </div> - </div> - </div> - <div class="col-sm-4"> - <div class="panel panel-default"> - <div class="panel-heading"> - <span class="glyphicon glyphicon glyphicon-sort-by-attributes"></span> <b>Layered APIs</b> - </div> - <div class="panel-body"> - <ul style="font-size: small;"> - <li>SQL on Stream & Batch Data</li> - <li>DataStream API & DataSet API</li> - <li>ProcessFunction (Time & State)</li> - </ul> - <a href="/flink-applications.html#layered-apis">Learn more</a> - </div> - </div> - </div> -</div> -<div class="row"> - <div class="col-sm-4"> - <div class="panel panel-default"> - <div class="panel-heading"> - <span class="glyphicon glyphicon-dashboard"></span> <b>Operational Focus</b> - </div> - <div class="panel-body"> - <ul style="font-size: small;"> - <li>Flexible deployment</li> - <li>High-availability setup</li> - <li>Savepoints</li> - </ul> - <a href="/flink-operations.html">Learn more</a> - </div> - </div> - </div> - <div class="col-sm-4"> - <div class="panel panel-default"> - <div class="panel-heading"> - <span class="glyphicon glyphicon-fullscreen"></span> <b>Scales to any use case</b> - </div> - <div class="panel-body"> - <ul style="font-size: small;"> - <li>Scale-out architecture</li> - <li>Support for very large state</li> - <li>Incremental checkpointing</li> - </ul> - <a href="/flink-architecture.html#run-applications-at-any-scale">Learn more</a> - </div> + <div class="row"> + <h1>Apache Flink 1.15.1 Release Announcement</h1> + <p><i></i></p> + + <article> + <p>06 Jul 2022 David Anderson (<a href="https://twitter.com/alpinegizmo">@alpinegizmo</a>)</p> + +<p>The Apache Flink Community is pleased to announce the first bug fix release of the Flink 1.15 series.</p> + +<p>This release includes 62 bug fixes, vulnerability fixes, and minor improvements for Flink 1.15. +Below you will find a list of all bugfixes and improvements (excluding improvements to the build infrastructure and build stability). For a complete list of all changes see: +<a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12351546">JIRA</a>.</p> + +<p>We highly recommend all users upgrade to Flink 1.15.1.</p> + +<h1 id="release-artifacts">Release Artifacts</h1> + +<h2 id="maven-dependencies">Maven Dependencies</h2> + +<div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span> + <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> + <span class="nt"><artifactId></span>flink-java<span class="nt"></artifactId></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> +<span class="nt"></dependency></span> +<span class="nt"><dependency></span> + <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> + <span class="nt"><artifactId></span>flink-streaming-java<span class="nt"></artifactId></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> +<span class="nt"></dependency></span> +<span class="nt"><dependency></span> + <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> + <span class="nt"><artifactId></span>flink-clients<span class="nt"></artifactId></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> +<span class="nt"></dependency></span></code></pre></div> + +<h2 id="binaries">Binaries</h2> + +<p>You can find the binaries on the updated <a href="/downloads.html">Downloads page</a>.</p> + +<h2 id="docker-images">Docker Images</h2> + +<ul> + <li><a href="https://hub.docker.com/_/flink?tab=tags&page=1&name=1.15.1">library/flink</a> (official images)</li> + <li><a href="https://hub.docker.com/r/apache/flink/tags?page=1&name=1.15.1">apache/flink</a> (ASF repository)</li> +</ul> + +<h2 id="pypi">PyPi</h2> + +<ul> + <li><a href="https://pypi.org/project/apache-flink/1.15.1/">apache-flink==1.15.1</a></li> +</ul> + +<h1 id="release-notes">Release Notes</h1> + +<p>The community is aware of two issues that were introduced with 1.15.0 that remain unresolved. Efforts are underway to fix these issues for Flink 1.15.2:</p> + +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28060">FLINK-28060</a>] - Kafka commit on checkpointing fails repeatedly after a broker restart +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28322">FLINK-28322</a>] - DataStreamScanProvider's new method is not compatible +</li> +</ul> + +<h2> Bug +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-22984">FLINK-22984</a>] - UnsupportedOperationException when using Python UDF to generate watermark +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-24491">FLINK-24491</a>] - ExecutionGraphInfo may not be archived when the dispatcher terminates +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-24735">FLINK-24735</a>] - SQL client crashes with `Cannot add expression of different type to set` +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26645">FLINK-26645</a>] - Pulsar Source subscribe to a single topic partition will consume all partitions from that topic +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27041">FLINK-27041</a>] - KafkaSource in batch mode failing if any topic partition is empty +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27140">FLINK-27140</a>] - Move JobResultStore dirty entry creation into ioExecutor +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27174">FLINK-27174</a>] - Non-null check for bootstrapServers field is incorrect in KafkaSink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27218">FLINK-27218</a>] - Serializer in OperatorState has not been updated when new Serializers are NOT incompatible +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27223">FLINK-27223</a>] - State access doesn't work as expected when cache size is set to 0 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27247">FLINK-27247</a>] - ScalarOperatorGens.numericCasting is not compatible with legacy behavior +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27255">FLINK-27255</a>] - Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27282">FLINK-27282</a>] - Fix the bug of wrong positions mapping in RowCoder +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27367">FLINK-27367</a>] - SQL CAST between INT and DATE is broken +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27368">FLINK-27368</a>] - SQL CAST(' 1 ' as BIGINT) returns wrong result +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27409">FLINK-27409</a>] - Cleanup stale slot allocation record when the resource requirement of a job is empty +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27418">FLINK-27418</a>] - Flink SQL TopN result is wrong +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27420">FLINK-27420</a>] - Suspended SlotManager fails to re-register metrics when started again +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27465">FLINK-27465</a>] - AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27487">FLINK-27487</a>] - KafkaMetricWrappers do incorrect cast +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27545">FLINK-27545</a>] - Update examples in PyFlink shell +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27563">FLINK-27563</a>] - Resource Providers - Yarn doc page has minor display error +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27606">FLINK-27606</a>] - CompileException when using UDAF with merge() method +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27676">FLINK-27676</a>] - Output records from on_timer are behind the triggering watermark in PyFlink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27683">FLINK-27683</a>] - Insert into (column1, column2) Values(.....) fails with SQL hints +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27711">FLINK-27711</a>] - Correct the typo of set_topics_pattern by changing it to set_topic_pattern for Pulsar Connector +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27733">FLINK-27733</a>] - Rework on_timer output behind watermark bug fix +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27734">FLINK-27734</a>] - Not showing checkpoint interval properly in WebUI when checkpoint is disabled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27760">FLINK-27760</a>] - NPE is thrown when executing PyFlink jobs in batch mode +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27762">FLINK-27762</a>] - Kafka WakeupException during handling splits changes +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27797">FLINK-27797</a>] - PythonTableUtils.getCollectionInputFormat cannot correctly handle None values +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27848">FLINK-27848</a>] - ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27881">FLINK-27881</a>] - The key(String) in PulsarMessageBuilder returns null +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27890">FLINK-27890</a>] - SideOutputExample.java fails +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27910">FLINK-27910</a>] - FileSink not enforcing rolling policy if started from scratch +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27933">FLINK-27933</a>] - Savepoint status cannot be queried from standby jobmanager +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27955">FLINK-27955</a>] - PyFlink installation failure on Windows OS +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27999">FLINK-27999</a>] - NoSuchMethodError when using Hive 3 dialect +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28018">FLINK-28018</a>] - the start index to create empty splits in BinaryInputFormat#createInputSplits is inappropriate +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28019">FLINK-28019</a>] - Error in RetractableTopNFunction when retracting a stale record with state ttl enabled +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-28114">FLINK-28114</a>] - The path of the Python client interpreter could not point to an archive file in distributed file system +</li> +</ul> + +<h2> Improvement +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-24586">FLINK-24586</a>] - SQL functions should return STRING instead of VARCHAR(2000) +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26788">FLINK-26788</a>] - AbstractDeserializationSchema should add cause when throwing a FlinkRuntimeException +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26909">FLINK-26909</a>] - Allow setting parallelism to -1 from CLI +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27064">FLINK-27064</a>] - Centralize ArchUnit rules for production code +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27480">FLINK-27480</a>] - KafkaSources sharing the groupId might lead to InstanceAlreadyExistException warning +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27534">FLINK-27534</a>] - Apply scalafmt to 1.15 branch +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27776">FLINK-27776</a>] - Throw exception when UDAF used in sliding window does not implement merge method in PyFlink +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27935">FLINK-27935</a>] - Add Pyflink example of create temporary view document +</li> +</ul> + +<h2> Technical Debt +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-25694">FLINK-25694</a>] - Upgrade Presto to resolve GSON/Alluxio Vulnerability +</li> +</ul> + +<h2> Sub-task +</h2> +<ul> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26052">FLINK-26052</a>] - Update chinese documentation regarding FLIP-203 +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-26588">FLINK-26588</a>] - Translate the new SQL CAST documentation to Chinese +</li> +<li>[<a href="https://issues.apache.org/jira/browse/FLINK-27382">FLINK-27382</a>] - Make Job mode wait with cluster shutdown until the cleanup is done +</li> +</ul> + + </article> </div> - </div> - <div class="col-sm-4"> - <div class="panel panel-default"> - <div class="panel-heading"> - <span class="glyphicon glyphicon-flash"></span> <b>Excellent Performance</b> - </div> - <div class="panel-body"> - <ul style="font-size: small;"> - <li>Low latency</li> - <li>High throughput</li> - <li>In-Memory computing</li> - </ul> - <a href="/flink-architecture.html#leverage-in-memory-performance">Learn more</a> - </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> - -<!-- Events section --> -<div class="row"> - -<div class="col-sm-12"> - <hr /> -</div> - -<div class="col-sm-3"> - - <h2><a>Upcoming Events</a></h2> - -</div> -<div class="col-sm-9"> - <!-- Flink Forward --> - <a href="https://flink-forward.org" target="_blank"> - <img style="width: 180px; padding-right: 10px" src="/img/flink-forward.png" alt="Flink Forward" /> - </a> - <!-- ApacheCon --> - <a href="https://www.apache.org/events/current-event" target="_blank"> - <img style="width: 200px; padding-right: 10px" src="https://www.apache.org/events/current-event-234x60.png" alt="ApacheCon" /> - </a> - <!-- Flink Forward Asia --> - <a href="https://flink-forward.org.cn/" target="_blank"> - <img style="width: 230px" src="/img/flink-forward-asia.png" alt="Flink Forward Asia" /> - </a> -</div> - -</div> - -<!-- Updates section --> - -<div class="row"> - -<div class="col-sm-12"> - <hr /> -</div> - -<div class="col-sm-3"> - - <h2><a href="/blog">Latest Blog Posts</a></h2> - -</div> - -<div class="col-sm-9"> - - <dl> - - <dt> <a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></dt> - <dd>The Apache Flink Community is pleased to announce another bug fix release for Flink 1.14.</dd> - - <dt> <a href="/2022/06/17/adaptive-batch-scheduler.html">Adaptive Batch Scheduler: Automatically Decide Parallelism of Flink Batch Jobs</a></dt> - <dd>To automatically decide parallelism of Flink batch jobs, we introduced adaptive batch scheduler in Flink 1.15. In this post, we'll take a close look at the design & implementation details.</dd> - - <dt> <a href="/news/2022/06/05/release-kubernetes-operator-1.0.0.html">Apache Flink Kubernetes Operator 1.0.0 Release Announcement</a></dt> - <dd><p>In the last two months since our <a href="https://flink.apache.org/news/2022/04/03/release-kubernetes-operator-0.1.0.html">initial preview release</a> the community has been hard at work to stabilize and improve the core Flink Kubernetes Operator logic. -We are now proud to announce the first production ready release of the operator project.</p> - -</dd> - - <dt> <a href="/2022/05/30/changelog-state-backend.html">Improving speed and stability of checkpointing with generic log-based incremental checkpoints</a></dt> - <dd>This post describes the mechanism introduced in Flink 1.15 that continuously uploads state changes to a durable storage while performing materialization in the background</dd> - - <dt> <a href="/2022/05/23/latency-part2.html">Getting into Low-Latency Gears with Apache Flink - Part Two</a></dt> - <dd>This multi-part series of blog post presents a collection of low-latency techniques in Flink. Following with part one, Part two continues with a few more techniques that optimize latency directly.</dd> - - </dl> - -</div> - -<!-- Scripts section --> - -<script type="text/javascript" src="/js/jquery.jcarousel.min.js"></script> - -<script type="text/javascript"> - - $(window).load(function(){ - $(function() { - var jcarousel = $('.jcarousel'); - - jcarousel - .on('jcarousel:reload jcarousel:create', function () { - var carousel = $(this), - width = carousel.innerWidth(); - - if (width >= 600) { - width = width / 4; - } else if (width >= 350) { - width = width / 3; - } - - carousel.jcarousel('items').css('width', Math.ceil(width) + 'px'); - }) - .jcarousel({ - wrap: 'circular', - autostart: true - }); - - $('.jcarousel-control-prev') - .jcarouselControl({ - target: '-=1' - }); - - $('.jcarousel-control-next') - .jcarouselControl({ - target: '+=1' - }); - - $('.jcarousel-pagination') - .on('jcarouselpagination:active', 'a', function() { - $(this).addClass('active'); - }) - .on('jcarouselpagination:inactive', 'a', function() { - $(this).removeClass('active'); - }) - .on('click', function(e) { - e.preventDefault(); - }) - .jcarouselPagination({ - perPage: 1, - item: function(page) { - return '<a href="#' + page + '">' + page + '</a>'; - } - }); - }); - }); - -</script> -</div> - </div> </div> diff --git a/content/q/gradle-quickstart.sh b/content/q/gradle-quickstart.sh index 189b40397..d98c655e8 100755 --- a/content/q/gradle-quickstart.sh +++ b/content/q/gradle-quickstart.sh @@ -41,7 +41,7 @@ function mkPackage() { defaultProjectName="quickstart" defaultOrganization="org.myorg.quickstart" defaultVersion="0.1-SNAPSHOT" -defaultFlinkVersion="${1:-1.15.0}" +defaultFlinkVersion="${1:-1.15.1}" # flink-docs-master/docs/dev/datastream/project-configuration/#gradle # passes the scala version prefixed with a _, e.g.: _2.12 scalaBinaryVersionFromCmdArg="${2/_/}" diff --git a/content/q/quickstart-scala.sh b/content/q/quickstart-scala.sh index bf850e39e..aabe9f276 100755 --- a/content/q/quickstart-scala.sh +++ b/content/q/quickstart-scala.sh @@ -24,7 +24,7 @@ PACKAGE=quickstart mvn archetype:generate \ -DarchetypeGroupId=org.apache.flink \ -DarchetypeArtifactId=flink-quickstart-scala \ - -DarchetypeVersion=${1:-1.15.0} \ + -DarchetypeVersion=${1:-1.15.1} \ -DgroupId=org.myorg.quickstart \ -DartifactId=$PACKAGE \ -Dversion=0.1 \ diff --git a/content/q/quickstart.sh b/content/q/quickstart.sh index 98db0ddcc..026eaee8b 100755 --- a/content/q/quickstart.sh +++ b/content/q/quickstart.sh @@ -24,7 +24,7 @@ PACKAGE=quickstart mvn archetype:generate \ -DarchetypeGroupId=org.apache.flink \ -DarchetypeArtifactId=flink-quickstart-java \ - -DarchetypeVersion=${1:-1.15.0} \ + -DarchetypeVersion=${1:-1.15.1} \ -DgroupId=org.myorg.quickstart \ -DartifactId=$PACKAGE \ -Dversion=0.1 \ diff --git a/content/q/sbt-quickstart.sh b/content/q/sbt-quickstart.sh index a77d723dd..46f24dc94 100755 --- a/content/q/sbt-quickstart.sh +++ b/content/q/sbt-quickstart.sh @@ -42,7 +42,7 @@ defaultProjectName="Flink Project" defaultOrganization="org.example" defaultVersion="0.1-SNAPSHOT" defaultScalaVersion="2.12.7" -defaultFlinkVersion="1.15.0" +defaultFlinkVersion="1.15.1" echo "This script creates a Flink project using Scala and SBT." diff --git a/content/zh/downloads.html b/content/zh/downloads.html index 56b12e8a1..e4d41eeda 100644 --- a/content/zh/downloads.html +++ b/content/zh/downloads.html @@ -234,7 +234,7 @@ <div class="page-toc"> <ul id="markdown-toc"> - <li><a href="#apache-flink-1150" id="markdown-toc-apache-flink-1150">Apache Flink 1.15.0</a></li> + <li><a href="#apache-flink-1151" id="markdown-toc-apache-flink-1151">Apache Flink 1.15.1</a></li> <li><a href="#apache-flink-1145" id="markdown-toc-apache-flink-1145">Apache Flink 1.14.5</a></li> <li><a href="#apache-flink-1136" id="markdown-toc-apache-flink-1136">Apache Flink 1.13.6</a></li> <li><a href="#apache-flink-1127" id="markdown-toc-apache-flink-1127">Apache Flink 1.12.7</a></li> @@ -260,18 +260,18 @@ </div> -<p>Apache Flink® 1.15.0 是我们最新的稳定版本。</p> +<p>Apache Flink® 1.15.1 是我们最新的稳定版本。</p> -<h2 id="apache-flink-1150">Apache Flink 1.15.0</h2> +<h2 id="apache-flink-1151">Apache Flink 1.15.1</h2> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz" id="1150-download_212">Apache Flink 1.15.0 for Scala 2.12</a> (<a href=" - https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz.sha512">sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz" id="1151-download_212">Apache Flink 1.15.1 for Scala 2.12</a> (<a href=" + https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz.sha512">sha512</a>) </p> <p> -<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.15.0/flink-1.15.0-src.tgz" id="1150-download-source">Apache Flink 1.15.0 Source Release</a> - (<a href="https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-src.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.15.0/flink-1.15.0-src.tgz.sha512">sha512</a>) +<a href="https://www.apache.org/dyn/closer.lua/flink/flink-1.15.1/flink-1.15.1-src.tgz" id="1151-download-source">Apache Flink 1.15.1 Source Release</a> + (<a href="https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-src.tgz.asc">asc</a>, <a href="https://downloads.apache.org/flink/flink-1.15.1/flink-1.15.1-src.tgz.sha512">sha512</a>) </p> <h4 id="section">发布说明</h4> @@ -449,17 +449,17 @@ flink-docs-release-1.11/release-notes/flink-1.11.html">Flink 1.11 的发布说 <div class="highlight"><pre><code class="language-xml"><span class="nt"><dependency></span> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> <span class="nt"><artifactId></span>flink-java<span class="nt"></artifactId></span> - <span class="nt"><version></span>1.15.0<span class="nt"></version></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> <span class="nt"></dependency></span> <span class="nt"><dependency></span> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> <span class="nt"><artifactId></span>flink-streaming-java_2.11<span class="nt"></artifactId></span> - <span class="nt"><version></span>1.15.0<span class="nt"></version></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> <span class="nt"></dependency></span> <span class="nt"><dependency></span> <span class="nt"><groupId></span>org.apache.flink<span class="nt"></groupId></span> <span class="nt"><artifactId></span>flink-clients_2.11<span class="nt"></artifactId></span> - <span class="nt"><version></span>1.15.0<span class="nt"></version></span> + <span class="nt"><version></span>1.15.1<span class="nt"></version></span> <span class="nt"></dependency></span></code></pre></div> <h3 id="apache-flink-stateful-functions">Apache Flink Stateful Functions</h3> @@ -521,6 +521,17 @@ flink-docs-release-1.11/release-notes/flink-1.11.html">Flink 1.11 的发布说 <li> +Flink 1.15.1 - 2022-07-06 +(<a href="https://archive.apache.org/dist/flink/flink-1.15.1/flink-1.15.1-src.tgz">Source</a>, +<a href="https://archive.apache.org/dist/flink/flink-1.15.1">Binaries</a>, +<a href="https://nightlies.apache.org/flink/flink-docs-release-1.15">Docs</a>, +<a href="https://nightlies.apache.org/flink/flink-docs-release-1.15/api/java">Javadocs</a>, +<a href="https://nightlies.apache.org/flink/flink-docs-release-1.15/api/scala/index.html">Scaladocs</a>) + +</li> + +<li> + Flink 1.15.0 - 2022-05-05 (<a href="https://archive.apache.org/dist/flink/flink-1.15.0/flink-1.15.0-src.tgz">Source</a>, <a href="https://archive.apache.org/dist/flink/flink-1.15.0">Binaries</a>, diff --git a/content/zh/index.html b/content/zh/index.html index dd5757e39..4b9cf0e08 100644 --- a/content/zh/index.html +++ b/content/zh/index.html @@ -398,6 +398,9 @@ <dl> + <dt> <a href="/news/2022/07/06/release-1.15.1.html">Apache Flink 1.15.1 Release Announcement</a></dt> + <dd>The Apache Flink Community is pleased to announce a bug fix release for Flink 1.15.</dd> + <dt> <a href="/news/2022/06/22/release-1.14.5.html">Apache Flink 1.14.5 Release Announcement</a></dt> <dd>The Apache Flink Community is pleased to announce another bug fix release for Flink 1.14.</dd> @@ -412,9 +415,6 @@ We are now proud to announce the first production ready release of the operator <dt> <a href="/2022/05/30/changelog-state-backend.html">Improving speed and stability of checkpointing with generic log-based incremental checkpoints</a></dt> <dd>This post describes the mechanism introduced in Flink 1.15 that continuously uploads state changes to a durable storage while performing materialization in the background</dd> - - <dt> <a href="/2022/05/23/latency-part2.html">Getting into Low-Latency Gears with Apache Flink - Part Two</a></dt> - <dd>This multi-part series of blog post presents a collection of low-latency techniques in Flink. Following with part one, Part two continues with a few more techniques that optimize latency directly.</dd> </dl>