- 25 2月, 2015 13 次提交
-
-
由 mingliang 提交于
-
由 mingliang 提交于
This closes #435.
-
由 zentol 提交于
This closes #438.
-
由 Ufuk Celebi 提交于
This addresses PR comments: https://github.com/apache/flink/pull/436/
-
由 Till Rohrmann 提交于
[FLINK-1607] [runtime] Moves PartialPartitionInfo from ExecutionVertex to Execution to automatically clear them in case of restart This closes #436.
-
由 Ufuk Celebi 提交于
-
由 Till Rohrmann 提交于
Replaces recursive concurrent modification resolution by while loop Turns off stdout-logging of Akka. Sends proper exceptions in ErrorResponse. Proper stream closing
-
由 Till Rohrmann 提交于
[FLINK-1607] [tests] Fixes SimpleRecoveryITCase by rebalancing the data sources so that all mappers receive at least one element
-
由 Till Rohrmann 提交于
[FLINK-1606] [tests] Fixes JobManagerFailsITCase for Akka 2.2.1 by setting gate-invalid-address-for = 5s and quarantine-systems-for = off
-
由 Henry Saputra 提交于
-
由 mjsax 提交于
package statement was not updated after class movement also added a missing import Author: mjsax <mjsax@informatik.hu-berlin.de> Closes #437 from mjsax/bug_fix_package_statement and squashes the following commits: 1470b0f [mjsax] fixed package statement
-
由 Stephan Ewen 提交于
[FLINK-1580] [FLINK-1590] [runtime] Various cleanups and improvements in the TaskManager initialization - Better checks during TaskManager startup - More robust initialization of TaskManager actor system and actor - Fix memory accounting during TaskManager startup - Better logging for TaskManagers started through YARN - Remove command line parameter hacking fro YARN TaskManagers
-
由 Henry Saputra 提交于
-
- 24 2月, 2015 9 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Also adds various tests for failure behavior during job submission.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-1598] [runtime] Better error message when network serialization of records exceeds java heap space.
-
由 Johannes 提交于
This closes #431
-
由 Martin Kiefer 提交于
[FLINK-1515] [gelly] Changed PageRank to use broadcast set provided by numberOfVertices() to read the number of vertices instead of passing it to the constructor. This closes #402
-
由 Martin Kiefer 提交于
[FLINK-1515] [gelly] Splitted runVertexCentricIteration into createVertexIteration and runVertexIteration to make VertexCentricIteration object accessible to developers.
-
由 Till Rohrmann 提交于
-
- 23 2月, 2015 6 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
Before, translateToDataflow of SingleInputOperator could only return a single input operator of the lower layer, same for TwoInputOperator. This change allows translateToDataflow to return more kinds of operators.
-
由 Ufuk Celebi 提交于
This closes #428.
-
- 21 2月, 2015 1 次提交
-
-
由 Gyula Fora 提交于
-
- 20 2月, 2015 11 次提交
-
-
由 Fabian Hueske 提交于
This closes #411
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
This closes #381
-
由 Fabian Hueske 提交于
This closes #379
-
由 Gyula Fora 提交于
-
由 Stephan Ewen 提交于
-
由 Robert Metzger 提交于
-
由 Stephan Ewen 提交于
-
由 Till Rohrmann 提交于
[FLINK-1499] [runtime] TaskManager sends explicit disconnect message to JobManager in case of shutdown This closes #423
-
由 Till Rohrmann 提交于
[Flink-1484] [runtime] JobManager sends an explicit disconnect message to the registered TaskManagers in case of a graceful shutdown.
-
由 Till Rohrmann 提交于
This closes #422
-