[1/5] flink git commit: [FLINK-5869] [flip-1] Add basic abstraction for Failover Strategies to ExecutionGraph

Repository: flink Updated Branches: refs/heads/master 821ec80d7 -> 8ed85fe49 http://git-wip-us.apache.org/repos/asf/flink/blob/8ed85fe4/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/GlobalModVersionTest.java

[5/5] flink git commit: [FLINK-6312] [build] Update curator version to 2.12.0

[FLINK-6312] [build] Update curator version to 2.12.0 The updated curator version includes a bugfix for a potential block Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aadfe45a Tree:

[4/5] flink git commit: [FLINK-6340] [flip-1] Add a termination future to the Execution

[FLINK-6340] [flip-1] Add a termination future to the Execution Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e0061272 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e0061272 Diff:

[2/5] flink git commit: [FLINK-5869] [flip-1] Add basic abstraction for Failover Strategies to ExecutionGraph

http://git-wip-us.apache.org/repos/asf/flink/blob/8ed85fe4/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala -- diff --git

[3/5] flink git commit: [FLINK-5869] [flip-1] Add basic abstraction for Failover Strategies to ExecutionGraph

[FLINK-5869] [flip-1] Add basic abstraction for Failover Strategies to ExecutionGraph - Rename 'ExecutionGraph.fail()' to 'ExecutionGraph.failGlobally()' to differentiate from fine grained failures/recovery - Add base class for FailoverStrategy - Add default implementation (restart all

[01/13] flink git commit: [FLINK-5969] Fix restore from empty state in KafkaConsumerBase

Repository: flink Updated Branches: refs/heads/master 72dfce40b -> 821ec80d7 [FLINK-5969] Fix restore from empty state in KafkaConsumerBase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ecb5d00 Tree:

[05/13] flink git commit: [FLINK-5969] Add OperatorSnapshotUtil

[FLINK-5969] Add OperatorSnapshotUtil This has methods for storing/reading OperatorStateHandles, as returned from stream operator test harnesses. This can be used to write binary snapshots for use in state migration tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[13/13] flink git commit: [FLINK-5969] Add CEPFrom12MigrationTest

[FLINK-5969] Add CEPFrom12MigrationTest The binary snapshots have been created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/821ec80d Tree:

[11/13] flink git commit: [FLINK-5969] Add KafkaConsumerBaseFrom12MigrationTest

[FLINK-5969] Add KafkaConsumerBaseFrom12MigrationTest The binary snapshots were created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e40f2e18 Tree:

[06/13] flink git commit: [FLINK-5969] Augment SavepointMigrationTestBase to catch failed jobs

[FLINK-5969] Augment SavepointMigrationTestBase to catch failed jobs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1882c905 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1882c905 Diff:

[09/13] flink git commit: [FLINK-5969] Add WindowOperatorFrom12MigrationTest

http://git-wip-us.apache.org/repos/asf/flink/blob/2c6377f2/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java -- diff --git

[04/13] flink git commit: [FLINK-5969] Remove watermark callback service

[FLINK-5969] Remove watermark callback service In Flink 1.2 we only wrote timers to key-grouped state streams. With the addition of the watermark callback service we started to also write the watermark callbacks to the key-grouped streams. This breaks backwards compatibility with saveoints taken

[08/13] flink git commit: [FLINK-5969] Add BucketingSinkFrom12MigrationTest

[FLINK-5969] Add BucketingSinkFrom12MigrationTest The binary snapshots have been created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fb7793f0 Tree:

[02/13] flink git commit: [FLINK-5969] Add ContinuousFileProcessingFrom12MigrationTest

[FLINK-5969] Add ContinuousFileProcessingFrom12MigrationTest The binary snapshots were created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/44e472f6 Tree:

[12/13] flink git commit: [FLINK-5969] Also snapshot legacy state in operator test harness

[FLINK-5969] Also snapshot legacy state in operator test harness Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/84eea722 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/84eea722 Diff:

[10/13] flink git commit: [FLINK-5969] Add WindowOperatorFrom12MigrationTest

[FLINK-5969] Add WindowOperatorFrom12MigrationTest The binary snapshots for this were created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c6377f2 Tree:

[07/13] flink git commit: [FLINK-5969] Add savepoint IT case that checks restore from 1.2

[FLINK-5969] Add savepoint IT case that checks restore from 1.2 The binary savepoints in this were created on the Flink 1.2.0 release commit. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9ed98f2e Tree:

[03/13] flink git commit: [FLINK-6353] Fix legacy user-state restore from 1.2

[FLINK-6353] Fix legacy user-state restore from 1.2 State that was checkpointed using Checkpointed (on a user function) could be restored using CheckpointedRestoring when the savepoint was done on Flink 1.2. The reason was an overzealous check in AbstractUdfStreamOperator that only restores from

[1/2] flink git commit: [FLINK-4604] [table] Clean-ups, improved Sum0 aggregation, simplified tests and bug fixing

Repository: flink Updated Branches: refs/heads/master 6d0c4c340 -> 72dfce40b [FLINK-4604] [table] Clean-ups, improved Sum0 aggregation, simplified tests and bug fixing Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-4604] [table] Add support for standard deviation/variance

