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: http://git-
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: http://git
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: http://git-wip-us.apache.org/repos/
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: http://git-wip-us.apache.org/repos/a
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: http://git-wip-us.apache.org/repos/asf/flink-we
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: http://git-wip-us.apache.org/repos/asf/fli
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: http://git-wip-us.a
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-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 FlinkTop
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
a/flink-contrib/flink-storm-examples/src/test/java/org/
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: http://git-wip-us.apa
11 matches
Mail list logo