[1/4] flink git commit: [FLINK-6612] Allow ZooKeeperStateHandleStore to lock created ZNodes

2017-05-19 Thread srichter
Repository: flink Updated Branches: refs/heads/release-1.3 0963718ac -> f62004079 http://git-wip-us.apache.org/repos/asf/flink/blob/f58fec70/flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStoreTest.java

[3/4] flink git commit: [FLINK-6633] Register shared state before adding to CompletedCheckpointStore

2017-05-19 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/f6200407/flink-runtime/src/test/java/org/apache/flink/runtime/state/IncrementalKeyedStateHandleTest.java -- diff --git

[4/4] flink git commit: [FLINK-6633] Register shared state before adding to CompletedCheckpointStore

2017-05-19 Thread srichter
[FLINK-6633] Register shared state before adding to CompletedCheckpointStore Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f6200407 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f6200407 Diff:

[1/4] flink git commit: [FLINK-6633] Register shared state before adding to CompletedCheckpointStore

2017-05-19 Thread srichter
Repository: flink Updated Branches: refs/heads/master b8f8524af -> 0162543ac http://git-wip-us.apache.org/repos/asf/flink/blob/0162543a/flink-runtime/src/test/java/org/apache/flink/runtime/state/IncrementalKeyedStateHandleTest.java

[3/4] flink git commit: [FLINK-6612] Allow ZooKeeperStateHandleStore to lock created ZNodes

2017-05-19 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/3d119e11/flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStoreTest.java -- diff --git

flink git commit: [FLINK-6582] [docs] Project from maven archetype is not buildable by default

2017-05-19 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 0162543ac -> 6ae759ae5 [FLINK-6582] [docs] Project from maven archetype is not buildable by default The pom.xml for flink-quickstart-java and flink-quickstart-scala must specify scala.version and scala.binary.version. This closes #3910

[4/4] flink git commit: [FLINK-6612] Allow ZooKeeperStateHandleStore to lock created ZNodes

2017-05-19 Thread srichter
[FLINK-6612] Allow ZooKeeperStateHandleStore to lock created ZNodes In order to guard against deletions of ZooKeeper nodes which are still being used by a different ZooKeeperStateHandleStore, we have to introduce a locking mechanism. Only after all ZooKeeperStateHandleStores have released their

flink git commit: [FLINK-6582] [docs] Project from maven archetype is not buildable by default

2017-05-19 Thread rmetzger
Repository: flink Updated Branches: refs/heads/release-1.3 f62004079 -> d1cff3ae3 [FLINK-6582] [docs] Project from maven archetype is not buildable by default The pom.xml for flink-quickstart-java and flink-quickstart-scala must specify scala.version and scala.binary.version. This closes

buildbot failure in on flink-docs-master

2017-05-19 Thread buildbot
The Buildbot has detected a new failure on builder flink-docs-master while building . Full details are available at: https://ci.apache.org/builders/flink-docs-master/builds/717 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: The Nightly

buildbot failure in on flink-docs-release-1.2

2017-05-19 Thread buildbot
The Buildbot has detected a new failure on builder flink-docs-release-1.2 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.2/builds/124 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The

buildbot failure in on flink-docs-release-1.1

2017-05-19 Thread buildbot
The Buildbot has detected a new failure on builder flink-docs-release-1.1 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.1/builds/300 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: The

buildbot failure in on flink-docs-release-0.9

2017-05-19 Thread buildbot
The Buildbot has detected a new failure on builder flink-docs-release-0.9 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.9/builds/695 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The

buildbot failure in on flink-docs-release-1.0

2017-05-19 Thread buildbot
The Buildbot has detected a new failure on builder flink-docs-release-1.0 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.0/builds/454 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: The

flink git commit: [FLINK-6634] [cep] NFASerializer serializes ComputationState counter.

2017-05-19 Thread kkloudas
Repository: flink Updated Branches: refs/heads/release-1.3 f6a596fe3 -> c62553c00 [FLINK-6634] [cep] NFASerializer serializes ComputationState counter. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c62553c0 Tree:

[2/2] flink git commit: [FLINK-6606] Hide WrapperMasterHook by making it private

2017-05-19 Thread trohrmann
[FLINK-6606] Hide WrapperMasterHook by making it private Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f6a596fe Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f6a596fe Diff:

[1/2] flink git commit: [FLINK-6606] Set UserCodeClassLoader as TCCL for MasterTriggerRestoreHook

2017-05-19 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-1.3 6d178a959 -> f6a596fe3 [FLINK-6606] Set UserCodeClassLoader as TCCL for MasterTriggerRestoreHook - wrap calls to MasterTriggerRestoreHook (and its factory) such that the user classloader is applied This closes #3933. Project:

