Hi everyone, Please review and vote on release candidate #1 for Flink 1.4.1, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes: * JIRA release notes [1], * the official Apache source release and binary convenience releases to be deployed to dist.apache.org [2], which are signed with the key with fingerprint 1C1E2394D3194E1944613488F320986D35C33D6A [3], * all artifacts to be deployed to the Maven Central Repository [4], * source code tag “release-1.4.1-rc1” [5], * website pull request listing the new release [6]. * A complete list of all new commits in release-1.4.1-rc1, since release-1.4.0 [7] The vote will be open for at least 72 hours. Please test the release and vote for the release candidate before Wednesday (February 14th), 7pm CET. It is adopted by majority approval, with at least 3 PMC affirmative votes. Thanks, Gordon [1] https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12342212 [2] http://people.apache.org/~tzulitai/flink-1.4.1-rc1/ [3] https://dist.apache.org/repos/dist/release/flink/KEYS [4] https://repository.apache.org/content/repositories/orgapacheflink-1145 [5] https://git-wip-us.apache.org/repos/asf?p=flink.git;a=commit;h=dbab73e5d097518838283a7a4f056cca0ac3f9a5 [6] https://github.com/apache/flink-web/pull/101 [7] * dbab73e5d0 - Commit for release 1.4.1 (17 hours ago) * beff62d2e6 - [FLINK-8571] [DataStream] Introduce utility function that reinterprets a data stream as keyed stream (backport from 1.5 branch) (17 hours ago) * 33ebc85c28 - [FLINK-8362] [elasticsearch] Further improvements for Elasticsearch connector shading (2 days ago) * 0c53e798cb - [FLINK-8362][elasticsearch] shade all dependencies (2 days ago) * 5f9e367be6 - [FLINK-7760] Fix deserialization of NFA state in CEP library (3 days ago) * 82f3957811 - [FLINK-8275] [security, yarn] Remove test-specific code path in YarnTaskManagerRunner (4 days ago) * 20146652ba - [FLINK-8275] [security, yarn] Fix keytab local path in YarnTaskManagerRunner (4 days ago) * fb1e24e25e - [FLINK-8421] [test] Increase MAX_MEM_STATE_SIZE and Akka framesize in AbstractEventTimeWindowCheckpointingITCase (4 days ago) * 71d682eb7f - [FLINK-8421] [DataStream] Make timer serializers reconfigurable on restore (4 days ago) * 93d514e628 - [FLINK-8421] [core] Introduce PostVersionedIOReadableWritable (4 days ago) * 319d510174 - [FLINK-8421] [core] Allow InstantiationUtil.deserializeObject() to use FailureTolerantObjectInputStream (4 days ago) * 1f81f6acf4 - [FLINK-8421] [DataStream, tests] Add WindowOperator migration test for Kryo-serialized window keys (4 days ago) * e41300d5a9 - [hotfix] [test] Remove stale savepoint files no longer used by migration tests (4 days ago) * f68fe3ee65 - [FLINK-8472] [tests] Extend AbstractOperatorRestoreTestBases for Flink 1.4 (4 days ago) * 6f4116fe53 - [FLINK-8472] [fs, test] Extend BucketingSinkMigrationTest for Flink 1.4 (4 days ago) * 8d910963fc - [FLINK-8472] [fs, test] Extend ContinuousFileProcessingMigrationTest for Flink 1.4 (4 days ago) * da47bd2ac8 - [FLINK-8472] [kafka, test] Extend FlinkKafkaConsumerBaseMigrationTest for Flink 1.4 (4 days ago) * 8cef78878d - [FLINK-8472] [kinesis, test] Extend FlinkKinesisConsumerMigrationTest for Flink 1.4 (4 days ago) * 83b9727dcc - [FLINK-8472] [DataStream, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4 (4 days ago) * 2ada8567e8 - [FLINK-8472] [DataStream, test] Refactor StatefulJobSavepointFrom*MigrationITCase to single ITCase (4 days ago) * 4fc14ccf7c - [FLINK-8472] [scala, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4 (4 days ago) * 4af0b59968 - [FLINK-8472] [DataStream, test] Extend WindowOperatorMigrationTest for Flink 1.4 (4 days ago) * 9276ee51aa - [hotfix] [kinesis] Use ArrayList for faster shard state updates (4 days ago) * 7884a4f749 - [FLINK-8484] [kinesis] Use an equivalence wrapper around restored StreamShardMetadatas to bypass out-of-sync shard infos (4 days ago) * f887575f88 - [hotfix] [kinesis, test] Use real test classes instead of Mockito in FlinkKinesisConsumerMigrationTest (4 days ago) * 426cf46970 - [FLINK-8484] [kinesis] Synchronize local shard metainfo’s on restore (4 days ago) * ca1e525c5c - [FLINK-8398] [kinesis, tests] Stabilize flaky KinesisDataFetcherTests (4 days ago) * 6922e4c6b6 - [FLINK-8398] [kinesis, tests] Cleanup confusing implementations in KinesisDataFetcherTest and related classes (4 days ago) * 0ad82b39ad - [hotfix][connectors] Fix log format strings (4 days ago) * 432273aa96 - [FLINK-8419] [kafka] Register metrics for dynamically discovered Kafka partitions (4 days ago) * e5ac4b08f7 - [FLINK-8419] [kafka] Move consumer metric group registration to FlinkKafkaConsumerBase (4 days ago) * a951852fb4 - [hotfix] [kafka] Make AbortedReassignmentException a static class (4 days ago) * 08163009e4 - [FLINK-8409] [kafka] Fix offset committing race condition in KafkaConsumerThread (4 days ago) * c9322661ea - [FLINK-8559][RocksDB] Release resources if snapshot operation fails (4 days ago) * 33efaf74a1 - [FLINK-8561] [cep] Fix SharedBuffer.removeEdges to use .equals(). (5 days ago) * a35b37a412 - [hotfix] [cep] SharedBuffer refactoring. (5 days ago) * 624131be3f - [FLINK-8242] [table] RexProgramExtractor only translates literals of known types. (5 days ago) * 19fcd5ebad - [FLINK-8242] [orc] Fix predicate translation if literal is not Serializable. (5 days ago) * e5c1261919 - [FLINK-8243] [orc] OrcTableSource reads input path recursively by default. (5 days ago) * dfa050c01a - [FLINK-8489][ES] Prevent side-effects when modifying user-config (8 days ago) * 4219572a87 - Revert “[FLINK-8411] [State Backends] HeapListState#add(null) will wipe out entire list state” (10 days ago) * 110b86dd20 - [FLINK-8230] [orc] Fix NPEs when reading nested columns. (10 days ago) * 0cc0572c44 - [FLINK-8496][metrics] Create missing “Network” group (10 days ago) * 14aabf82cf - [hotfix][docs] Fix Scala code example in Controlling Latency section (12 days ago) * 09edf6a628 - [FLINK-8485] [client] Unblock JobSubmissionClientActor#tryToSubmitJob (2 weeks ago) * fb088bc134 - [FLINK-7949] Add unit test for AsyncWaitOperator recovery with full queue (2 weeks ago) * a2198b0471 - [FLINK-7949] Make AsyncWaitOperator recoverable also when queue is full (2 weeks ago) * 38278ebefe - [FLINK-8352] [web-dashboard] Report error on jar submission failure (2 weeks ago) * eb6380901e - [FLINK-8406] [bucketing sink] Fix proper access of Hadoop File Systems (2 weeks ago) * 4d1ba45e78 - [FLINK-8466] [runtime] Make sure ErrorInfo references no user-defined classes. (2 weeks ago) * a8ea1698f4 - [hotfix] [build] Converge Kryo dependency (2 weeks ago) * 15cb057bff - [FLINK-8499] [core] Force Kryo to be parent-first loaded. (2 weeks ago) * da8446ee5d - [hotfix] [build] Fix diverging snappy versions. (2 weeks ago) * c701a335be - [hotfix] [build] Print cache info (2 weeks ago) * 77df20bc50 - [FLINK-8433] [doc] Remove ununsed CheckpointedRestoring interface (2 weeks ago) * e4d7ea2641 - [FLINK-8079][tests] Stop end-to-end test execution after first failure (2 weeks ago) * 20be204b96 - [FLINK-8473][webUI] Improve error behavior of JarListHandler (2 weeks ago) * df05261723 - [FLINK-8411] [State Backends] HeapListState#add(null) will wipe out entire list state (3 weeks ago) * aa5e491804 - [FLINK-8325] [table] Fix COUNT(*) and COUNT(1). (3 weeks ago) * bfe3ff07c3 - [FLINK-8355] [table] Remove DataSetAggregateWithNullValuesRule. (3 weeks ago) * 537552267a - [FLINK-8461] [build] Adjust logger configurations for shaded Netty classnames (3 weeks ago) * 0677f08b8f - [FLINK-8455] [core] Make ‘org.apache.hadoop.’ a ‘parent-first’ classloading pattern. (3 weeks ago) * 0deaee835c - [hotfix] [docs] Fix typos (3 weeks ago) * c91544d140 - [hotfix] [kafka] Remove stale comment on publishing procedures of AbstractFetcher (4 weeks ago) * c4bfc7de36 - [FLINK-8306] [kafka, tests] Fix mock verifications on final method (4 weeks ago) * 968683f153 - [FLINK-8296] [kafka] Rework FlinkKafkaConsumerBaseTest to not rely on Java reflection (4 weeks ago) * b7f8a5a2b0 - [hotfix] Fix typo in AbstractMetricGroup.java (4 weeks ago) * ae00cad38c - [hotfix] [doc] Fixed doc typo in DataStream API (4 weeks ago) * b607a8b95d - [FLINK-6951] [kinesis] Shade httpcomponents dependency for Kinesis connector (4 weeks ago) * b32ac3aaf9 - [FLINK-8226] [cep] Dangling reference generated after NFA clean up timed out SharedBufferEntry (4 weeks ago) * 71ede3992a - [FLINK-8371][network] always recycle Buffers when releasing SpillableSubpartition (4 weeks ago) * a316989e5d - [FLINK-7499][io] also let AsynchronousBufferFileWriter#writeBlock() recycle the buffer in case of failures (4 weeks ago) * 2c667dea8e - [hotfix] only update buffer statistics in SpillableSubpartition#add() if successful (4 weeks ago) * 9398dafae6 - [hotfix] add some more buffer recycling checks in SpillableSubpartitionTest (4 weeks ago) * 6f50ed256a - [FLINK-8320][docs] Clarify that only Java 8 is supported (5 weeks ago) * 951d1b94d9 - [hotfix][docs][metrics] Fix Threads.Count metric reference (5 weeks ago) * 2f6e001172 - [hotfix][docs] Fix DataStream iterations documentation (5 weeks ago) * 78e3405bec - [FLINK-8200][tests] Use TemporaryFolder in RocksDBAsyncSnapshotTest (5 weeks ago) * 74135c9db1 - [FLINK-8283] [kafka] Stabalize FlinkKafkaConsumerBaseTest::testScaleUp() (5 weeks ago) * f462f77194 - [hotfix] [kafka] Add serialVersionUID to FlinkKafkaProducer010 (5 weeks ago) * 16a49de3f6 - [hotfix] [kafka] Fix stale Javadoc link in FlinkKafkaProducer09 (5 weeks ago) * 24d449353e - [hotfix] [kafka] Properly deprecate FlinkKafkaProducer010Configuration (5 weeks ago) * 10f1acf923 - [FLINK-8260] [kafka] Reorder deprecated / regular constructors of FlinkKafkaProducer010 (5 weeks ago) * 71974895da - [FLINK-8287] [kafka] Improve Kafka producer Javadocs / doc to clarify partitioning behaviour (5 weeks ago) * c454ee3fa9 - [FLINK-8260] [kafka] Fix usage of deprecated instantiation methods in FlinkKafkaProducer docs (5 weeks ago) * 1e637c54c2 - [FLINK-8116] [DataStream] Provide proper checkpointed source function example in Javadocs (5 weeks ago) * 6884ce98f3 - [FLINK-8116] [DataStream] Fix stale comments referring to Checkpointed interface (5 weeks ago) * 4b2178677e - [FLINK-8346][docs] add v4 signature workaround for manual S3 setups (5 weeks ago) * 1c7a7fa706 - [FLINK-8331][core] FieldParser do not correctly set EMPT_COLUMN error state. (5 weeks ago) * e7395efece - [FLINK-8323] [table] Fix modulo scalar function bug (5 weeks ago) * ff8b2098b2 - [hotfix] [docs] Fix Scala code snippets in docs. (5 weeks ago) * 5cf0f57b99 - [hotfix] [docs] Remove duplicated ‘program’ in docs/dev/api_concepts.md (5 weeks ago) * 87d8dc1b0a - [FLINK-8265] Missing jackson dependency for flink-mesos (5 weeks ago) * 96051e516b - [FLINK-5506] [gelly] Fix CommunityDetection NullPointerException (6 weeks ago) * e42182d40b - [FLINK-8278] [docs] Fix Scala examples of metrics docs (var initialization). (7 weeks ago) * 47c067a592 - [FLINK-8301][table] Support Unicode in codegen for TableAPI && SQL (7 weeks ago) * 7e497f744a - [FLINK-8295] [cassandra] [build] Properly shade netty for the datastax driver (7 weeks ago) * f638deddb7 - [hotfix] [doc] Fix typo in TaskManager and EnvironmentInformation doc (8 weeks ago) * dbbaa9a4a7 - [FLINK-8249] [kinesis] Fix setting region on KinesisProducerConfiguration (8 weeks ago) * 0e27e20886 - [hotfix] [javadoc] Fix typo in StreamExecutionEnvironment javadoc (8 weeks ago) * 57de25d895 - [FLINK-8264] [core] Add ‘scala.’ to the ‘parent-first’ classloading patterns. (8 weeks ago) * 18efbea671 - [FLINK-8263] [quickstarts] Correctly set ‘flink-core’ to provided in Scala Quickstart pom.xml (8 weeks ago) * d84e215136 - [hotfix] [quickstarts] Fix indentation in Java Quickstart pom.xml (8 weeks ago) * dcd3e3ab4d - [hotfix] [quickstarts] Exclude not only slf4j api, but also bridges (8 weeks ago) * a4b401c8eb - [FLINK-8261] [quickstarts] Fix typos in exclusion patterns. (8 weeks ago) * 6981412f73 - [hotfix][javadocs] Clarify replacement for deprecated FoldingState (8 weeks ago) * d94bd7cbe5 - [hotfix] [docs] Correct version in _config.yml (8 weeks ago) * 897e6a7a89 - [FLINK-8235][build] Spotbugs exclusion file path now absolute (9 weeks ago) * b8f1744b54 - [FLINK-8145][tests] fix various IOManagerAsync instances not being shut down (9 weeks ago) * 0b024aad17 - [hotfix][javadoc] Fix typo in StreamElement javadoc (9 weeks ago) * f00e7297a5 - Update 1.4.0 doc to “stable” (9 weeks ago) * 2435fe9091 - [hotfix] [docs] Upgrade Scala version to 2.11 (9 weeks ago) * 9b63cbacec - [FLINK-7880][QS] Wait for proper resource cleanup after each ITCase. (9 weeks ago) * 415b74ce17 - [FLINK-7974][QS] Wait for QS abstract server to shutdown. (9 weeks ago) * 68b5a61aab - [FLINK-7975][QS] Wait for QS client to shutdown. (9 weeks ago)
