Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add Flink 1.2.1 announcement #54

Closed
wants to merge 2 commits into from
Closed

Add Flink 1.2.1 announcement #54

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
09228e4
Add Flink 1.2.1 announcement
rmetzger Apr 25, 2017
ec1b55b
Mention remaining issues
rmetzger Apr 25, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
219 changes: 219 additions & 0 deletions _posts/2017-04-26-release-1.2.1.md
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,219 @@
---
layout: post
title: "Apache Flink 1.2.1 Released"
date: 2017-04-26 18:00:00
categories: news
---

The Apache Flink community released the first bugfix version of the Apache Flink 1.2 series.

This release includes many critical fixes for Flink 1.2.0. The list below includes a detailed list of all fixes.

We highly recommend all users to upgrade to Flink 1.2.1.

Please note that there are two unresolved major issues in Flink 1.2.1 and 1.2.0:

- [FLINK-6353](https://issues.apache.org/jira/browse/FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2
- [FLINK-6188](https://issues.apache.org/jira/browse/FLINK-6188) Some setParallelism() methods can't cope with default parallelism



```xml
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>1.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.10</artifactId>
<version>1.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients_2.10</artifactId>
<version>1.2.1</version>
</dependency>
```

You can find the binaries on the updated [Downloads page](http://flink.apache.org/downloads.html).


<h2>Release Notes - Flink - Version 1.2.1</h2>


<h3> Sub-task
</h3>
<ul>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5546'>FLINK-5546</a>] - java.io.tmpdir setted as project build directory in surefire plugin
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5640'>FLINK-5640</a>] - configure the explicit Unit Test file suffix
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5723'>FLINK-5723</a>] - Use &quot;Used&quot; instead of &quot;Initial&quot; to make taskmanager tag more readable
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5825'>FLINK-5825</a>] - In yarn mode, a small pic can not be loaded
</li>
</ul>

<h3> Bug
</h3>
<ul>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4813'>FLINK-4813</a>] - Having flink-test-utils as a dependency outside Flink fails the build
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4848'>FLINK-4848</a>] - keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5628'>FLINK-5628</a>] - CheckpointStatsTracker implements Serializable but isn&#39;t
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5644'>FLINK-5644</a>] - Task#lastCheckpointSize metric broken
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5650'>FLINK-5650</a>] - Flink-python tests executing cost too long time
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5652'>FLINK-5652</a>] - Memory leak in AsyncDataStream
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5669'>FLINK-5669</a>] - flink-streaming-contrib DataStreamUtils.collect in local environment mode fails when offline
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5678'>FLINK-5678</a>] - User-defined TableFunctions do not support all types of parameters
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5699'>FLINK-5699</a>] - Cancel with savepoint fails with a NPE if savepoint target directory not set
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5701'>FLINK-5701</a>] - FlinkKafkaProducer should check asyncException on checkpoints
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5708'>FLINK-5708</a>] - we should remove duplicated configuration options
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5732'>FLINK-5732</a>] - Java quick start mvn command line is incorrect
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5749'>FLINK-5749</a>] - unset HADOOP_HOME and HADOOP_CONF_DIR to avoid env in build machine failing the UT and IT
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5751'>FLINK-5751</a>] - 404 in documentation
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5771'>FLINK-5771</a>] - DelimitedInputFormat does not correctly handle multi-byte delimiters
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5773'>FLINK-5773</a>] - Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5806'>FLINK-5806</a>] - TaskExecutionState toString format have wrong key
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5814'>FLINK-5814</a>] - flink-dist creates wrong symlink when not used with cleaned before
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5817'>FLINK-5817</a>] - Fix test concurrent execution failure by test dir conflicts.
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5828'>FLINK-5828</a>] - BlobServer create cache dir has concurrency safety problem
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5885'>FLINK-5885</a>] - Java code snippet instead of scala in documentation
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5907'>FLINK-5907</a>] - RowCsvInputFormat bug on parsing tsv
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5934'>FLINK-5934</a>] - Scheduler in ExecutionGraph null if failure happens in ExecutionGraph.restoreLatestCheckpointedState
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5940'>FLINK-5940</a>] - ZooKeeperCompletedCheckpointStore cannot handle broken state handles
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5942'>FLINK-5942</a>] - Harden ZooKeeperStateHandleStore to deal with corrupted data
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5945'>FLINK-5945</a>] - Close function in OuterJoinOperatorBase#executeOnCollections
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5949'>FLINK-5949</a>] - Flink on YARN checks for Kerberos credentials for non-Kerberos authentication methods
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5962'>FLINK-5962</a>] - Cancel checkpoint canceller tasks in CheckpointCoordinator
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5965'>FLINK-5965</a>] - Typo on DropWizard wrappers
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5972'>FLINK-5972</a>] - Don&#39;t allow shrinking merging windows
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5985'>FLINK-5985</a>] - Flink treats every task as stateful (making topology changes impossible)
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6000'>FLINK-6000</a>] - Can not start HA cluster with start-cluster.sh
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6001'>FLINK-6001</a>] - NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6002'>FLINK-6002</a>] - Documentation: &#39;MacOS X&#39; under &#39;Download and Start Flink&#39; in Quickstart page is not rendered correctly
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6006'>FLINK-6006</a>] - Kafka Consumer can lose state if queried partition list is incomplete on restore
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6025'>FLINK-6025</a>] - User code ClassLoader not used when KryoSerializer fallbacks to serialization for copying
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6051'>FLINK-6051</a>] - Wrong metric scope names in documentation
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6084'>FLINK-6084</a>] - Cassandra connector does not declare all dependencies
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6133'>FLINK-6133</a>] - fix build status in README.md
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6170'>FLINK-6170</a>] - Some checkpoint metrics rely on latest stat snapshot
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6181'>FLINK-6181</a>] - Zookeeper scripts use invalid regex
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6182'>FLINK-6182</a>] - Fix possible NPE in SourceStreamTask
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6183'>FLINK-6183</a>] - TaskMetricGroup may not be cleanup when Task.run() is never called or exits early
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6184'>FLINK-6184</a>] - Buffer metrics can cause NPE
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6203'>FLINK-6203</a>] - DataSet Transformations
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6207'>FLINK-6207</a>] - Duplicate type serializers for async snapshots of CopyOnWriteStateTable
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6308'>FLINK-6308</a>] - Task managers are not attaching to job manager on macos
</li>
</ul>

