- 19 12月, 2014 21 次提交
-
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Removed old events. Adapted webserver communication so that it can now talk to the actor implementations.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Removed old java implementations of the JobManager, TaskManager, JobClient, EventCollector, TaskOperationResult and MemoryArchivist.
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
Renamed NepheleMiniCluster to FlinkMiniCluster.
-
由 Till Rohrmann 提交于
Changed RuntimeEnvironment and TaskInputSplitProvider to work with ActorRefs.
-
由 Till Rohrmann 提交于
Replacing the EventCollector and the MemoryArchivist. Finished EventCollector and adjusted ExecutionGraph and ExecutionVertex to register actors as listeners.
-
由 Till Rohrmann 提交于
added further communication logic to jobmanager and taskmanager.
-
由 Till Rohrmann 提交于
-
- 18 12月, 2014 7 次提交
-
-
由 Stephan Ewen 提交于
-
由 Till Rohrmann 提交于
Fixes race condition in ExecutionGraph which allowed a job to go into the finished state without all job vertices having properly processed the finalizeOnMaster method.
-
由 Robert Metzger 提交于
This closes #271
-
由 Robert Metzger 提交于
The performance of data-intensive jobs using Kryo is probably going to be slow. Set correct classloader try to use Kryo.copy() with fallback to serialization copy
-
由 twalthr 提交于
-
由 mbalassi 提交于
This closes #273
-
由 Gyula Fora 提交于
-
- 17 12月, 2014 9 次提交
-
-
由 mbalassi 提交于
The current examples show-case the API, more meaningful examples are coming for the 0.9 release.
-
由 mbalassi 提交于
PrintSinkFunction now explicitly states threads in output Added printToErr functionality
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Aljoscha Krettek 提交于
This closes #269
-
由 Aljoscha Krettek 提交于
-
由 Stephan Ewen 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
- 16 12月, 2014 2 次提交
-
-
由 mbalassi 提交于
Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
-
由 szape 提交于
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/environment/StreamExecutionEnvironment.java
-
- 15 12月, 2014 1 次提交
-
-
由 Stephan Ewen 提交于
-