flink git commit: [FLINK-6600] Add key serializer config snapshot to keyed backend checkpoints

Repository: flink Updated Branches: refs/heads/release-1.3 98f4fad93 -> 8b5ba676f [FLINK-6600] Add key serializer config snapshot to keyed backend checkpoints This commit adds the config snapshot of the key serializer of keyed backends to its checkpoints. This allows the oppurtunity to

flink git commit: [FLINK-6600] Add key serializer config snapshot to keyed backend checkpoints

Repository: flink Updated Branches: refs/heads/master 2bfead7d9 -> d8a467b01 [FLINK-6600] Add key serializer config snapshot to keyed backend checkpoints This commit adds the config snapshot of the key serializer of keyed backends to its checkpoints. This allows the oppurtunity to upgrade key

[1/3] flink git commit: [FLINK-6598] [table] Remove unused parameter from DataStreamGroupAggregate.

Repository: flink Updated Branches: refs/heads/release-1.3 7a045f204 -> 98f4fad93 [FLINK-6598] [table] Remove unused parameter from DataStreamGroupAggregate. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/056d9553 Tree:

[2/3] flink git commit: [FLINK-6583] [table] Add state cleanup for counting GroupWindows.

[FLINK-6583] [table] Add state cleanup for counting GroupWindows. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36cac0fb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/36cac0fb Diff:

[3/3] flink git commit: [FLINK-6589] [core] Deserialize ArrayList with capacity of size+1 to prevent growth.

[FLINK-6589] [core] Deserialize ArrayList with capacity of size+1 to prevent growth. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/98f4fad9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/98f4fad9 Diff:

[1/3] flink git commit: [FLINK-6589] [core] Deserialize ArrayList with capacity of size+1 to prevent growth.

Repository: flink Updated Branches: refs/heads/master b6afc06ab -> 2bfead7d9 [FLINK-6589] [core] Deserialize ArrayList with capacity of size+1 to prevent growth. This closes #3912. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink git commit: [FLINK-6583] [table] Add state cleanup for counting GroupWindows.

[FLINK-6583] [table] Add state cleanup for counting GroupWindows. This closes #3919. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d85d9693 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d85d9693 Diff:

flink git commit: [hotfix] Add configuration notice to HistryServer overview

Repository: flink Updated Branches: refs/heads/release-1.3 849dd9d85 -> 7a045f204 [hotfix] Add configuration notice to HistryServer overview Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a045f20 Tree:

flink git commit: [hotfix] Add configuration notice to HistryServer overview

Repository: flink Updated Branches: refs/heads/master 00ce3f1b1 -> b6afc06ab [hotfix] Add configuration notice to HistryServer overview Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b6afc06a Tree:

[2/9] flink git commit: [FLINK-6371] [cep] NFA return matched patterns as Map<String, List>.

[FLINK-6371] [cep] NFA return matched patterns as Map. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fa64a60f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fa64a60f Diff:

[6/9] flink git commit: [FLINK-6578] [cep] Fix self-loop handling in SharedBuffer.

[FLINK-6578] [cep] Fix self-loop handling in SharedBuffer. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36df9019 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/36df9019 Diff:

[4/9] flink git commit: [FLINK-6255] [cep] Remove PatternStream.getSideOutput().

[FLINK-6255] [cep] Remove PatternStream.getSideOutput(). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4560d56c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4560d56c Diff:

[9/9] flink git commit: [FLINK-6609] [cep] Fix wrong version assignment with multiple TAKEs.

[FLINK-6609] [cep] Fix wrong version assignment with multiple TAKEs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/849dd9d8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/849dd9d8 Diff:

[7/9] flink git commit: [FLINK-6604] [cep] Remove java serialization from the library.

http://git-wip-us.apache.org/repos/asf/flink/blob/d80af819/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigration11to13Test.java -- diff --git

[8/9] flink git commit: [FLINK-6604] [cep] Remove java serialization from the library.

[FLINK-6604] [cep] Remove java serialization from the library. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d80af819 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d80af819 Diff:

[1/9] flink git commit: [FLINK-6371] [cep] NFA return matched patterns as Map<String, List>.

Repository: flink Updated Branches: refs/heads/release-1.3 fe1316b33 -> 849dd9d85 http://git-wip-us.apache.org/repos/asf/flink/blob/fa64a60f/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java --

[3/9] flink git commit: [FLINK-6536] [cep] Improve error message in SharedBuffer::put().

[FLINK-6536] [cep] Improve error message in SharedBuffer::put(). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4f14e53b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4f14e53b Diff:

[5/9] flink git commit: [hotfix] [cep] Remove unused keySelector in operator.

[hotfix] [cep] Remove unused keySelector in operator. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/34a6020f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/34a6020f Diff:

[8/9] flink git commit: [FLINK-6604] [cep] Remove java serialization from the library.

[FLINK-6604] [cep] Remove java serialization from the library. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a54d05e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a54d05e Diff:

[9/9] flink git commit: [FLINK-6609] [cep] Fix wrong version assignment with multiple TAKEs.

[FLINK-6609] [cep] Fix wrong version assignment with multiple TAKEs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/00ce3f1b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/00ce3f1b Diff:

[4/9] flink git commit: [FLINK-6536] [cep] Improve error message in SharedBuffer::put().

[FLINK-6536] [cep] Improve error message in SharedBuffer::put(). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/02ea418f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/02ea418f Diff:

[7/9] flink git commit: [FLINK-6604] [cep] Remove java serialization from the library.

http://git-wip-us.apache.org/repos/asf/flink/blob/7a54d05e/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigration11to13Test.java -- diff --git

[5/9] flink git commit: [hotfix] [cep] Remove unused keySelector in operator.

