flink git commit: [FLINK-2825] FlinkClient.killTopology fails due to missing leader session ID

Repository: flink Updated Branches: refs/heads/master af1e03e13 -> b489c3673 [FLINK-2825] FlinkClient.killTopology fails due to missing leader session ID Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b489c367 Tree: http:

flink git commit: Create a deep-copy of the record when changing timestamps.

Repository: flink Updated Branches: refs/heads/master 48791c347 -> af1e03e13 Create a deep-copy of the record when changing timestamps. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af1e03e1 Tree: http://git-wip-us.apach

[1/2] flink git commit: Revert "[FLINK-2203] handling null values for RowSerializer"

Repository: flink Updated Branches: refs/heads/master b08669abf -> 48791c347 Revert "[FLINK-2203] handling null values for RowSerializer" This reverts commit f8e12b20d925c3f6f24769327d1da5d98affa679. The commit had to be reverted because the RowSerializer is not in sync with other comperators

[2/2] flink git commit: Revert "[FLINK-2210] Table API support for aggregation on columns with null values"

Revert "[FLINK-2210] Table API support for aggregation on columns with null values" This reverts commit b59c81bc41f0fc4ade5359dfdf42549a76d412fa. The commit had to be reverted because the RowSerializer is not in sync with other comparators and serializers. See FLINK-2236. Project: http://git-w

[2/5] flink git commit: [FLINK-2283] [streaming] Test for checkpointing in internal operators

[FLINK-2283] [streaming] Test for checkpointing in internal operators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a76d9638 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a76d9638 Diff: http://git-wip-us.apache.org

