[VOTE] Release 1.4.1, release candidate #1

[Tzu-Li (Gordon) Tai]

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)

[Fabian Hueske-2]

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 <[hidden email]>:

> 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)
>
>

[Alexx]

Hi everyone,

Is [FLINK-6352] [kafka] Timestamp-based offset configuration for
FlinkKafkaConsumer <https://github.com/apache/flink/pull/5282> going to
make it into 1.4.1? Or it's left for 1.5?

Best,
Alex.

On 13 February 2018 at 19:05, Fabian Hueske <[hidden email]> wrote:

> 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 <[hidden email]>:
>
> > 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 AbstractOperatorRestoreTestBas
> es
> > 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 DataSetAggregateWithNullValues
> Rule.
> > (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)
> >
> >
>

[Fabian Hueske-2]

Hi Alex,

FLINK-6352 seems to be an improvement / new feature.
These are included in minor releases like 1.5.0 but not in bug fix releases
such as 1.4.1.

Best, Fabian

2018-02-13 19:08 GMT+01:00 Alexandru Gutan <[hidden email]>:

> Hi everyone,
>
> Is [FLINK-6352] [kafka] Timestamp-based offset configuration for
> FlinkKafkaConsumer <https://github.com/apache/flink/pull/5282> going to
> make it into 1.4.1? Or it's left for 1.5?
>
> Best,
> Alex.
>
> On 13 February 2018 at 19:05, Fabian Hueske <[hidden email]> wrote:
>
> > 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 <[hidden email]>:
> >
> > > 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
> AbstractOperatorRestoreTestBas
> > es
> > > 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
> DataSetAggregateWithNullValues
> > Rule.
> > > (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)
> > >
> > >
> >
>

[Aljoscha Krettek-2]

+1 (binding)

 - I checked the signatures and hashes
 - I ran a cluster and tried some example programs
 - I checked the list of all changes: we're good, legally, and the other changes also all look good

The only thing I'm not sure about is the Network Buffer changes but I don't think they make things worse.

Best,
Aljoscha

> On 13. Feb 2018, at 19:19, Fabian Hueske <[hidden email]> wrote:
>
> Hi Alex,
>
> FLINK-6352 seems to be an improvement / new feature.
> These are included in minor releases like 1.5.0 but not in bug fix releases
> such as 1.4.1.
>
> Best, Fabian
>
> 2018-02-13 19:08 GMT+01:00 Alexandru Gutan <[hidden email]>:
>
>> Hi everyone,
>>
>> Is [FLINK-6352] [kafka] Timestamp-based offset configuration for
>> FlinkKafkaConsumer <https://github.com/apache/flink/pull/5282> going to
>> make it into 1.4.1? Or it's left for 1.5?
>>
>> Best,
>> Alex.
>>
>> On 13 February 2018 at 19:05, Fabian Hueske <[hidden email]> wrote:
>>
>>> 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 <[hidden email]>:
>>>
>>>> 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
>> AbstractOperatorRestoreTestBas
>>> es
>>>> 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
>> DataSetAggregateWithNullValues
>>> Rule.
>>>> (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)
>>>>
>>>>
>>>
>>

[Timo Walther-2]

+1 (binding)

- I scanned the changes
- Run some example table programs

Looks good from my side.

Regards,
Timo


Am 2/14/18 um 5:46 PM schrieb Aljoscha Krettek:

> +1 (binding)
>
>   - I checked the signatures and hashes
>   - I ran a cluster and tried some example programs
>   - I checked the list of all changes: we're good, legally, and the other changes also all look good
>
> The only thing I'm not sure about is the Network Buffer changes but I don't think they make things worse.
>
> Best,
> Aljoscha
>
>> On 13. Feb 2018, at 19:19, Fabian Hueske <[hidden email]> wrote:
>>
>> Hi Alex,
>>
>> FLINK-6352 seems to be an improvement / new feature.
>> These are included in minor releases like 1.5.0 but not in bug fix releases
>> such as 1.4.1.
>>
>> Best, Fabian
>>
>> 2018-02-13 19:08 GMT+01:00 Alexandru Gutan <[hidden email]>:
>>
>>> Hi everyone,
>>>
>>> Is [FLINK-6352] [kafka] Timestamp-based offset configuration for
>>> FlinkKafkaConsumer <https://github.com/apache/flink/pull/5282> going to
>>> make it into 1.4.1? Or it's left for 1.5?
>>>
>>> Best,
>>> Alex.
>>>
>>> On 13 February 2018 at 19:05, Fabian Hueske <[hidden email]> wrote:
>>>
>>>> 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 <[hidden email]>:
>>>>
>>>>> 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
>>> AbstractOperatorRestoreTestBas
>>>> es
>>>>> 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
>>> DataSetAggregateWithNullValues
>>>> Rule.
>>>>> (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)
>>>>>
>>>>>

[Tzu-Li (Gordon) Tai]