[hotfix] [cep] Remove unused keySelector in operator. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7ebcb07 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7ebcb07 Diff:

[1/9] flink git commit: [FLINK-6371] [cep] NFA return matched patterns as Map<String, List>.

Repository: flink Updated Branches: refs/heads/master 9244106b3 -> 00ce3f1b1 http://git-wip-us.apache.org/repos/asf/flink/blob/ae9c9d06/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/NFAITCase.java -- diff

[6/9] flink git commit: [FLINK-6578] [cep] Fix self-loop handling in SharedBuffer.

[FLINK-6578] [cep] Fix self-loop handling in SharedBuffer. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e4db423 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8e4db423 Diff:

[3/9] flink git commit: [FLINK-6255] [cep] Remove PatternStream.getSideOutput().

[FLINK-6255] [cep] Remove PatternStream.getSideOutput(). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/05ad87f4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/05ad87f4 Diff:

[2/9] flink git commit: [FLINK-6371] [cep] NFA return matched patterns as Map<String, List>.

[FLINK-6371] [cep] NFA return matched patterns as Map. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ae9c9d06 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ae9c9d06 Diff:

flink git commit: [FLINK-6587] [table] Simplification and bug fixing of the ExpressionParser

Repository: flink Updated Branches: refs/heads/release-1.3 954a100dd -> fe1316b33 [FLINK-6587] [table] Simplification and bug fixing of the ExpressionParser This closes #3923. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-6587] [table] Simplification and bug fixing of the ExpressionParser

Repository: flink Updated Branches: refs/heads/master a2580171d -> 9244106b3 [FLINK-6587] [table] Simplification and bug fixing of the ExpressionParser This closes #3923. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink-web git commit: Remove term 'official' from docker blog post and add disclaimer

Repository: flink-web Updated Branches: refs/heads/asf-site f467722b5 -> edbd65a2e Remove term 'official' from docker blog post and add disclaimer Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/edbd65a2 Tree:

flink git commit: [FLINK-6601] [table] Use time indicators in DataStreamLogicalWindowAggregateRule

Repository: flink Updated Branches: refs/heads/release-1.3 60873b0c5 -> 954a100dd [FLINK-6601] [table] Use time indicators in DataStreamLogicalWindowAggregateRule This closes #3924. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-6601] [table] Use time indicators in DataStreamLogicalWindowAggregateRule

Repository: flink Updated Branches: refs/heads/master 7ad489d87 -> a2580171d [FLINK-6601] [table] Use time indicators in DataStreamLogicalWindowAggregateRule This closes #3924. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/5] flink git commit: [FLINK-6555] [futures] Generalize ConjunctFuture to return results

Repository: flink Updated Branches: refs/heads/master dceb5cc17 -> 7ad489d87 [FLINK-6555] [futures] Generalize ConjunctFuture to return results The ConjunctFuture now returns the set of future values once it is completed. Introduce WaitingConjunctFuture; Fix thread safety issue with

[3/5] flink git commit: [FLINK-6519] Integrate BlobStore in lifecycle management of HighAvailabilityServices

http://git-wip-us.apache.org/repos/asf/flink/blob/88b0f2ac/flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java -- diff --git

[4/5] flink git commit: [FLINK-6519] Integrate BlobStore in lifecycle management of HighAvailabilityServices

[FLINK-6519] Integrate BlobStore in lifecycle management of HighAvailabilityServices The HighAvailabilityService creates a single BlobStoreService instance which is shared by all BlobServer and BlobCache instances. The BlobStoreService's lifecycle is exclusively managed by the

[5/5] flink git commit: [FLINK-6020] Introduce BlobServer#readWriteLock to synchronize file creation and deletion

[FLINK-6020] Introduce BlobServer#readWriteLock to synchronize file creation and deletion This commit introduces a BlobServer#readWriteLock in order to synchronize file creation and deletion operations in BlobServerConnection and BlobServer. This will prevent that multiple put and get

[2/5] flink git commit: [FLINK-6284] Correct sorting of completed checkpoints in ZooKeeperStateHandleStore

[FLINK-6284] Correct sorting of completed checkpoints in ZooKeeperStateHandleStore In order to store completed checkpoints in an increasing order in ZooKeeper, the paths for the completed checkpoint is no generated by String.format("/%019d", checkpointId) instead of String.format("/%s",

[2/5] flink git commit: [FLINK-6284] Correct sorting of completed checkpoints in ZooKeeperStateHandleStore

[FLINK-6284] Correct sorting of completed checkpoints in ZooKeeperStateHandleStore In order to store completed checkpoints in an increasing order in ZooKeeper, the paths for the completed checkpoint is no generated by String.format("/%019d", checkpointId) instead of String.format("/%s",

[4/5] flink git commit: [FLINK-6519] Integrate BlobStore in lifecycle management of HighAvailabilityServices

[FLINK-6519] Integrate BlobStore in lifecycle management of HighAvailabilityServices The HighAvailabilityService creates a single BlobStoreService instance which is shared by all BlobServer and BlobCache instances. The BlobStoreService's lifecycle is exclusively managed by the

[1/5] flink git commit: [FLINK-6555] [futures] Generalize ConjunctFuture to return results

Repository: flink Updated Branches: refs/heads/release-1.3 4104409cc -> 60873b0c5 [FLINK-6555] [futures] Generalize ConjunctFuture to return results The ConjunctFuture now returns the set of future values once it is completed. Introduce WaitingConjunctFuture; Fix thread safety issue with

[3/5] flink git commit: [FLINK-6519] Integrate BlobStore in lifecycle management of HighAvailabilityServices

http://git-wip-us.apache.org/repos/asf/flink/blob/e3ea89a9/flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java -- diff --git