- 14 12月, 2017 1 次提交
-
-
由 zentol 提交于
-
- 13 12月, 2017 14 次提交
-
-
由 gyao 提交于
Implement SubmittedJobGraphListener interface in Dispatcher Call start() on SubmittedJobGraphStore with Dispatcher as listener. To enable this, the dispatcher must implement the SubmittedJobGraphListener interface. Add simple unit tests for the new methods. Refactor DispatcherTest to remove redundancy. [FLINK-8176][flip6] Make InMemorySubmittedJobGraphStore thread-safe [FLINK-8176][flip6] Add method isStarted() to TestingLeaderElectionService [FLINK-8176][flip6] Return same RunningJobsRegistry instance from TestingHighAvailabilityServices [FLINK-8176][flip6] Fix race conditions in Dispatcher and DispatcherTest Check if jobManagerRunner exists before submitting job. Replace JobManagerRunner mock used in tests with real instance. Do not run job graph recovery in actor main thread when job graph is recovered from SubmittedJobGraphListener#onAddedJobGraph(JobID). [FLINK-8176][flip6] Rename variables in DispatcherTest [FLINK-8176][flip6] Remove injectMocks in DispatcherTest [FLINK-8176][flip6] Update Dispatcher's SubmittedJobGraphListener callbacks Always attempt the job submission if onAddedJobGraph or onRemovedJobGraph are called. The checks in submitJob and removeJob are sufficient. This closes #5107.
-
由 gyao 提交于
-
由 gyao 提交于
-
由 Bowen Li 提交于
This closes #5129.
-
由 Joerg Schad 提交于
This closes #5157.
-
由 zentol 提交于
This closes #5153.
-
由 zentol 提交于
-
由 zentol 提交于
-
由 zentol 提交于
This closes #8213.
-
由 zentol 提交于
This closes #5099.
-
由 Nico Kruber 提交于
-
由 Nico Kruber 提交于
This closes #5127.
-
由 Nico Kruber 提交于
Previously, the ResultPartitionWriter implemented the EventListener interface and was used for event registration, although event publishing was already handled via the TaskEventDispatcher. Now, we use the TaskEventDispatcher for both, event registration and publishing. It also adds the TaskEventDispatcher to the Environment information for a task to be able to work with it (only IterationHeadTask so far). This closes #4761.
-
由 Nico Kruber 提交于
This closes #5147.
-
- 12 12月, 2017 4 次提交
-
-
由 zentol 提交于
This closes #5146.
-
由 Tony Wei 提交于
This closes #5115.
-
由 Nico Kruber 提交于
This closes #5064.
-
由 Raycee 提交于
This closes #5152.
-
- 08 12月, 2017 1 次提交
-
-
由 zentol 提交于
-
- 07 12月, 2017 1 次提交
-
-
由 zentol 提交于
This closes #5052.
-
- 06 12月, 2017 7 次提交
-
-
由 kkloudas 提交于
-
由 kkloudas 提交于
-
由 kkloudas 提交于
-
由 Aljoscha Krettek 提交于
-
由 Eron Wright 提交于
[FLINK-8174] Mesos RM unable to accept offers for unreserved resources - added test `OfferTest` [FLINK-8174] Mesos RM unable to accept offers for unreserved resources - fix `LaunchCoordinatorTest` [FLINK-8174] Mesos RM unable to accept offers for unreserved resources - improved javadocs [FLINK-8174] Mesos RM unable to accept offers for unreserved resources - rename `print` to `toString` - precalculate offer resource values - extend TestLogger This closes #5114.
-
由 zentol 提交于
This closes #5118.
-
由 Till Rohrmann 提交于
The TaskManagerServicesTest was extremely slow because it uses the PowerMockRunner for a single test case. Additionally some other tests test different settings in a loop which was quite slow because the PowerMockRunner instrumented all method calls. Moving the test which required the PowerMockRunner into a separate test class sped up things by a factor of 50.
-
- 05 12月, 2017 10 次提交
-
-
由 Aljoscha Krettek 提交于
Before, AvroUtils were loaded when the class was loaded which didn't take into account the user-code ClassLoader. Now, we try loading avro utils with the Thread context ClassLoader.
-
由 Till Rohrmann 提交于
Replace wait on lock with OneShotLatch to resolve race condition between task start up and unblocking of invokable.
-
由 zentol 提交于
-
由 zentol 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
-
由 Tzu-Li (Gordon) Tai 提交于
This closes #5117.
-
由 Aljoscha Krettek 提交于
-
- 04 12月, 2017 2 次提交
-
-
由 Till Rohrmann 提交于
-
由 zentol 提交于
This closes #4504.
-