[jira] [Created] (SAMZA-1645) A few issues found by BEAM stress test

Xinyu Liu created SAMZA-1645: Summary: A few issues found by BEAM stress test Key: SAMZA-1645 URL: https://issues.apache.org/jira/browse/SAMZA-1645 Project: Samza Issue Type: Bug

[jira] [Commented] (SAMZA-1643) StreamPartitionCountMonitor should only restart/shut down the job if partition count increases

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

[jira] [Created] (SAMZA-1644) Blocking poll on KafkaConsumer can miss the last batch of messages

Prateek Maheshwari created SAMZA-1644: - Summary: Blocking poll on KafkaConsumer can miss the last batch of messages Key: SAMZA-1644 URL: https://issues.apache.org/jira/browse/SAMZA-1644 Project:

[jira] [Created] (SAMZA-1643) StreamPartitionCountMonitor should only restart/shut down the job if partition count increases

Prateek Maheshwari created SAMZA-1643: - Summary: StreamPartitionCountMonitor should only restart/shut down the job if partition count increases Key: SAMZA-1643 URL:

samza git commit: Upgrade to latest event hub version (1.0.1)

Repository: samza Updated Branches: refs/heads/master 8e000f398 -> fda1e37d0 Upgrade to latest event hub version (1.0.1) * Upgrade to the latest event hub version 1.0.1 * Adding configs for prefetchCount and maxEventPerPoll * Fix the high cpu usage issue in SamzaHistogram * Fixing a race