Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.13.0
-
None
-
None
-
None
Description
Clean up the LocalApplicationRunner based on the further feedback. The changes include the following:
- Remove the processorId from the JobCoordinatorFactory/JobCoordinator interfaces
- LocalApplicationRunner.run() is non-blocking. Add LocalApplicationRunner.waitForFinish() for blocking for completion
- Remove the config for CooridnatorServiceFactory, and now the CoordinatorService is created based on the type of JobCoordinator.
- Clean up the StreamProcessor life cycle listener logic inside LocalApplicationRunner.
Attachments
Issue Links
- is depended upon by
-
SAMZA-1130 ApplicationRunner for running StreamApplication
- Resolved
- links to