[GitHub] [samza] lakshmi-manasa-g opened a new pull request #1448: SAMZA-2606: container orchestration for AM HA

lakshmi-manasa-g opened a new pull request #1448: URL: https://github.com/apache/samza/pull/1448 Feature: Main feature is YARN AM high availability. The feature ensures that the new AM can establish connection with already running containers to avoid restarting all running containers when

[jira] [Created] (SAMZA-2606) Job coordinator High availability - orchestrate container launches by new AM

Lakshmi Manasa Gaduputi created SAMZA-2606: -- Summary: Job coordinator High availability - orchestrate container launches by new AM Key: SAMZA-2606 URL: https://issues.apache.org/jira/browse/SAMZA-2606

[samza] branch master updated: SAMZA-2602: Dynamic heartbeat establish with new AM (#1442)

This is an automated email from the ASF dual-hosted git repository. bharathkk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/samza.git The following commit(s) were added to refs/heads/master by this push: new 3fd456a SAMZA-2602: Dynamic heartbeat establi

[GitHub] [samza] mynameborat merged pull request #1442: SAMZA-2602: Dynamic heartbeat establish with new AM

mynameborat merged pull request #1442: URL: https://github.com/apache/samza/pull/1442 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 t

[GitHub] [samza] MabelYC commented on a change in pull request #1437: SAMZA-2598:Kafka clients are not created and closed properly

MabelYC commented on a change in pull request #1437: URL: https://github.com/apache/samza/pull/1437#discussion_r530062128 ## File path: samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java ## @@ -55,6 +55,7 @@ public MetadataResourceUtil(JobModel job

[GitHub] [samza] MabelYC commented on a change in pull request #1437: SAMZA-2598:Kafka clients are not created and closed properly

MabelYC commented on a change in pull request #1437: URL: https://github.com/apache/samza/pull/1437#discussion_r530061841 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ## @@ -441,15 +441,24 @@ public void afterStop() { @Over

[GitHub] [samza] prateekm commented on a change in pull request #1437: SAMZA-2598:Kafka clients are not created and closed properly

prateekm commented on a change in pull request #1437: URL: https://github.com/apache/samza/pull/1437#discussion_r529790732 ## File path: samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java ## @@ -441,15 +441,24 @@ public void afterStop() { @Ove

[GitHub] [samza] prateekm commented on a change in pull request #1437: SAMZA-2598:Kafka clients are not created and closed properly

prateekm commented on a change in pull request #1437: URL: https://github.com/apache/samza/pull/1437#discussion_r529787680 ## File path: samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java ## @@ -55,6 +55,7 @@ public MetadataResourceUtil(JobModel jo