[GitHub] [samza] ajothomas commented on a diff in pull request #1605: SAMZA-2742: [Pipeline Drain] Add Drain components and integrate them with SamzaContainer and JC

Mon, 13 Jun 2022 13:06:15 -0700 


ajothomas commented on code in PR #1605:
URL: https://github.com/apache/samza/pull/1605#discussion_r896090497


##########
samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java:
##########
@@ -141,6 +142,8 @@ static void run(
               samzaEpochId, config);
       MetricsRegistryMap metricsRegistryMap = new MetricsRegistryMap();
 
+      DrainMonitor drainMonitor = new DrainMonitor(coordinatorStreamStore, 
config);

Review Comment:
   Added the config and calling the constructor only if the config is true.



-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to