buildbot failure in on flink-docs-release-0.9

2016-04-26 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/307 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: lares_ubuntu Build Reason: The Nightly s

buildbot exception in on flink-docs-release-1.0

2016-04-26 Thread buildbot
The Buildbot has detected a build exception 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/65 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: lares_ubuntu Build Reason: The Nightl

flink git commit: [FLINK-3800] [jobmanager] Terminate ExecutionGraphs properly

2016-04-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master e29ac036a -> 28c57c3a5 [FLINK-3800] [jobmanager] Terminate ExecutionGraphs properly This PR terminates the ExecutionGraphs properly without restarts when the JobManager calls cancelAndClearEverything. It is achieved by allowing the method

flink git commit: [FLINK-3708] [cep] Add Scala CEP API

2016-04-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 2bd6212a3 -> e29ac036a [FLINK-3708] [cep] Add Scala CEP API Added missing test dependency to pom. Pattern in Scala API now uses Option to shield users against null values from the Java API Added test-jar for build phase to pom. Removed

flink git commit: [hotfix] OptionSerializer.duplicate to respect stateful element serializer

2016-04-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-1.0 7062b0ae8 -> d8feb15df [hotfix] OptionSerializer.duplicate to respect stateful element serializer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8feb15d Tree: ht

flink git commit: [hotfix] [build] Replace maven-scala-plugin with newer scala-maven-plugin

2016-04-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 1ccc79891 -> 2bd6212a3 [hotfix] [build] Replace maven-scala-plugin with newer scala-maven-plugin Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2bd6212a Tree: http://g

flink git commit: [hotfix] OptionSerializer.duplicate to respect stateful element serializer

2016-04-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master e293e68c9 -> 1ccc79891 [hotfix] OptionSerializer.duplicate to respect stateful element serializer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1ccc7989 Tree: http://

flink git commit: [FLINK-3804][docs] Fix YARN and Kafka docs

2016-04-26 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master ac2137cfa -> e293e68c9 [FLINK-3804][docs] Fix YARN and Kafka docs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e293e68c Tree: http://git-wip-us.apache.org/repos/asf/

flink git commit: [FLINK-3777] Add openIF/closeIF methods to IF lifecycle

2016-04-26 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 879bb1bb0 -> ac2137cfa [FLINK-3777] Add openIF/closeIF methods to IF lifecycle This closes #1903 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ac2137cf Tree: http://

flink git commit: [hotfix] Disable WAL in RocksDB state "clear"

2016-04-26 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 06bf4bf3f -> 879bb1bb0 [hotfix] Disable WAL in RocksDB state "clear" Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/879bb1bb Tree: http://git-wip-us.apache.org/repos/a

flink git commit: [FLINK-3799] [gelly] Graph checksum should execute single job

2016-04-26 Thread greg
Repository: flink Updated Branches: refs/heads/master a58cd80f9 -> 06bf4bf3f [FLINK-3799] [gelly] Graph checksum should execute single job This closes #1922 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06bf4bf3 Tree: h

flink git commit: [Doc] added note to fix Eclipse build

2016-04-26 Thread mjsax
Repository: flink Updated Branches: refs/heads/master 4a69f72a3 -> a58cd80f9 [Doc] added note to fix Eclipse build Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a58cd80f Tree: http://git-wip-us.apache.org/repos/asf/flink

[2/2] flink git commit: [FLINK-3809] Add missing breaks in ZKRetrievalService

2016-04-26 Thread trohrmann
[FLINK-3809] Add missing breaks in ZKRetrievalService This closes #1935. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4a69f72a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4a69f72a Diff: http://git-wip-us.apache

[1/2] flink git commit: [FLINK-3810] Add missing breaks in ZKElectionService

2016-04-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 172fcfa1e -> 4a69f72a3 [FLINK-3810] Add missing breaks in ZKElectionService Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/55a88a4b Tree: http://git-wip-us.apache.org/

flink git commit: [FLINK-3811] [tableAPI] Use only Java ExecutionEnvironments in TableEnvironments

2016-04-26 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 0cf04108f -> 172fcfa1e [FLINK-3811] [tableAPI] Use only Java ExecutionEnvironments in TableEnvironments This closes #1930 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/comm

[2/2] flink git commit: [FLINK-3756] [state] Add state hierarchy to CheckpointCoordinator

2016-04-26 Thread trohrmann
[FLINK-3756] [state] Add state hierarchy to CheckpointCoordinator This commit introduces a state hierarchy for the StateForTask objects kept at the CheckpointCoordinator. Task states are now grouped together if they belong to the same ExecutionJobVertex. The StateForTask objects are now stored in

[1/2] flink git commit: [FLINK-3756] [state] Add state hierarchy to CheckpointCoordinator

2016-04-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 7abf8ef77 -> 0cf04108f http://git-wip-us.apache.org/repos/asf/flink/blob/0cf04108/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/SavepointCoordinatorTest.java -

flink git commit: [FLINK-3775] [shell] Load Flink configuration before forwarding it

2016-04-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 8330539e4 -> 7abf8ef77 [FLINK-3775] [shell] Load Flink configuration before forwarding it This commit makes sure that the GlobalConfiguration is loaded before the FlinkShell is started. Add configDir option to FlinkShell This allows to c

flink git commit: [FLINK-3803] [runtime] Pass CheckpointStatsTracker to ExecutionGraph

2016-04-26 Thread uce
Repository: flink Updated Branches: refs/heads/master 8305c1755 -> 8330539e4 [FLINK-3803] [runtime] Pass CheckpointStatsTracker to ExecutionGraph `CheckpointStatsTracker` was instantiated in `ExecutionGraph#enableSnapshotCheckpointing`, where the Flink configuration is not available to parse

flink git commit: [FLINK-3803] [runtime] Pass CheckpointStatsTracker to ExecutionGraph

2016-04-26 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.0 f80f6d602 -> 7062b0ae8 [FLINK-3803] [runtime] Pass CheckpointStatsTracker to ExecutionGraph Backport of 8330539. `CheckpointStatsTracker` was instantiated in `ExecutionGraph#enableSnapshotCheckpointing`, where the Flink configuration