flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: [VOTE] Release 1.4.1, release candidate #1
Date Wed, 14 Feb 2018 16:46:02 GMT
+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 <fhueske@gmail.com> 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 <alex.gutan.m@gmail.com>:
> 
>> 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 <fhueske@gmail.com> 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 <tzulitai@apache.org>:
>>> 
>>>> Hi everyone,
>>>> 
>>>> Please review and vote on release candidate #1 for Flink 1.4.1, as
>>>> follows:
>>>> [ ] +1, Approve the release
>>>> [ ] -1, Do not approve the release (please provide specific comments)
>>>> 
>>>> The complete staging area is available for your review, which includes:
>>>> * JIRA release notes [1],
>>>> * the official Apache source release and binary convenience releases to
>>> be
>>>> deployed to dist.apache.org [2], which are signed with the key with
>>>> fingerprint 1C1E2394D3194E1944613488F320986D35C33D6A [3],
>>>> * all artifacts to be deployed to the Maven Central Repository [4],
>>>> * source code tag “release-1.4.1-rc1” [5],
>>>> * website pull request listing the new release [6].
>>>> * A complete list of all new commits in release-1.4.1-rc1, since
>>>> release-1.4.0 [7]
>>>> 
>>>> The vote will be open for at least 72 hours.
>>>> Please test the release and vote for the release candidate before
>>>> Wednesday (February 14th), 7pm CET.
>>>> It is adopted by majority approval, with at least 3 PMC affirmative
>>> votes.
>>>> 
>>>> Thanks,
>>>> Gordon
>>>> 
>>>> [1] https://issues.apache.org/jira/secure/ReleaseNote.jspa?
>>>> projectId=12315522&version=12342212
>>>> [2] http://people.apache.org/~tzulitai/flink-1.4.1-rc1/
>>>> [3] https://dist.apache.org/repos/dist/release/flink/KEYS
>>>> [4] https://repository.apache.org/content/repositories/
>>> orgapacheflink-1145
>>>> [5] https://git-wip-us.apache.org/repos/asf?p=flink.git;a=commit;h=
>>>> dbab73e5d097518838283a7a4f056cca0ac3f9a5
>>>> [6] https://github.com/apache/flink-web/pull/101
>>>> 
>>>> [7]
>>>> * dbab73e5d0 - Commit for release 1.4.1 (17 hours ago)
>>>> * beff62d2e6 - [FLINK-8571] [DataStream] Introduce utility function
>> that
>>>> reinterprets a data stream as keyed stream (backport from 1.5 branch)
>> (17
>>>> hours ago)
>>>> * 33ebc85c28 - [FLINK-8362] [elasticsearch] Further improvements for
>>>> Elasticsearch connector shading (2 days ago)
>>>> * 0c53e798cb - [FLINK-8362][elasticsearch] shade all dependencies (2
>> days
>>>> ago)
>>>> * 5f9e367be6 - [FLINK-7760] Fix deserialization of NFA state in CEP
>>>> library (3 days ago)
>>>> * 82f3957811 - [FLINK-8275] [security, yarn] Remove test-specific code
>>>> path in YarnTaskManagerRunner (4 days ago)
>>>> * 20146652ba - [FLINK-8275] [security, yarn] Fix keytab local path in
>>>> YarnTaskManagerRunner (4 days ago)
>>>> * fb1e24e25e - [FLINK-8421] [test] Increase MAX_MEM_STATE_SIZE and Akka
>>>> framesize in AbstractEventTimeWindowCheckpointingITCase (4 days ago)
>>>> * 71d682eb7f - [FLINK-8421] [DataStream] Make timer serializers
>>>> reconfigurable on restore (4 days ago)
>>>> * 93d514e628 - [FLINK-8421] [core] Introduce
>>> PostVersionedIOReadableWritable
>>>> (4 days ago)
>>>> * 319d510174 - [FLINK-8421] [core] Allow InstantiationUtil.
>>> deserializeObject()
>>>> to use FailureTolerantObjectInputStream (4 days ago)
>>>> * 1f81f6acf4 - [FLINK-8421] [DataStream, tests] Add WindowOperator
>>>> migration test for Kryo-serialized window keys (4 days ago)
>>>> * e41300d5a9 - [hotfix] [test] Remove stale savepoint files no longer
>>> used
>>>> by migration tests (4 days ago)
>>>> * f68fe3ee65 - [FLINK-8472] [tests] Extend
>> 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)
>>>> 
>>>> 
>>> 
>> 


Mime
View raw message