[jira] [Resolved] (SAMZA-1364) Unclean shutdown of streamApplication in LocalApplicationRunner.kill(streamApplication)

[ https://issues.apache.org/jira/browse/SAMZA-1364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh resolved SAMZA-1364. -- Resolution: Fixed Issue resolved by pull request 246 [https://github.com/apache/samza/pull/246]

samza git commit: Samza-1364: Handle ZKExceptions in zkCoordinationUtils.reset.

Repository: samza Updated Branches: refs/heads/master 95d96b944 -> d32e8bb3a Samza-1364: Handle ZKExceptions in zkCoordinationUtils.reset. In some cases LocalAppRunner.waitForFinish indefinitely blocks after LocalApplicationRunner.kill. Last step in LocalAppRunner.kill(streamApp) is zkClient

[jira] [Commented] (SAMZA-1364) Unclean shutdown of streamApplication in LocalApplicationRunner.kill(streamApplication)

[ https://issues.apache.org/jira/browse/SAMZA-1364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16100983#comment-16100983 ] Navina Ramesh commented on SAMZA-1364: -- [~spvenkat] sorry about the late reply. Yes.

samza git commit: Fix build failures after master merge

Repository: samza Updated Branches: refs/heads/master 57758615b -> 95d96b944 Fix build failures after master merge Changes * Fix checkstyle errors from #243 * Fix failure after bad merge in #244 Author: Shanthoosh Venkataraman Reviewers: Navina Ramesh Closes #252 from shanthoosh/fix_NPE_a

[jira] [Resolved] (SAMZA-1282) Spinning up more containers than the number of tasks kills leader

[ https://issues.apache.org/jira/browse/SAMZA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh resolved SAMZA-1282. -- Resolution: Fixed Issue resolved by pull request 244 [https://github.com/apache/samza/pull/244]

[jira] [Commented] (SAMZA-1282) Spinning up more containers than the number of tasks kills leader

[ https://issues.apache.org/jira/browse/SAMZA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16100887#comment-16100887 ] ASF GitHub Bot commented on SAMZA-1282: --- Github user asfgit closed the pull request

samza git commit: SAMZA-1282: Spinning up more containers than number of tasks.

Repository: samza Updated Branches: refs/heads/master 35143b676 -> 57758615b SAMZA-1282: Spinning up more containers than number of tasks. Changes * Stop streamProcessor in onNewJobModelAvailable eventHandler(instead of onNewJobModelConfirmed eventHandler) when it's not part of the group a

[jira] [Commented] (SAMZA-1370) Memory leak in CachedStore when using ByteBufferSerde as key serde

[ https://issues.apache.org/jira/browse/SAMZA-1370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16100859#comment-16100859 ] ASF GitHub Bot commented on SAMZA-1370: --- GitHub user prateekm opened a pull request:

[jira] [Created] (SAMZA-1370) Memory leak in CachedStore when using ByteBufferSerde as key serde

Prateek Maheshwari created SAMZA-1370: - Summary: Memory leak in CachedStore when using ByteBufferSerde as key serde Key: SAMZA-1370 URL: https://issues.apache.org/jira/browse/SAMZA-1370 Project: S

[jira] [Resolved] (SAMZA-1359) Handle phantom container notifications cleanly during RM fail-over

[ https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1359. - Resolution: Fixed > Handle phantom container notifications cleanly during RM fail-over > -

[jira] [Closed] (SAMZA-1359) Handle phantom container notifications cleanly during RM fail-over

[ https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1359. --- > Handle phantom container notifications cleanly during RM fail-over > ---

[jira] [Commented] (SAMZA-1359) Handle phantom container notifications cleanly during RM fail-over

[ https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16100483#comment-16100483 ] ASF GitHub Bot commented on SAMZA-1359: --- Github user asfgit closed the pull request

samza git commit: SAMZA-1359; Handle phantom container notifications cleanly during an RM fail-over

Repository: samza Updated Branches: refs/heads/master 91b22fd77 -> 35143b676 SAMZA-1359; Handle phantom container notifications cleanly during an RM fail-over 1. Improved our container handling logic to be resilient to phantom notifications. 2. Added a new metric to Samza's ContainerProcessM

samza git commit: Fix log messages from StreamProcessor(onJobModelExpired event).

Repository: samza Updated Branches: refs/heads/master 1c1139399 -> 91b22fd77 Fix log messages from StreamProcessor(onJobModelExpired event). Log messages published in onJobModelExpired event have `processorId` as null. `processorId` is cached as final var in jobCoordinatorListener method. JLS