- 18 2月, 2015 8 次提交
-
-
由 Robert Metzger 提交于
-
由 Aljoscha Krettek 提交于
Also fix tests for JodaTime. Conflicts: flink-dist/src/main/flink-bin/LICENSE flink-java/pom.xml flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/KryoGenericTypeSerializerTest.scala flink-tests/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerTest.scala
-
由 Robert Metzger 提交于
Conflicts: flink-java/pom.xml flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
-
由 Robert Metzger 提交于
Conflicts: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoSerializer.java
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
This closes #412
-
由 Fabian Hueske 提交于
Move RuntimeContext initialization to begin of RegularPactTask.invoke().
-
由 Gyula Fora 提交于
-
- 17 2月, 2015 8 次提交
-
-
由 Till Rohrmann 提交于
Fixes unhandled FailsIntermediateResultPartitions message. Changes JobResultFailed and JobResultCanceled to send the cause as a throwable instead of a string. Fixes NullPointerException if an execution has already been prepared for archiving and sendPartitionInfos is called asynchronously This closes #406.
-
由 Till Rohrmann 提交于
[FLINK-1554] [runtime] Allows the LocalFlinkMiniCluster to start multiple TaskManager in the same ActorSystem. This closes #403.
-
由 Till Rohrmann 提交于
This closes #397.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Henry Saputra 提交于
[FLINK-1542] Test case at BlobUtilsTest should not assume user could not create new item in root directory Sometimes, user that run tests could have write access to root dir such as creating /cannot-create-this is possible, hence to exception thrown. Need to construct a Flink test directory under directory specified under "java.io.tmpdir" and change the permission to not allow create new directory. This closes #396
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
- 16 2月, 2015 20 次提交
-
-
由 Stephan Ewen 提交于
[FLINK-1454] [job client] Improve error handling for failed connections between JobClient and JobManager
-
由 mbalassi 提交于
This closes #395
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
[streaming] StreamDiscretizer rework to support only 1 eviction and trigger for robustness + test cleanup
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 mbalassi 提交于
This closes #303
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
[FLINK-1487] [runtime][tests] Fixes SchedulerIsolatedTasksTest.testScheduleQueueing by waiting for the released resources to registered at the Scheduler again. This closes #398
-
由 Till Rohrmann 提交于
[FLINK-1545] [runtime][tests] Fixes AsynchronousFileIOChannelsTest.testExceptionForwardsToClose by introducing additional error check in AsynchronousFileIOChannel.close method This closes #399
-
- 15 2月, 2015 1 次提交
-
-
由 Chiwan Park 提交于
[FLINK-1179] [jobmanager] Add button to JobManager web interface to request stack trace of a TaskManager This closes #374
-
- 14 2月, 2015 3 次提交
-
-
由 Till Rohrmann 提交于
[FLINK-1543] [runtime] Adds try and catch blocks around all method calls from an actor's receive method which can throw an exception. Sets the StoppingSupervisorStrategy as default for all guardians. This closes #394.
-
由 Till Rohrmann 提交于
[FLINK-1508] [runtime] Removes AkkaUtil.ask and replaces respective calls with explicit future handling. Removes blocking calls for ActorRef retrieval in actors. This closes #384.
-
-