[FLINK-4604] [table] Add support for standard deviation/variance This closes #3260. Old PR: This closes #2762. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0af57fc1 Tree:

flink git commit: [FLINK-6427] Ensure file length is flushed in StreamWriterBase

Repository: flink Updated Branches: refs/heads/master 6181302f1 -> 6d0c4c340 [FLINK-6427] Ensure file length is flushed in StreamWriterBase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d0c4c34 Tree:

[39/50] [abbrv] flink git commit: [hotfix] [runtime] SerializedThrowable copy constructor preserves cause

[hotfix] [runtime] SerializedThrowable copy constructor preserves cause Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/03721cff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/03721cff Diff:

[16/50] [abbrv] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java -- diff --git

[29/50] [abbrv] flink git commit: [FLINK-6337][network] Remove the buffer provider from PartitionRequestServerHandler

[FLINK-6337][network] Remove the buffer provider from PartitionRequestServerHandler The buffer provider is not needed and most likely a left over from prior refactorings. This closes #3785. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[35/50] [abbrv] flink git commit: [hotfix] [build] Remove unneeded logback-test.xml files

[hotfix] [build] Remove unneeded logback-test.xml files Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bad7e0b9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bad7e0b9 Diff:

[45/50] [abbrv] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

http://git-wip-us.apache.org/repos/asf/flink/blob/856485be/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/TableEnvironmentITCase.scala -- diff --git

[22/50] [abbrv] flink git commit: [FLINK-6406] [table] Remove unused imports

[FLINK-6406] [table] Remove unused imports This closes #3795 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ea54962e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ea54962e Diff:

