[jira] [Created] (SAMZA-1669) Prioritize preferred host requests over ANY-HOST requests

Jagadish created SAMZA-1669: --- Summary: Prioritize preferred host requests over ANY-HOST requests Key: SAMZA-1669 URL: https://issues.apache.org/jira/browse/SAMZA-1669 Project: Samza Issue Type:

[jira] [Updated] (SAMZA-1668) StreamProcessor shutdown waits indefinitely for SamzaContainer to stop.

[ https://issues.apache.org/jira/browse/SAMZA-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1668: --- Description: Existing StreamProcessor shutdown sequence is the following: #

[jira] [Updated] (SAMZA-1668) StreamProcessor shutdown waits indefinitely for SamzaContainer to stop.

[ https://issues.apache.org/jira/browse/SAMZA-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1668: --- Description: In the current implementation, StreamProcessor shutdown sequence

[jira] [Created] (SAMZA-1668) StreamProcessor shutdown waits indefinitely for SamzaContainer to stop.

Shanthoosh Venkataraman created SAMZA-1668: -- Summary: StreamProcessor shutdown waits indefinitely for SamzaContainer to stop. Key: SAMZA-1668 URL: https://issues.apache.org/jira/browse/SAMZA-1668

[jira] [Closed] (SAMZA-1478) Delete unneeded data from intermediate Kafka topic on offset commit

[ https://issues.apache.org/jira/browse/SAMZA-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari closed SAMZA-1478. - > Delete unneeded data from intermediate Kafka topic on offset commit >

samza git commit: SAMZA-1478: Delete unneeded data from intermediate Kafka topic on offset commit

Repository: samza Updated Branches: refs/heads/master 5d73ecdad -> 3cc2a05f7 SAMZA-1478: Delete unneeded data from intermediate Kafka topic on offset commit Author: Dong Lin Author: Dong Lin Reviewers: Prateek Maheshwari ,

[jira] [Updated] (SAMZA-1653) Support waitForFinish() in remote and add duration to both

[ https://issues.apache.org/jira/browse/SAMZA-1653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1653: - Description: WE need the consistent api for waitForFinish() in remote runner. This is for two reasons:

[2/3] samza git commit: Misc. Util cleanup

http://git-wip-us.apache.org/repos/asf/samza/blob/5d73ecda/samza-core/src/main/scala/org/apache/samza/util/FileUtil.scala -- diff --git a/samza-core/src/main/scala/org/apache/samza/util/FileUtil.scala

[1/3] samza git commit: Misc. Util cleanup

Repository: samza Updated Branches: refs/heads/master bca978eb2 -> 5d73ecdad http://git-wip-us.apache.org/repos/asf/samza/blob/5d73ecda/samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxy.java -- diff

[3/3] samza git commit: Misc. Util cleanup

Misc. Util cleanup Major changes: 1. Broke up 'Util' class into multiple classes: 'FileUtil', 'HttpUtil', 'CoordinatorStreamUtil'. 2. Consolidated some Util classes: MathUtil, ScalaJavaUtil 3. Removed redundant Util classes: ClassloaderUtil, ScalaToJavaUtil 4. Renamed some Util classes for

[jira] [Resolved] (SAMZA-1666) Benchmark Samza SystemProducers and Consumers

[ https://issues.apache.org/jira/browse/SAMZA-1666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivasulu Punuru resolved SAMZA-1666. --- Resolution: Fixed > Benchmark Samza SystemProducers and Consumers >

[jira] [Assigned] (SAMZA-1666) Benchmark Samza SystemProducers and Consumers

[ https://issues.apache.org/jira/browse/SAMZA-1666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Srinivasulu Punuru reassigned SAMZA-1666: - Assignee: Srinivasulu Punuru > Benchmark Samza SystemProducers and Consumers >

[jira] [Commented] (SAMZA-1640) JobModel Json deserialization error in ZkJobCoordinator

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

samza git commit: SAMZA-1640: JobModel Json deserialization error in ZkJobCoordinator.

Repository: samza Updated Branches: refs/heads/master aac6368a2 -> bca978eb2 SAMZA-1640: JobModel Json deserialization error in ZkJobCoordinator. Author: Shanthoosh Venkataraman Author: Shanthoosh Venkataraman Reviewers: