[jira] [Commented] (SAMZA-1667) Skip storing configuration as a part of JobModel in zookeeper data nodes.

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

[jira] [Updated] (SAMZA-1667) Skip storing configuration as a part of JobModel in zookeeper data nodes.

[ https://issues.apache.org/jira/browse/SAMZA-1667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1667: --- Summary: Skip storing configuration as a part of JobModel in zookeeper data

[jira] [Created] (SAMZA-1667) Nuke JobModel configuration in ZkJobCoordinator.

Shanthoosh Venkataraman created SAMZA-1667: -- Summary: Nuke JobModel configuration in ZkJobCoordinator. Key: SAMZA-1667 URL: https://issues.apache.org/jira/browse/SAMZA-1667 Project: Samza

[jira] [Updated] (SAMZA-1665) Fix race condition when stopping StreamProcessor.

[ https://issues.apache.org/jira/browse/SAMZA-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1665: --- Summary: Fix race condition when stopping StreamProcessor. (was: Race

[jira] [Updated] (SAMZA-1665) Race condition when stopping StreamProcessor.

[ https://issues.apache.org/jira/browse/SAMZA-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1665: --- Summary: Race condition when stopping StreamProcessor. (was: Fix race

[jira] [Commented] (SAMZA-1651) Samza-sql: Implement GROUP BY SQL operator

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

[jira] [Commented] (SAMZA-1664) ZkJobCoordinator stability fixes.

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

samza git commit: SAMZA-1651: Samza-sql - Implement GROUP BY SQL operator

Repository: samza Updated Branches: refs/heads/master d7a071b34 -> aac6368a2 SAMZA-1651: Samza-sql - Implement GROUP BY SQL operator Author: Aditya Toomula Reviewers: Srini P Closes #478 from atoomula/groupby1 Project:

samza git commit: SAMZA-1664: ZkJobCoordinator stability fixes.

Repository: samza Updated Branches: refs/heads/master 12968cfb6 -> d7a071b34 SAMZA-1664: ZkJobCoordinator stability fixes. Issues fixed: * Handle job coordinator shutdown gracefully in case of unclean container shutdowns. * Fix the zookeeper session handling logic. * Fix the forever retry

samza git commit: SAMZA-1666: Benchmark SystemProducer and SystemConsumer

Repository: samza Updated Branches: refs/heads/master 5b953ac3e -> 12968cfb6 SAMZA-1666: Benchmark SystemProducer and SystemConsumer * Tests to benchmark the performance of the system consumers and producers. * Config to test the benchmark for the event hub system producer and consumer.

samza git commit: Revert "SAMZA-1645: A few issues found by BEAM stress test"

Repository: samza Updated Branches: refs/heads/master 67ce608f2 -> 5b953ac3e Revert "SAMZA-1645: A few issues found by BEAM stress test" This reverts commit 26294151642283c1cfb51590b51a86d2eaedd11f. Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit:

[jira] [Created] (SAMZA-1665) Fix race condition when stopping StreamProcessor.

Shanthoosh Venkataraman created SAMZA-1665: -- Summary: Fix race condition when stopping StreamProcessor. Key: SAMZA-1665 URL: https://issues.apache.org/jira/browse/SAMZA-1665 Project: Samza

[jira] [Created] (SAMZA-1664) ZkJobCoordinator stability fixes.

Shanthoosh Venkataraman created SAMZA-1664: -- Summary: ZkJobCoordinator stability fixes. Key: SAMZA-1664 URL: https://issues.apache.org/jira/browse/SAMZA-1664 Project: Samza Issue

[jira] [Commented] (SAMZA-1651) Samza-sql: Implement GROUP BY SQL operator

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

[jira] [Commented] (SAMZA-1651) Samza-sql: Implement GROUP BY SQL operator

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

[jira] [Commented] (SAMZA-1651) Samza-sql: Implement GROUP BY SQL operator

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

samza git commit: Initial version for in memory system.

Repository: samza Updated Branches: refs/heads/master 58c39e371 -> 67ce608f2 Initial version for in memory system. Getting the PR out to unblock sanil. Pending tasks 1. Add documentation 2. Add more tests 3. Currently initialization of the stream happens using createStream on admin. We