- 03 3月, 2015 5 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-1608] [taskmanager] Network address selection makes multiple attempts before switching to heuristics.
-
由 Stephan Ewen 提交于
-
由 Henry Saputra 提交于
-) Remove extra "solution" word. -) Change propagete to propagate. Author: Henry Saputra <henry.saputra@gmail.com> Closes #443 from hsaputra/fix_typo_in_iterations_md and squashes the following commits: fd781cc [Henry Saputra] Fix typos in iterations.md file: -) Remove extra solution word. -) Change propagete to propagate.
-
- 02 3月, 2015 4 次提交
-
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
-
由 Till Rohrmann 提交于
-
由 Gyula Fora 提交于
Closes #444
-
- 01 3月, 2015 2 次提交
-
-
由 Gyula Fora 提交于
-
由 Paris Carbone 提交于
-
- 28 2月, 2015 4 次提交
-
-
由 Gábor Hermann 提交于
Closes #433
-
由 Paris Carbone 提交于
Closes #432
-
由 Max Michels 提交于
- this implements two convenience methods on DataSet for the Java and Scala API - appropriate tests have been added count(): returns the number of elements in a DataSet collect(): returns a List<T> with the actual elements of a DataSet<T> - both methods use accumulators to get the results back to the client - both methods force an execution of the job to generate the results This closes #210
-
由 Maximilian Michels 提交于
-
- 27 2月, 2015 2 次提交
- 26 2月, 2015 1 次提交
-
-
由 mbalassi 提交于
-
- 25 2月, 2015 18 次提交
-
-
由 Till Rohrmann 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Ufuk Celebi 提交于
The PipelinedPartitionQueueTest spuriously fails with a timeout. It is unclear whether this is due to a deadlock or a test environment hickup. Since build artifacts like stack traces for stalled builds are uploaded to S3, we can let this test deadlock (if it is one) and then start debugging. ;-)
-
由 mbalassi 提交于
This closes #424
-
由 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 4 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Also adds various tests for failure behavior during job submission.
-
由 Stephan Ewen 提交于
-