[5/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference

[FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Remove Pact word from class and file names in Apache Flink. Pact was the name used in Stratosphere time to refer to concept of distributed datasets (similar to Flink Dataset). It was used when Pac

[3/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference

http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java

[1/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference

Repository: flink Updated Branches: refs/heads/master e494c2795 -> b08669abf http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/TaskContext.java -- diff --g

[2/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference

http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceCombineDriver.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators

[4/5] flink git commit: [FLINK-2815] [REFACTOR] Remove Pact from class and file names since it is no longer valid reference

http://git-wip-us.apache.org/repos/asf/flink/blob/b08669ab/flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadPactTask.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/iterati

[5/5] flink git commit: [FLINK-2812] [streaming] KeySelectorUtil interacts well with type extraction

[FLINK-2812] [streaming] KeySelectorUtil interacts well with type extraction The interaction is tested in the AggregationFunctionTest and the scala DataStreamTest amongst others. Closes #1155 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/

[3/5] flink git commit: [streaming] Removed unused StreamReduce

[streaming] Removed unused StreamReduce Refactored corresponding tests, some minor cleanups. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/906bd6dc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/906bd6dc Diff: http

[1/5] flink git commit: [FLINK-2283] [streaming] Proper serialization of state in StreamGroupedFold and Reduce

Repository: flink Updated Branches: refs/heads/master 4938ff09f -> e494c2795 [FLINK-2283] [streaming] Proper serialization of state in StreamGroupedFold and Reduce Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c414ea98

[4/5] flink git commit: [FLINK-2283] [streaming] grouped reduce and fold operators checkpoint state

[FLINK-2283] [streaming] grouped reduce and fold operators checkpoint state Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/225704bc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/225704bc Diff: http://git-wip-us.apac

flink git commit: [FLINK-2642] [table] Scala Table API crashes when executing word count example

Repository: flink Updated Branches: refs/heads/master 4c5d43b6f -> 4938ff09f [FLINK-2642] [table] Scala Table API crashes when executing word count example This closes #1209. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commi

flink git commit: [FLINK-2822] [streaming] Remove scala.Serializable imports

Repository: flink Updated Branches: refs/heads/master 4cb967089 -> 4c5d43b6f [FLINK-2822] [streaming] Remove scala.Serializable imports Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4c5d43b6 Tree: http://git-wip-us.apach

[02/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/AbstractTest.java -- diff --git a/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/A

[07/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/wordcount/stormoperators/WordCountDataPojos.java --

[10/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/test/java/org/apache/flink/stormcompatibility/wrappers/StormBoltWrapperTest.java -- diff --git a

[12/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/SplitStreamTypeKeySelector.java -- diff --git

[14/15] flink git commit: [FLINK-2566] FlinkTopologyContext not populated completely - extended FlinkTopologyContext to be populted with all supportable attributes - added JUnit test - updated README.

http://git-wip-us.apache.org/repos/asf/flink/blob/7a67a60f/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/test/java/org/apache/flink/stormcompatibility/util/FiniteTestSpout.java -- diff --git a/flink-co

[05/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountLocalByName.java -- diff --git a/flink-contrib/flink-storm-examples/src/main/jav

[06/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/excamation/ExclamationLocal.java -- diff --git a/flink-contrib/flink-storm-examples/src/main/java/o

[08/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/src/main/java/org/apache/flink/stormcompatibility/util/FiniteStormInMemorySpout.java -- diff --gi

[04/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/wordcount/WordCountLocalITCase.java -- diff --git a/flink-contrib/flink-storm-examples/src/test/jav

[11/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormSpoutWrapper.java -- diff --git a/fl

[01/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

Repository: flink Updated Branches: refs/heads/master 39115abe4 -> 4cb967089 http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/WrapperSetupHelperTest.java ---

[09/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-examples/pom.xml -- diff --git a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-exampl

[03/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

http://git-wip-us.apache.org/repos/asf/flink/blob/4cb96708/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/AbstractStormCollector.java -- diff --git a/flink-contrib/flink-storm/src/main/java/org/apache/flin

[15/15] flink git commit: [FLINK-2566] FlinkTopologyContext not populated completely - extended FlinkTopologyContext to be populted with all supportable attributes - added JUnit test - updated README.

[FLINK-2566] FlinkTopologyContext not populated completely - extended FlinkTopologyContext to be populted with all supportable attributes - added JUnit test - updated README.md additionally: module restructuring to get cleaner package structure This closes #1135 Project: http://git-wip-us.

[13/15] flink git commit: [Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed

[Storm Compatibility] Maven module restucturing and cleanup - removed storm-parent; renamed storm-core and storm-examples - updated internal Java package structure * renamed package "stormcompatibility" to "storm" * unified *SpoutWrapper* to single SpoutWrapper.java class * moved cl

[1/2] flink git commit: [FLINK-2786] Remove Spargel code and docs; Port Spargel tests to Gelly; Remove Beta badge from Gelly

Repository: flink Updated Branches: refs/heads/master 2b81b17d5 -> 39115abe4 http://git-wip-us.apache.org/repos/asf/flink/blob/39115abe/flink-staging/flink-spargel/src/main/java/org/apache/flink/spargel/java/VertexUpdateFunction.java -

[2/2] flink git commit: [FLINK-2786] Remove Spargel code and docs; Port Spargel tests to Gelly; Remove Beta badge from Gelly

[FLINK-2786] Remove Spargel code and docs; Port Spargel tests to Gelly; Remove Beta badge from Gelly This closes #1229 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/39115abe Tree: http://git-wip-us.apache.org/repos/asf/fli

flink git commit: [FLINK-2741] Use single log statement in TestLogger

Repository: flink Updated Branches: refs/heads/master de14a8015 -> 2b81b17d5 [FLINK-2741] Use single log statement in TestLogger This closes #1221 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b81b17d Tree: http://git-

[3/3] flink git commit: [FLINK-2811] [web-dashboard] Add job manager configuration overview

[FLINK-2811] [web-dashboard] Add job manager configuration overview This closes #1219 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/de14a801 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/de14a801 Diff: http://git-

[2/3] flink git commit: [FLINK-2811] [web-dashboard] Add job manager configuration overview

http://git-wip-us.apache.org/repos/asf/flink/blob/de14a801/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index 8d8

[1/3] flink git commit: [FLINK-2811] [web-dashboard] Add job manager configuration overview

Repository: flink Updated Branches: refs/heads/master 19076b2df -> de14a8015 http://git-wip-us.apache.org/repos/asf/flink/blob/de14a801/flink-runtime-web/web-dashboard/web/partials/jobmanager/config.html -- diff --git a/flink-

flink git commit: [FLINK-1610] fix building of java doc for Java 8

Repository: flink Updated Branches: refs/heads/release-0.9 2b6a837a2 -> cf6f87b5e [FLINK-1610] fix building of java doc for Java 8 This closes #1225. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf6f87b5 Tree: http://g

[3/3] flink git commit: [FLINK-1610] fix building of java doc for Java 8

[FLINK-1610] fix building of java doc for Java 8 This closes #1225. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/352b041b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/352b041b Diff: http://git-wip-us.apache.org/

[1/3] flink git commit: [FLINK-2810] Warn user if bc not installed

Repository: flink Updated Branches: refs/heads/master 9513f0e33 -> 19076b2df [FLINK-2810] Warn user if bc not installed This closes #1228. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/19076b2d Tree: http://git-wip-us.a

[2/3] flink git commit: [FLINK-2813] document parameter for off-heap memory

[FLINK-2813] document parameter for off-heap memory This closes #1226. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f8fa3377 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f8fa3377 Diff: http://git-wip-us.apache.o