[jira] [Commented] (SAMZA-1649) Improve host-aware allocation to account for strict locality

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

samza git commit: SAMZA-1649: Improve host-aware allocation to account for strict locality

Repository: samza Updated Branches: refs/heads/master 96c333469 -> b6219f181 SAMZA-1649: Improve host-aware allocation to account for strict locality Currently working on a doc for the behavior of the CapacityScheduler and further testing is needed on an actual cluster - but here's a summary

[jira] [Updated] (SAMZA-1655) StreamProcessor skips all events from zookeeper server after zkClient session expiration.

[ https://issues.apache.org/jira/browse/SAMZA-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1655: --- Description: *Problem:* StreamProcessor skips all events from zookeeper

[jira] [Updated] (SAMZA-1655) StreamProcessor skips all events from zookeeper server after zkClient session expiration.

[ https://issues.apache.org/jira/browse/SAMZA-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1655: --- Description: *Problem:* StreamProcessor skips all events from zookeeper

[jira] [Commented] (SAMZA-1650) Window high level API: Trigger is not fired at the end of trigger interval for tumbling window

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

samza git commit: SAMZA-1650: Fix for firing trigger at the end of trigger interval for tumbling window

Repository: samza Updated Branches: refs/heads/master 76de840c7 -> 96c333469 SAMZA-1650: Fix for firing trigger at the end of trigger interval for tumbling window Author: Aditya Toomula Reviewers: Jagadish Closes #472 from atoomula/window

[jira] [Commented] (SAMZA-1650) Window high level API: Trigger is not fired at the end of trigger interval for tumbling window

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

[jira] [Commented] (SAMZA-1584) Improve logging in StreamProcessor.

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

[jira] [Resolved] (SAMZA-1584) Improve logging in StreamProcessor.

[ https://issues.apache.org/jira/browse/SAMZA-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1584. --- Resolution: Fixed > Improve logging in StreamProcessor. >

samza git commit: SAMZA-1584: Improve logging in StreamProcessor.

Repository: samza Updated Branches: refs/heads/master 3895a9070 -> 76de840c7 SAMZA-1584: Improve logging in StreamProcessor. Add the processorID in the log lines wherever necessary(since we support running multiple stream applications in a JVM) and improving logging in general in

[jira] [Updated] (SAMZA-1655) StreamProcessor skips all events from zookeeper server after zkClient session expiration.

[ https://issues.apache.org/jira/browse/SAMZA-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1655: --- Description: *Problem:* StreamProcessor skips all events from zookeeper

[jira] [Commented] (SAMZA-1655) StreamProcessor skips all events from zookeeper server after zkClient session expiration.

[ https://issues.apache.org/jira/browse/SAMZA-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16436310#comment-16436310 ] Shanthoosh Venkataraman commented on SAMZA-1655: [~xinyu] [~jagadish1...@gmail.com]

[jira] [Commented] (SAMZA-1655) StreamProcessor skips all events from zookeeper server after zkClient session expiration.

[ https://issues.apache.org/jira/browse/SAMZA-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16436304#comment-16436304 ] Shanthoosh Venkataraman commented on SAMZA-1655: *Fix:* A. Route all the watcher events

[jira] [Updated] (SAMZA-1655) StreamProcessor skips all events from zookeeper server after zkClient session expiration.

[ https://issues.apache.org/jira/browse/SAMZA-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman updated SAMZA-1655: --- Description: *Problem:* StreamProcessor skips all events from zookeeper

[jira] [Created] (SAMZA-1655) StreamProcessor skips all events from zookeeper server after zkClient session expiration.

Shanthoosh Venkataraman created SAMZA-1655: -- Summary: StreamProcessor skips all events from zookeeper server after zkClient session expiration. Key: SAMZA-1655 URL:

samza git commit: minor fix on eventhubs size limit for event body and partition key

Repository: samza Updated Branches: refs/heads/master bbcf14eba -> 3895a9070 minor fix on eventhubs size limit for event body and partition key Author: Hai Lu Reviewers: Jagadish , Srinivasulu Punuru Closes #470 from

[jira] [Created] (SAMZA-1654) calculate the exact size of the AMQP message for skipping large message

Hai created SAMZA-1654: -- Summary: calculate the exact size of the AMQP message for skipping large message Key: SAMZA-1654 URL: https://issues.apache.org/jira/browse/SAMZA-1654 Project: Samza Issue

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

Xinyu Liu created SAMZA-1653: Summary: Support waitForFinish() in remote and add duration to both Key: SAMZA-1653 URL: https://issues.apache.org/jira/browse/SAMZA-1653 Project: Samza Issue Type:

[jira] [Commented] (SAMZA-1649) Improve host-aware allocation to account for strict locality

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

[jira] [Created] (SAMZA-1652) Window high level API: End Of Stream message does not fire Window trigger

Aditya created SAMZA-1652: - Summary: Window high level API: End Of Stream message does not fire Window trigger Key: SAMZA-1652 URL: https://issues.apache.org/jira/browse/SAMZA-1652 Project: Samza

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

Aditya created SAMZA-1651: - Summary: Samza-sql: Implement GROUP BY SQL operator Key: SAMZA-1651 URL: https://issues.apache.org/jira/browse/SAMZA-1651 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1649) Improve host-aware allocation to account for strict locality

Jagadish created SAMZA-1649: --- Summary: Improve host-aware allocation to account for strict locality Key: SAMZA-1649 URL: https://issues.apache.org/jira/browse/SAMZA-1649 Project: Samza Issue

[jira] [Created] (SAMZA-1648) Collection Stream

Sanil Jain created SAMZA-1648: - Summary: Collection Stream Key: SAMZA-1648 URL: https://issues.apache.org/jira/browse/SAMZA-1648 Project: Samza Issue Type: New Feature Components: