[08/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/6642768a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/memory/SerializedStateHandle.java -- diff --git

[09/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/6642768a/flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java -- diff --git

[04/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/6642768a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java -- diff --git

[03/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/6642768a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointFrom11MigrationITCase.java -- diff --git

[02/11] flink git commit: [FLINK-7505] Use lambdas in suppressed exception idiom

2017-08-24 Thread srichter
[FLINK-7505] Use lambdas in suppressed exception idiom Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5456cf9f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5456cf9f Diff:

[05/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/6642768a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AccumulatingAlignedProcessingTimeWindowOperatorTest.java -- diff --git

[10/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/6642768a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java -- diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java

[06/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/6642768a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java -- diff --git

[07/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/6642768a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/savepoint/MigrationV0ToV1Test.java -- diff --git

[01/11] flink git commit: [FLINK-7460] [state backends] Close all ColumnFamilyHandles when restoring from rescaled incremental checkpoints

2017-08-24 Thread srichter
Repository: flink Updated Branches: refs/heads/master 3f4de57b1 -> 6642768ad [FLINK-7460] [state backends] Close all ColumnFamilyHandles when restoring from rescaled incremental checkpoints Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[11/11] flink git commit: [FLINK-7461] Remove Backwards compatibility with <= Flink 1.1

2017-08-24 Thread srichter
[FLINK-7461] Remove Backwards compatibility with <= Flink 1.1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6642768a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6642768a Diff:

[1/2] flink git commit: [hotfix][tests] Implement AutoCloseable in TestHarness

2017-08-24 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master d21d5d632 -> 3f4de57b1 [hotfix][tests] Implement AutoCloseable in TestHarness Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/87e5b8be Tree:

[2/2] flink git commit: [hotfix][streaming] Refactor TwoPhaseCommitSinkFunctionTest

2017-08-24 Thread aljoscha
[hotfix][streaming] Refactor TwoPhaseCommitSinkFunctionTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3f4de57b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3f4de57b Diff:

flink git commit: [FLINK-7147] [cep] Support greedy quantifier in CEP

2017-08-24 Thread dwysakowicz
Repository: flink Updated Branches: refs/heads/master b3ffd919f -> d21d5d632 [FLINK-7147] [cep] Support greedy quantifier in CEP This closes #4296. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d21d5d63 Tree:

flink git commit: [hotfix] [cep] Spelling corrections

2017-08-24 Thread dwysakowicz
Repository: flink Updated Branches: refs/heads/master 3e706b13a -> b3ffd919f [hotfix] [cep] Spelling corrections Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b3ffd919 Tree: