- 25 9月, 2014 17 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Aljoscha Krettek 提交于
Also update documentation accordingly.
-
由 Aljoscha Krettek 提交于
-
由 Ufuk Celebi 提交于
-
由 mbalassi 提交于
-
由 mbalassi 提交于
-
由 Gyula Fora 提交于
-
由 mbalassi 提交于
[FLINK-1103] [streaming] Updated WordCount example to become self-contained and removed old TestDataUtil
-
由 mbalassi 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/JobGraphBuilder.java flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamConfig.java flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedDataStream.java flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
-
由 szape 提交于
[streaming] added batchReduceGroup, windowReduceGroup functionality to ConnectedDataStream and GroupedConnectedDataStream
-
由 Gyula Fora 提交于
-
由 ghermann 提交于
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
Excluded DataSet.first(), UnsortedGrouping.first(), and SortedGrouping.first() methods from ScalaAPICompletenessTest.
-
- 24 9月, 2014 15 次提交
-
-
由 zentol 提交于
This closes #88
-
由 Fabian Hueske 提交于
- GroupReduceCombineDriver uses separate comparators for sorting and grouping. - Adding support for multiple comparators for a single input driver required some refactoring. This closes #109
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
[FLINK-1060] Added methods to DataSet to explicitly hash-partition or rebalance the input of Map-based operators. This closes #108
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Tasks are marked correctly as failed (not canceled), when the taskmanager kills then during shutdown or reset.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-1115] Local file streams retry file creation on FileNotFoundException to increase resilience against spurious failures in tests
-
由 Stephan Ewen 提交于
[FLINK-1114] Move scala-style checks to scala projects, change paths to style conifg, to allow isolated building of individual projects.
-
- 23 9月, 2014 6 次提交
-
-
由 Till Rohrmann 提交于
Updated license notices in in java files to be written in block comments instead of javadoc comments.
-
由 Till Rohrmann 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
- 22 9月, 2014 2 次提交
-
-
由 Stephan Ewen 提交于
-
由 Ufuk Celebi 提交于
Instead of waiting for the number of connected task managers, the local mini cluster used for tests now waits for the total number of available slots. Waiting for the number of connected task managers instead of the available slots might result in races in rare situations. In addition, rename task tracker (sic) to task manager in test classes.
-