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 Night

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 Night

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 Night

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 Night

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 schedul

[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: http://git-wip-us.apache.org

[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: http://git-wip-u

[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: ht

[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: http://git-wip-us.apache.org/repo

[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: http://git-wip-us.apache.org/repos/asf/flink/diff/5d1

[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: http://git-wi

[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:

[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: http://git-wip-us.apache.org/repo

[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: http://g

[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: htt

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: http://

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

2017-05-19 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master 8814ba767 -> 8e3213678 [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/8e321367 Tree: http://git-w

[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: http://git-wip-us.apache.org/repo

[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: http://git-wip-us.apache.

[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: http://git-wip-us.apache.org/repos/asf/fl

[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: http:

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: http://git-w

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 Tre

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 #391

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 P

[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 a/flink-runtime/src/test/java/org/apache/flink/runtime/state/

[2/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

[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: http://git-wip-us.apa

[2/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/0162543a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0162543a Diff: http://git-wip-us.apa

[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 a/flink-runtime/src/test/java/org/apache/flink/runtime/zook

[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