+1 (binding)

- Built from source, tests pass.
- Tested the now shaded Elasticsearch Connector on a cluster execution. Logs are correctly forwarded to TM logs. Checked that all dependencies are correctly shaded.
- Successfully restored a window operator job’s savepoint from 1.3.2 in 1.4.1.
- Kerberos on YARN using keytabs working without issues
- List of staged sources / binaries look good. No staged Maven artifacts is missing.

Regarding the Network Buffer changes:
I ran the usual chaos monkey test we do for major releases on AWS, but modified so that the job fails randomly on some message (instead of shooting down TMs).
Everything seems to be working without issues, so I assume we’re good to go on this front.

Cheers,
Gordon
On 15 February 2018 at 12:57:14 AM, Timo Walther ([hidden email]) wrote:

+1 (binding)  

- I scanned the changes  
- Run some example table programs  

Looks good from my side.  

Regards,  
Timo  


Am 2/14/18 um 5:46 PM schrieb Aljoscha Krettek:  

> +1 (binding)  
>  
> - I checked the signatures and hashes  
> - I ran a cluster and tried some example programs  
> - I checked the list of all changes: we're good, legally, and the other changes also all look good  
>  
> The only thing I'm not sure about is the Network Buffer changes but I don't think they make things worse.  
>  
> Best,  
> Aljoscha  
>  
>> On 13. Feb 2018, at 19:19, Fabian Hueske <[hidden email]> wrote:  
>>  
>> Hi Alex,  
>>  
>> FLINK-6352 seems to be an improvement / new feature.  
>> These are included in minor releases like 1.5.0 but not in bug fix releases  
>> such as 1.4.1.  
>>  
>> Best, Fabian  
>>  
>> 2018-02-13 19:08 GMT+01:00 Alexandru Gutan <[hidden email]>:  
>>  
>>> Hi everyone,  
>>>  
>>> Is [FLINK-6352] [kafka] Timestamp-based offset configuration for  
>>> FlinkKafkaConsumer <https://github.com/apache/flink/pull/5282> going to  
>>> make it into 1.4.1? Or it's left for 1.5?  
>>>  
>>> Best,  
>>> Alex.  
>>>  
>>> On 13 February 2018 at 19:05, Fabian Hueske <[hidden email]> wrote:  
>>>  
>>>> 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 <[hidden email]>:  
>>>>  
>>>>> 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  
>>> AbstractOperatorRestoreTestBas  
>>>> es  
>>>>> 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  
>>> DataSetAggregateWithNullValues  
>>>> Rule.  
>>>>> (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)  
>>>>>  
>>>>>  

[Tzu-Li Tai]

The voting time has passed and I'm happy to announce that we've collected
enough votes to release this RC as Flink 1.4.1.

+1 votes:
- Fabian (binding)
- Aljoscha (binding)
- Timo (binding)
- Gordon (binding)

That's 4 votes, 4 binding. No 0 or -1 votes.

Thanks to everyone who has contributed the release and efforts in verifying
it!
I'll send out a separate announcement mail, after the artifacts / sources
and binaries are pushed.



--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[Fabian Hueske-2]

Thanks Gordon for managing the release!

2018-02-15 13:22 GMT+01:00 Tzu-Li Tai <[hidden email]>:

> The voting time has passed and I'm happy to announce that we've collected
> enough votes to release this RC as Flink 1.4.1.
>
> +1 votes:
> - Fabian (binding)
> - Aljoscha (binding)
> - Timo (binding)
> - Gordon (binding)
>
> That's 4 votes, 4 binding. No 0 or -1 votes.
>
> Thanks to everyone who has contributed the release and efforts in verifying
> it!
> I'll send out a separate announcement mail, after the artifacts / sources
> and binaries are pushed.
>
>
>
> --
> Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
>

[Till Rohrmann]

Thanks Gordon for being the release manager. Also thanks to the community
for all the work which went into Flink 1.4.1.

Cheers,
Till

On Thu, Feb 15, 2018 at 1:57 PM, Fabian Hueske <[hidden email]> wrote:

> Thanks Gordon for managing the release!
>
> 2018-02-15 13:22 GMT+01:00 Tzu-Li Tai <[hidden email]>:
>
> > The voting time has passed and I'm happy to announce that we've collected
> > enough votes to release this RC as Flink 1.4.1.
> >
> > +1 votes:
> > - Fabian (binding)
> > - Aljoscha (binding)
> > - Timo (binding)
> > - Gordon (binding)
> >
> > That's 4 votes, 4 binding. No 0 or -1 votes.
> >
> > Thanks to everyone who has contributed the release and efforts in
> verifying
> > it!
> > I'll send out a separate announcement mail, after the artifacts / sources
> > and binaries are pushed.
> >
> >
> >
> > --
> > Sent from: http://apache-flink-mailing-list-archive.1008284.n3.
> nabble.com/
> >
>