| --- |
| date: "2017-04-26T18:00:00Z" |
| title: Apache Flink 1.2.1 Released |
| aliases: |
| - /news/2017/04/26/release-1.2.1.html |
| --- |
| |
| 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 "Used" instead of "Initial" 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'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'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: 'MacOS X' under 'Download and Start Flink' 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'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> |
| |
