- 05 3月, 2015 12 次提交
-
-
由 Gyula Fora 提交于
[FLINK-1625] [streaming] Refactored StreamVertex and subclasses to clean up after invoke and properly log and propagate exceptions
-
由 vasia 提交于
-
由 balidani 提交于
This closes #441
-
由 balidani 提交于
-
由 andralungu 提交于
This closes #429
-
由 andralungu 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Ufuk Celebi 提交于
Add a hint about how to configure the number of network buffers.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
- Fix bugs with non-serializable messages - Separate parser and action logic - Clean up tests - Vastly improve logging in CLI client - Additional tests for parsing / config setup in the command line client
-
由 Ufuk Celebi 提交于
The fixed race condition could lead to an infinite loop, in which the network I/O thread is continuously trying to request a buffer from an already destroyed buffer provider. The problem was noticed in certain builds during recovery test cases, where the blocked network I/O thread prevented restarted tasks from connecting to remote task managers.
-
- 04 3月, 2015 6 次提交
-
-
由 Till Rohrmann 提交于
-
由 Robert Metzger 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
This closes #415
-
- 03 3月, 2015 12 次提交
-
-
由 Ufuk Celebi 提交于
Task thread Exceptions were always logged, even if the task was cancelled or failed externally. In certain scenarios this lead to misleading error messages and made it hard to figure out the root exception. When an exception is thrown w/o the task being canceled or failed, the error is still handled via Task#markFailed(Throwable).
-
由 Robert Metzger 提交于
-
由 Maximilian Michels 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Ufuk Celebi 提交于
-
由 Gyula Fora 提交于
-
由 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 提交于
-