buildbot success in on flink-docs-release-0.9

2017-03-10 Thread buildbot
The Buildbot has detected a restored build 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/624 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The Ni

Build failed in Jenkins: flink-snapshot-deployment #400

2017-03-10 Thread Apache Jenkins Server
See -- [...truncated 170.33 KB...] [ERROR] public static void rethrowIOException(Throwable t) throws IOException { [ERROR] ^ [ERROR]

flink git commit: [FLINK-6023] fix process function doc examples

2017-03-10 Thread kurt
Repository: flink Updated Branches: refs/heads/master 7ef068ccc -> 354a13edf [FLINK-6023] fix process function doc examples This closes #3510. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/354a13ed Tree: http://git-wip-

flink git commit: [FLINK-5954] [table] Always assign names to the windows in SQL queries on streams.

2017-03-10 Thread fhueske
Repository: flink Updated Branches: refs/heads/master f15a7d2d9 -> 7ef068ccc [FLINK-5954] [table] Always assign names to the windows in SQL queries on streams. This closes #3461. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/

flink git commit: [FLINK-5874] Restrict key types in the DataStream API.

2017-03-10 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master 70e78a620 -> f15a7d2d9 [FLINK-5874] Restrict key types in the DataStream API. Reject a type from being a key in keyBy() if it is: 1. it is a POJO type but does not override the hashCode() and relies on the Object.hashCode() implementatio

[1/2] flink git commit: [FLINK-5910] [gelly] Framework for Gelly examples

2017-03-10 Thread greg
Repository: flink Updated Branches: refs/heads/master 206ea2119 -> 70e78a620 [FLINK-5910] [gelly] Framework for Gelly examples Driver jobs are composed of an input, an algorithm driver, and an output. Create the interfaces for inputs, drivers, and outputs. This closes #3431 Project: http://

[2/2] flink git commit: [FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled

2017-03-10 Thread greg
[FLINK-5890] [gelly] GatherSumApply broken when object reuse enabled GatherSumApplyIteration uses reduce and join for which extra care must be taken when object reuse is enabled. Adds a check for objects returned by the user to prevent system objects from being overwritten. This closes #3402 Pr

[7/7] flink git commit: [FLINK-4545] [network] Small adjustments to LocalBufferPool with limited the number of used buffers

2017-03-10 Thread sewen
[FLINK-4545] [network] Small adjustments to LocalBufferPool with limited the number of used buffers Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/206ea211 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/206ea211 Dif

[2/7] flink git commit: [FLINK-6005] [misc] Fix some ArrayList initializations without initial size

2017-03-10 Thread sewen
[FLINK-6005] [misc] Fix some ArrayList initializations without initial size This closes #3499 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb1197d9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bb1197d9 Diff: htt

[6/7] flink git commit: [FLINK-4545] [network] Allow LocalBufferPool to limited the number of used buffers

2017-03-10 Thread sewen
[FLINK-4545] [network] Allow LocalBufferPool to limited the number of used buffers Use "a * + b" buffers for bounded pipelined partitions: Default: a = 2, b = 8 * 1 buffer for in-flight data in the subpartition/input channel * 1 buffer for parallel serialization * + some extra buffers (8 seems

[1/7] flink git commit: [FLINK-6010] [docs] Correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section

2017-03-10 Thread sewen
Repository: flink Updated Branches: refs/heads/master 7456d78d2 -> 206ea2119 [FLINK-6010] [docs] Correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section This closes #3504 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repo

[5/7] flink git commit: [FLINK-4545] [network] Allow LocalBufferPool to limited the number of used buffers

2017-03-10 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/11e2aa6d/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java -- diff --git a/flink-streaming-java/src/test/java/org/apache/f

[4/7] flink git commit: [FLINK-5980] [core] Expose max-parallelism value in RuntimeContext.

2017-03-10 Thread sewen
[FLINK-5980] [core] Expose max-parallelism value in RuntimeContext. This closes #3487 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f47e31b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6f47e31b Diff: http://git-

[3/7] flink git commit: [FLINK-5976] [tests] Deduplicate Tokenizer in tests

2017-03-10 Thread sewen
[FLINK-5976] [tests] Deduplicate Tokenizer in tests This closes #3485 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e5e6da0b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e5e6da0b Diff: http://git-wip-us.apache.or