Hi, I check the diff between Flink 1.4.0 and Flink 1.4.1-RC1 for added/changed dependencies. I only found a version update of the Snappy dependency. Both, the previous and the new version, are ASL so this is fine.
The signatures and hashes are OK. I also built the binary release and found no issues, i.e., mvn -DskipTests clean install finished successfully. +1 (binding) to release RC1 @Gordon, thanks for taking care of the release! Best, Fabian 2018-02-10 15:21 GMT+01:00 Tzu-Li (Gordon) Tai <tzuli...@apache.org>: > 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) > >
