kw2542 commented on a change in pull request #1370:
URL: https://github.com/apache/samza/pull/1370#discussion_r434181614
##########
File path:
samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala
##########
@@ -48,6 +48,23 @@ object CoordinatorStreamUtil extends Logging {
new MapConfig(coordinatorSystemConfig)
}
+ /**
+ * Creates coordinator stream from config.
+ *
+ * @param config to create coordinator stream.
+ */
+ def createCoordinatorStream(config: Config): Unit = {
+ val systemAdmins = new SystemAdmins(config)
+
+ // Create the coordinator stream if it doesn't exist
+ info("Creating coordinator stream")
Review comment:
It is already there, createCoordinatorStream(config: Config) encapsulate
another createCoordinatorStream(coordinatorSystemStream,
coordinatorSystemAdmin) where there is a logging to distinguish actual creation
or no-op.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