<h3> Improvement
</h3>
<ul>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-4326'>FLINK-4326</a>] - Flink start-up scripts should optionally start services on the foreground
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5217'>FLINK-5217</a>] - Deprecated interface Checkpointed make clear suggestion
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5331'>FLINK-5331</a>] - PythonPlanBinderTest idling extremely long
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5581'>FLINK-5581</a>] - Improve Kerberos security related documentation
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5639'>FLINK-5639</a>] - Clarify License implications of RabbitMQ Connector
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5680'>FLINK-5680</a>] - Document env.ssh.opts
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5681'>FLINK-5681</a>] - Make ReaperThread for SafetyNetCloseableRegistry a singleton
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5702'>FLINK-5702</a>] - Kafka Producer docs should warn if using setLogFailuresOnly, at-least-once is compromised
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5705'>FLINK-5705</a>] - webmonitor&#39;s request/response use UTF-8 explicitly
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5713'>FLINK-5713</a>] - Protect against NPE in WindowOperator window cleanup
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5721'>FLINK-5721</a>] - Add FoldingState to State Documentation
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5800'>FLINK-5800</a>] - Make sure that the CheckpointStreamFactory is instantiated once per operator only
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5805'>FLINK-5805</a>] - improve docs for ProcessFunction
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5807'>FLINK-5807</a>] - improved wording for doc home page
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5837'>FLINK-5837</a>] - improve readability of the queryable state docs
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5876'>FLINK-5876</a>] - Mention Scala type fallacies for queryable state client serializers
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5877'>FLINK-5877</a>] - Fix Scala snippet in Async I/O API doc
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5894'>FLINK-5894</a>] - HA docs are misleading re: state backends
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5895'>FLINK-5895</a>] - Reduce logging aggressiveness of FileSystemSafetyNet
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-5938'>FLINK-5938</a>] - Replace ExecutionContext by Executor in Scheduler
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6212'>FLINK-6212</a>] - Missing reference to flink-avro dependency
</li>
</ul>

<h3> New Feature
</h3>
<ul>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-6139'>FLINK-6139</a>] - Documentation for building / preparing Flink for MapR
</li>
</ul>

<h3> Task
</h3>
<ul>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-2883'>FLINK-2883</a>] - Add documentation to forbid key-modifying ReduceFunction
</li>
<li>[<a href='https://issues.apache.org/jira/browse/FLINK-3903'>FLINK-3903</a>] - Homebrew Installation
</li>
</ul>