Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
https://github.com/apache/samza/pull/397 added a "start" and "stop" to the SystemAdmin interface. Most places got updated to manage the lifecycle. However, a few places were missed (or other changes were made more recently that did not correctly manage the lifecycle):
- CoordinatorStreamSystemConsumer starts a SystemAdmin in its "start" method. However, it uses SystemAdmin.getSystemStreamMetadata in "register", which is called before "start". This class properly stops SystemAdmin.
- SystemConsumerBench does not start/stop the SystemAdmin.
- TestRunner does not start/stop the SystemAdmin.