flink git commit: [FLINK-6574] [table] Support nested catalogs in ExternalCatalog.

2017-05-19 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.3 d1cff3ae3 -> 6d178a959 [FLINK-6574] [table] Support nested catalogs in ExternalCatalog. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d178a95 Tree:

[1/2] flink git commit: [FLINK-6606] Hide WrapperMasterHook by making it private

2017-05-19 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master acea4cde5 -> 8814ba767 [FLINK-6606] Hide WrapperMasterHook by making it private Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8814ba76 Tree:

[2/2] flink git commit: [FLINK-6606] Set UserCodeClassLoader as TCCL for MasterTriggerRestoreHook

2017-05-19 Thread trohrmann
[FLINK-6606] Set UserCodeClassLoader as TCCL for MasterTriggerRestoreHook - wrap calls to MasterTriggerRestoreHook (and its factory) such that the user classloader is applied This closes #3933. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[5/5] flink git commit: [FLINK-5636][metrics] Measure numRecordsIn in StreamTwoInputProcessor

2017-05-19 Thread chesnay
[FLINK-5636][metrics] Measure numRecordsIn in StreamTwoInputProcessor This closes #3950. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ccaffe3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8ccaffe3 Diff:

[4/5] flink git commit: [FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil

2017-05-19 Thread chesnay
[FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil This closes #3904. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/65fdadac Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/65fdadac Diff:

[2/5] flink git commit: [FLINK-6639][docs] fix code tabs in CEP docs

2017-05-19 Thread chesnay
[FLINK-6639][docs] fix code tabs in CEP docs This closes #3952. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fadc026b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fadc026b Diff:

[3/5] flink git commit: [FLINK-6586] InputGateMetrics return 0 as min for local channels

2017-05-19 Thread chesnay
[FLINK-6586] InputGateMetrics return 0 as min for local channels This closes #3907. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17ec6f02 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17ec6f02 Diff:

[1/5] flink git commit: [hotfix][rat] Add exclusion for all test snapshots/savepoints

2017-05-19 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 8e3213678 -> 65fdadac8 [hotfix][rat] Add exclusion for all test snapshots/savepoints This closes #3854. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4b485307 Tree:

[4/6] flink git commit: [FLINK-6288] [kafka] Cleanup and improvements to FlinkKafkaPartitioner custom partitioning

2017-05-19 Thread tzulitai
http://git-wip-us.apache.org/repos/asf/flink/blob/e3fcbb08/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java -- diff --git

[1/6] flink git commit: [hotfix] [kafka] Remove unused operator state store field in FlinkKafkaProducerBase

2017-05-19 Thread tzulitai
Repository: flink Updated Branches: refs/heads/master e8c909503 -> b8f8524af [hotfix] [kafka] Remove unused operator state store field in FlinkKafkaProducerBase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8f8524a

[6/6] flink git commit: [FLINK-6608] [security, config] Relax Kerberos login contexts parsing

2017-05-19 Thread tzulitai
[FLINK-6608] [security, config] Relax Kerberos login contexts parsing This closes #3928. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ffa9aa0e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ffa9aa0e Diff:

[3/6] flink git commit: [FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple Kafka sink topics

2017-05-19 Thread tzulitai
[FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple Kafka sink topics Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9ed9b683 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9ed9b683

[2/6] flink git commit: [FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple Kafka sink topics

2017-05-19 Thread tzulitai
http://git-wip-us.apache.org/repos/asf/flink/blob/9ed9b683/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java -- diff --git

[5/6] flink git commit: [FLINK-6288] [kafka] Cleanup and improvements to FlinkKafkaPartitioner custom partitioning

2017-05-19 Thread tzulitai
[FLINK-6288] [kafka] Cleanup and improvements to FlinkKafkaPartitioner custom partitioning This commit wraps up some general improvements to the new Kafka sink custom partitioning API, most notably: 1. remove deprecated constructors from base classes, as they are not user-facing. 2. modify

[3/6] flink git commit: [FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple Kafka sink topics

2017-05-19 Thread tzulitai
[FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple Kafka sink topics Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/58c4eed5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/58c4eed5

[5/6] flink git commit: [FLINK-6288] [kafka] Cleanup and improvements to FlinkKafkaPartitioner custom partitioning

2017-05-19 Thread tzulitai
[FLINK-6288] [kafka] Cleanup and improvements to FlinkKafkaPartitioner custom partitioning This commit wraps up some general improvements to the new Kafka sink custom partitioning API, most notably: 1. remove deprecated constructors from base classes, as they are not user-facing. 2. modify

[4/6] flink git commit: [FLINK-6288] [kafka] Cleanup and improvements to FlinkKafkaPartitioner custom partitioning

2017-05-19 Thread tzulitai
http://git-wip-us.apache.org/repos/asf/flink/blob/d3b58709/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java -- diff --git

[2/6] flink git commit: [FLINK-6288] [kafka] New custom partitioner API that correctly handles multiple Kafka sink topics

2017-05-19 Thread tzulitai
http://git-wip-us.apache.org/repos/asf/flink/blob/58c4eed5/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java -- diff --git

[6/6] flink git commit: [hotfix] [kafka] Remove unused operator state store field in FlinkKafkaProducerBase

2017-05-19 Thread tzulitai
[hotfix] [kafka] Remove unused operator state store field in FlinkKafkaProducerBase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0963718a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0963718a Diff:

[1/6] flink git commit: [FLINK-6608] [security, config] Relax Kerberos login contexts parsing

2017-05-19 Thread tzulitai
Repository: flink Updated Branches: refs/heads/release-1.3 94111f985 -> 0963718ac [FLINK-6608] [security, config] Relax Kerberos login contexts parsing This closes #3928. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/4] flink git commit: [hotfix] Remove some raw type usage in RocksDBKeyedStateBackend

2017-05-19 Thread trohrmann
[hotfix] Remove some raw type usage in RocksDBKeyedStateBackend Introduce more generic parameters Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f2af1a9f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f2af1a9f

[4/4] flink git commit: [hotfix] Correct equals & hashCode implementation of KryoSerializer

2017-05-19 Thread trohrmann
[hotfix] Correct equals & hashCode implementation of KryoSerializer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e8c90950 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e8c90950 Diff:

[2/4] flink git commit: [hotfix] Remove some raw type usage in RocksDBKeyedStateBackend

2017-05-19 Thread trohrmann
[hotfix] Remove some raw type usage in RocksDBKeyedStateBackend Introduce more generic parameters Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c573540 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6c573540

[1/4] flink git commit: [hotfix] Correct equals & hashCode implementation of KryoSerializer

2017-05-19 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-1.3 51fb7ed79 -> 94111f985 [hotfix] Correct equals & hashCode implementation of KryoSerializer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/94111f98 Tree:

[4/4] flink git commit: [hotfix] Restore KeySerializer only once

2017-05-19 Thread trohrmann
[hotfix] Restore KeySerializer only once Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cfb6a698 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cfb6a698 Diff:

[3/4] flink git commit: [hotfix] Remove unnecessary job id from RocksDBKeyedStateBackend

2017-05-19 Thread trohrmann
[hotfix] Remove unnecessary job id from RocksDBKeyedStateBackend Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20b356c7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/20b356c7 Diff:

[1/4] flink git commit: [hotfix] Restore KeySerializer only once

2017-05-19 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 9a64d50f0 -> e8c909503 [hotfix] Restore KeySerializer only once Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef6f7b60 Tree:

[3/4] flink git commit: [hotfix] Remove unnecessary job id from RocksDBKeyedStateBackend

2017-05-19 Thread trohrmann
[hotfix] Remove unnecessary job id from RocksDBKeyedStateBackend Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe5b92f7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fe5b92f7 Diff:

[4/5] flink git commit: [FLINK-6586] InputGateMetrics return 0 as min for local channels

2017-05-19 Thread chesnay
[FLINK-6586] InputGateMetrics return 0 as min for local channels Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c3ab5c82 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c3ab5c82 Diff:

[3/5] flink git commit: [hotfix][rat] Add exclusion for all test snapshots/savepoints

2017-05-19 Thread chesnay
[hotfix][rat] Add exclusion for all test snapshots/savepoints This closes #3854. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17a4bb14 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17a4bb14 Diff:

[1/5] flink git commit: [FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil

2017-05-19 Thread chesnay
Repository: flink Updated Branches: refs/heads/release-1.3 c62553c00 -> 5fde739fd [FLINK-6439] Fix close OutputStream && InputStream in OperatorSnapshotUtil Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5fde739f Tree:

[5/5] flink git commit: [FLINK-5636][metrics] Measure numRecordsIn in StreamTwoInputProcessor

2017-05-19 Thread chesnay
[FLINK-5636][metrics] Measure numRecordsIn in StreamTwoInputProcessor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/54b88d71 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/54b88d71 Diff:

[2/5] flink git commit: [FLINK-6639][docs] fix code tabs in CEP docs

2017-05-19 Thread chesnay
[FLINK-6639][docs] fix code tabs in CEP docs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5d1cda52 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5d1cda52 Diff:

flink git commit: [FLINK-6574] [table] Support nested catalogs in ExternalCatalog.

2017-05-19 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 6ae759ae5 -> acea4cde5 [FLINK-6574] [table] Support nested catalogs in ExternalCatalog. This closes #3913. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/acea4cde