[50/50] [abbrv] flink git commit: [FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction.

[FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e265620d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e265620d

[15/50] [abbrv] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java -- diff --git

[46/50] [abbrv] flink git commit: [FLINK-6091] [table] Implement and turn on retraction for non-windowed aggregates.

http://git-wip-us.apache.org/repos/asf/flink/blob/856485be/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/CRowWrappingCollector.scala -- diff --git

[41/50] [abbrv] flink git commit: [FLINK-2067] [runtime] Unwrap the ExceptionInChainedOperatorException exceptions to clean up stack traces

[FLINK-2067] [runtime] Unwrap the ExceptionInChainedOperatorException exceptions to clean up stack traces Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6181302f Tree:

[31/50] [abbrv] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

http://git-wip-us.apache.org/repos/asf/flink/blob/2d33c0be/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java -- diff --git

[05/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTest.java -- diff --git

[38/50] [abbrv] flink git commit: [hotfix] [runtime] Minor improvement to logging in CheckpointCoordinator

[hotfix] [runtime] Minor improvement to logging in CheckpointCoordinator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/91b2d6f3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/91b2d6f3 Diff:

[10/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Make slot registration static

[FLINK-5810] [flip-6] Make slot registration static Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d16a5a29 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d16a5a29 Diff:

[34/50] [abbrv] flink git commit: [FLINK-6415] [build] Make sure core Flink artifacts have no specific logger dependency

[FLINK-6415] [build] Make sure core Flink artifacts have no specific logger dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e0ba2687 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e0ba2687 Diff:

[07/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

[FLINK-5810] [flip-6] Introduce a hardened slot manager Harden the slot manager so that it better deals with lost and out of order messages from the TaskManager. The basic idea is that the TaskManager are considered the ground truth and the SlotManager tries to maintain a consistent view of

[04/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java -- diff --git

[18/50] [abbrv] flink git commit: [Flink-5892] Restore state on operator level

[Flink-5892] Restore state on operator level Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7980a7e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7980a7e Diff:

[26/50] [abbrv] flink git commit: [FLINK-6377] [table] Support map types in the Table / SQL API

[FLINK-6377] [table] Support map types in the Table / SQL API This closes #3767. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b6e71ce Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5b6e71ce Diff:

[25/50] [abbrv] flink git commit: [FLINK-6377] [table] Add additional map tests

[FLINK-6377] [table] Add additional map tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d49efbd2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d49efbd2 Diff:

[19/50] [abbrv] flink git commit: [FLINK-5892] Add tests for topology modifications

[FLINK-5892] Add tests for topology modifications This closes #3770. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c68085f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2c68085f Diff:

[02/50] [abbrv] flink git commit: [FLINK-6208] [cep] Implement skip till next match strategy

[FLINK-6208] [cep] Implement skip till next match strategy Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7c35dc0e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7c35dc0e Diff:

[30/50] [abbrv] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

http://git-wip-us.apache.org/repos/asf/flink/blob/2d33c0be/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/WindowAggregateTest.scala -- diff --git

[21/50] [abbrv] flink git commit: [FLINK-6395] [tests] Mark test bases as abstract

[FLINK-6395] [tests] Mark test bases as abstract This closes #3790 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d27d3dda Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d27d3dda Diff:

[11/50] [abbrv] flink git commit: [FLINK-6411] [flip-6] Remove job removal from RunningJobsRegistry in YarnFlinkApplicationMasterRunner.shutdown

[FLINK-6411] [flip-6] Remove job removal from RunningJobsRegistry in YarnFlinkApplicationMasterRunner.shutdown The YarnFlinkApplicationMasterRunner should not be concerned with removing jobs from the RunningJobsRegistry. This is the responsibility of the JobManagerRunner. This PR removes the

[06/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Introduce a hardened slot manager

http://git-wip-us.apache.org/repos/asf/flink/blob/59aefb57/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java -- diff --git

[49/50] [abbrv] flink git commit: [FLINK-6093] [table] Add stream TableSinks and DataStream conversion with support for retraction.

http://git-wip-us.apache.org/repos/asf/flink/blob/e265620d/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sinks/RetractStreamTableSink.scala -- diff --git

[42/50] [abbrv] flink git commit: [FLINK-6090] [table] Add RetractionRules for annotating AccMode to DataStreamRel nodes.

[FLINK-6090] [table] Add RetractionRules for annotating AccMode to DataStreamRel nodes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/455a3c58 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/455a3c58 Diff:

[40/50] [abbrv] flink git commit: [hotfix] [client] Unwrap SerializedThrowable in client log statements when possible

[hotfix] [client] Unwrap SerializedThrowable in client log statements when possible Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9623be2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c9623be2 Diff:

[14/50] [abbrv] flink git commit: [FLINK-5892] Add new StateAssignmentOperationV2

[FLINK-5892] Add new StateAssignmentOperationV2 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8045faba Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8045faba Diff:

[48/50] [abbrv] flink git commit: [FLINK-6093] [table] Implement and turn on retraction for table sinks.

[FLINK-6093] [table] Implement and turn on retraction for table sinks. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/917f7249 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/917f7249 Diff:

[03/50] [abbrv] flink git commit: [FLINK-6293] [tests] Harden JobManagerITCase

[FLINK-6293] [tests] Harden JobManagerITCase One of the unit tests in JobManagerITCase starts a MiniCluster and sends a LeaderSessionMessage to the JobManager without waiting until the JobManager has gained leadership. This can lead to a dropped TriggerSavepoint message which will cause the test

[23/50] [abbrv] flink git commit: [FLINK-6112] [table] Support Calcite 1.12's new numerical functions

[FLINK-6112] [table] Support Calcite 1.12's new numerical functions This closes #3718. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a06b3222 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a06b3222 Diff:

[44/50] [abbrv] flink git commit: [FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams.

[FLINK-6216] [table] Add non-windowed GroupBy aggregation for streams. This closes #3646. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24fa1a1c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24fa1a1c Diff:

[33/50] [abbrv] flink git commit: [FLINK-6337] [network] Fix instability in SuccessAfterNetworkBuffersFailureITCase

[FLINK-6337] [network] Fix instability in SuccessAfterNetworkBuffersFailureITCase The reduced number of network buffers as part of this issue was too low and lead to instable tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[32/50] [abbrv] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

[FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly This closes #3799. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2d33c0be Tree:

[28/50] [abbrv] flink git commit: [FLINK-6382] [gelly] Support additional types for generated graphs in Gelly examples

[FLINK-6382] [gelly] Support additional types for generated graphs in Gelly examples The Gelly examples current support IntValue, LongValue, and StringValue for RMatGraph. Allow transformations and tests for all generated graphs for ByteValue, Byte, ShortValue, Short, CharValue, Character,

[08/50] [abbrv] flink git commit: [FLINK-5810] [flip-6] Multiple small cleanups across Resource Manager related code

[FLINK-5810] [flip-6] Multiple small cleanups across Resource Manager related code Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/759f46ea Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/759f46ea Diff:

[20/50] [abbrv] flink git commit: [FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table.

[FLINK-6059] [table] Reject GenericType when converting DataSet or DataStream to Table. This closes #3546. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c8eb55f1 Tree:

[13/50] [abbrv] flink git commit: [FLINK-6341] [jm] Add test case to guard against RM registration loop

[FLINK-6341] [jm] Add test case to guard against RM registration loop Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/591841f3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/591841f3 Diff:

[27/50] [abbrv] flink git commit: [FLINK-6382] [gelly] Support additional types for generated graphs in Gelly examples

http://git-wip-us.apache.org/repos/asf/flink/blob/33695781/flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/GraphMetricsITCase.java -- diff --git

[01/50] [abbrv] flink git commit: [FLINK-6208] [cep] Implement skip till next match strategy [Forced Update!]

Repository: flink Updated Branches: refs/heads/table-retraction b237a3ef0 -> e265620d4 (forced update) http://git-wip-us.apache.org/repos/asf/flink/blob/7c35dc0e/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java

[36/50] [abbrv] flink git commit: [hotfix] [tests] Fix test log level in flink-runtime

[hotfix] [tests] Fix test log level in flink-runtime Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9cb76213 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9cb76213 Diff:

[24/50] [abbrv] flink git commit: [FLINK-6112] [table] Improve documentation, consistency, and fix bugs

[FLINK-6112] [table] Improve documentation, consistency, and fix bugs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a334312 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0a334312 Diff:

[17/50] [abbrv] flink git commit: [Flink-5892] Restore state on operator level

http://git-wip-us.apache.org/repos/asf/flink/blob/f7980a7e/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperationV2.java -- diff --git

[12/50] [abbrv] flink git commit: [FLINK-6341] [jm] Don't let JM fall into infinite loop

[FLINK-6341] [jm] Don't let JM fall into infinite loop This closes #3745. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/23838392 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/23838392 Diff:

[09/11] flink git commit: [FLINK-5969] Add WindowOperatorFrom12MigrationTest

[FLINK-5969] Add WindowOperatorFrom12MigrationTest The binary snapshots for this were created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9ba4f03 Tree:

[01/11] flink git commit: [FLINK-6353] Fix legacy user-state restore from 1.2

Repository: flink Updated Branches: refs/heads/release-1.2 fdb3f65f2 -> 852a710b4 [FLINK-6353] Fix legacy user-state restore from 1.2 State that was checkpointed using Checkpointed (on a user function) could not be restored using CheckpointedRestoring when the savepoint was done on Flink 1.2.

[05/11] flink git commit: [FLINK-5969] Add savepoint IT case that checks restore from 1.2

[FLINK-5969] Add savepoint IT case that checks restore from 1.2 The binary savepoints in this were created on the Flink 1.2.0 release commit. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/52fb5789 Tree:

[06/11] flink git commit: [FLINK-5969] Also snapshot legacy state in operator test harness

[FLINK-5969] Also snapshot legacy state in operator test harness Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c89d4b43 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c89d4b43 Diff:

[08/11] flink git commit: [FLINK-5969] Add WindowOperatorFrom12MigrationTest

http://git-wip-us.apache.org/repos/asf/flink/blob/c9ba4f03/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java -- diff --git

[04/11] flink git commit: [FLINK-5969] Add OperatorSnapshotUtil

[FLINK-5969] Add OperatorSnapshotUtil This has methods for storing/reading OperatorStateHandles, as returned from stream operator test harnesses. This can be used to write binary snapshots for use in state migration tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[03/11] flink git commit: [FLINK-5969] Add ContinuousFileProcessingFrom12MigrationTest

[FLINK-5969] Add ContinuousFileProcessingFrom12MigrationTest The binary snapshots were created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/62601b49 Tree:

[11/11] flink git commit: [FLINK-5969] Add CEPFrom12MigrationTest

[FLINK-5969] Add CEPFrom12MigrationTest The binary snapshots have been created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/852a710b Tree:

[10/11] flink git commit: [FLINK-5969] Add BucketingSinkFrom12MigrationTest

[FLINK-5969] Add BucketingSinkFrom12MigrationTest The binary snapshots have been created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/53432e06 Tree:

[02/11] flink git commit: [FLINK-5969] Augment SavepointMigrationTestBase to catch failed jobs

[FLINK-5969] Augment SavepointMigrationTestBase to catch failed jobs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a3ccffcb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a3ccffcb Diff:

[07/11] flink git commit: [FLINK-5969] Add KafkaConsumerBaseFrom12MigrationTest

[FLINK-5969] Add KafkaConsumerBaseFrom12MigrationTest The binary snapshots were created on the Flink 1.2 branch. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c43fc2a1 Tree: