- 10 3月, 2015 21 次提交
-
-
由 Paris Carbone 提交于
This closes #459
-
由 Gyula Fora 提交于
-
由 Paris Carbone 提交于
Fault Tolerance monitor suicide on ExecutionGraph terminal state Forwarding messages to StreamCheckpointCoordinator
-
由 mbalassi 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 mbalassi 提交于
Exposed state registering in the public API
-
由 Gábor Hermann 提交于
-
由 mbalassi 提交于
-
由 Paris Carbone 提交于
-
由 Paris Carbone 提交于
-
由 Gyula Fora 提交于
-
由 Maximilian Michels 提交于
-
由 Fabian Hueske 提交于
This closes #458
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Henry Saputra 提交于
Add parentheses on Exception#getMessage calls from pattern of: "Initializing the input processing failed" + e.getMessage() == null ? "." : ": " + e.getMessage() to: "Initializing the input processing failed" + (e.getMessage() == null ? "." : ": " + e.getMessage()) Extra parentheses needed to make sure ternary operator check on e.getMessage scope call. Author: Henry Saputra <henry.saputra@gmail.com> Closes #461 from hsaputra/fix_parentheses_exception_getmessage and squashes the following commits: 1345cbf [Henry Saputra] Fix checking null for Exception#getMessage call from pattern of:
-
由 Henry Saputra 提交于
JobManagerStartupTest should not assume user could not create /does-not-exist-no-sir dir. Sometimes, user that run tests could have write access to root directory so creating /does-not-exist-no-sir is possible, hence no 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. Author: Henry Saputra <henry.saputra@gmail.com> Closes #460 from hsaputra/FLINK-1651_fix_jobmanager_fail_test and squashes the following commits: 5d46716 [Henry Saputra] [FLINK-1651] Fix test case at JobManagerStartupTest should not assume user could not create /does-not-exist-no-sir dir.
-
- 09 3月, 2015 4 次提交
-
-
由 Robert Metzger 提交于
This closes #450
-
由 mbalassi 提交于
This closes #463
-
由 Akshay Dixit 提交于
-
由 Gábor Hermann 提交于
-
- 08 3月, 2015 1 次提交
-
-
由 andralungu 提交于
This closes #440
-
- 07 3月, 2015 1 次提交
-
-
由 Henry Saputra 提交于
-
- 06 3月, 2015 2 次提交
-
-
由 Henry Saputra 提交于
This PR consists of: 1. Remove unnecessary brackets in ExecutionVertex#getPreferredLocations 2. Throw illegal argument with proper message for consistencies of not nullable argument. 3. Add final modifier to RecordWriter#serializers since the content being used as lock. 4. Wrap too long of lines in some of the Java code for readibility. 5. Add missing JavaDoc parameter. 6. Remove final modifier in the OutputEmitter's private methods because it is redundant. Author: Henry Saputra <henry.saputra@gmail.com> Closes #457 from hsaputra/cleanup_javadoc_and_longlines_1 and squashes the following commits: 8815302 [Henry Saputra] Some cleanups and doc updates while looking at runtime package: 1. Remove unnecessary brackets in ExecutionVertex#getPreferredLocations 2. Throw illegal argument with proper message for consistencies of not nullable argument. 3. Add final modifier to RecordWriter#serializers since the content being used as lock. 4. Wrap too long of lines in some of the Java code for readibility. 5. Add missing JavaDoc parameter. 6. Remove final modifier in the OutputEmitter's private methods because it is redundant.
-
由 Fabian Hueske 提交于
This closes #453
-
- 05 3月, 2015 11 次提交
-
-
由 Stephan Ewen 提交于
This closes #455
-
由 Stephan Ewen 提交于
This closes #456
-
由 Maximilian Michels 提交于
-
由 mbalassi 提交于
This closes #449
-
由 Gyula Fora 提交于
[FLINK-1625] [streaming] [api-breaking] Added proper cancellation to StreamInvokables + Sink- and SourceFunction interfaces extended with cancel method
-
由 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 提交于
-