flink git commit: [FLINK-3100] signal handler prints error on normal shutdown of cluster

2015-12-02 Thread mxm
Repository: flink Updated Branches: refs/heads/master 0ccab95e7 -> 4e592324a [FLINK-3100] signal handler prints error on normal shutdown of cluster Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4e592324 Tree:

flink git commit: [FLINK-3087] [Table API] support multi count in aggregation.

2015-12-02 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 9215b7242 -> 20fe2af8b [FLINK-3087] [Table API] support multi count in aggregation. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20fe2af8 Tree:

[3/3] flink git commit: [FLINK-2837][storm] various improvements for the compatibility layer

2015-12-02 Thread mxm
[FLINK-2837][storm] various improvements for the compatibility layer - refactor to use Storm's topology builder - remove FlinkTopologyBuilder - instantiate context-based StreamExecutionEnvironment (local or remote) - remove some of the Flink and Storm behavior replicating classes - modify

[1/3] flink git commit: [FLINK-2837][storm] various improvements for the compatibility layer

2015-12-02 Thread mxm
Repository: flink Updated Branches: refs/heads/master 20fe2af8b -> 88636799e http://git-wip-us.apache.org/repos/asf/flink/blob/88636799/flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/SetupOutputFieldsDeclarer.java

flink git commit: [FLINK-3080] Relax restrictions of DataStream.union()

2015-12-02 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master f8b456b58 -> 04b38028d [FLINK-3080] Relax restrictions of DataStream.union() Before, it would not allow unioning with predecessors (also transitive) and streams of differing parallelism. Project:

flink-web git commit: Update features page

2015-12-02 Thread sewen
Repository: flink-web Updated Branches: refs/heads/asf-site e36fdf822 -> 91ce5e267 Update features page Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/91ce5e26 Tree:

[2/3] flink git commit: [FLINK-2837][storm] various improvements for the compatibility layer

2015-12-02 Thread mxm
http://git-wip-us.apache.org/repos/asf/flink/blob/88636799/flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/split/SplitSpoutTopology.java -- diff --git

flink git commit: [FLINK-2115] [Table API] support no aggregation after groupBy.

2015-12-02 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 88636799e -> f8b456b58 [FLINK-2115] [Table API] support no aggregation after groupBy. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f8b456b5 Tree:

flink git commit: [FLINK-3080] Relax restrictions of DataStream.union()

2015-12-02 Thread aljoscha
Repository: flink Updated Branches: refs/heads/release-0.10 961adea59 -> b8fa5b877 [FLINK-3080] Relax restrictions of DataStream.union() Before, it would not allow unioning with predecessors (also transitive) and streams of differing parallelism. Project:

flink git commit: [FLINK-2440][py] Expand Environment feature coverage

2015-12-02 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 0ccbd2779 -> 0ccab95e7 [FLINK-2440][py] Expand Environment feature coverage This closes #1383 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ccab95e Tree:

flink git commit: [FLINK-3071] Add asynchronous state materialization thread

2015-12-02 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 04b38028d -> 0ccbd2779 [FLINK-3071] Add asynchronous state materialization thread This also adds a test for asynchronous state handles. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: