samza git commit: Update SNAPSHOT version for 0.13 release

Repository: samza Updated Branches: refs/heads/0.13.0 f6d0d6551 -> 9f60e980b Update SNAPSHOT version for 0.13 release Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/9f60e980 Tree: http://git-wip-us.apache.org/repos/asf/sa

[samza] Git Push Summary

Repository: samza Updated Branches: refs/heads/0.13.0 [created] f6d0d6551

[samza] Git Push Summary

Repository: samza Updated Tags: refs/tags/release-0.13.0-rc0 [created] 170d9fac5

[jira] [Updated] (SAMZA-1284) HappyPath Testing. Rolling Upgrades.

[ https://issues.apache.org/jira/browse/SAMZA-1284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh updated SAMZA-1284: - Issue Type: Task (was: Sub-task) Parent: (was: SAMZA-1064) > HappyPath Testing. Rolli

[jira] [Updated] (SAMZA-1258) HappyPathTesting. Single and multiple processors happy path.

[ https://issues.apache.org/jira/browse/SAMZA-1258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh updated SAMZA-1258: - Issue Type: Task (was: Sub-task) Parent: (was: SAMZA-1064) > HappyPathTesting. Single

[jira] [Created] (SAMZA-1284) HappyPath Testing. Rolling Upgrades.

Boris Shkolnik created SAMZA-1284: - Summary: HappyPath Testing. Rolling Upgrades. Key: SAMZA-1284 URL: https://issues.apache.org/jira/browse/SAMZA-1284 Project: Samza Issue Type: Sub-task

[jira] [Resolved] (SAMZA-1283) Expose the buffered-message-size metric from BlockingEnvelopeMap

[ https://issues.apache.org/jira/browse/SAMZA-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu resolved SAMZA-1283. -- Resolution: Fixed Fix Version/s: 0.13.0 > Expose the buffered-message-size metric from BlockingEn

[jira] [Commented] (SAMZA-871) Implement heart-beat mechanism between JobCoordinator and all running containers

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

[jira] [Commented] (SAMZA-1279) list of children in onProcessorsChange throws NPE when there an exception in ZK

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

samza git commit: SAMZA-871; Heart-beat mechanism between JobCoordinator and all running containers

Repository: samza Updated Branches: refs/heads/master 46b1333c4 -> f6d0d6551 SAMZA-871; Heart-beat mechanism between JobCoordinator and all running containers Author: Abhishek Shivanna Reviewers: Navina Ramesh , Jagadish V Closes #163 from abhishekshivanna/master Project: http://git-wip

samza git commit: SAMZA-1279: Do not process onProcessorChange if list of children is null.

Repository: samza Updated Branches: refs/heads/master 71930e22f -> 46b1333c4 SAMZA-1279: Do not process onProcessorChange if list of children is null. Author: Boris Shkolnik Reviewers: Navina Ramesh Closes #180 from sborya/NPEinCaseOfZKException Project: http://git-wip-us.apache.org/repo

[jira] [Commented] (SAMZA-524) Update KafkaSystemProducer after Kafka provides a flush behavior

[ https://issues.apache.org/jira/browse/SAMZA-524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005676#comment-16005676 ] Prateek Maheshwari commented on SAMZA-524: -- Kafka producer flush API is now availa

[jira] [Commented] (SAMZA-1283) Expose the buffered-message-size metric from BlockingEnvelopeMap

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

[jira] [Updated] (SAMZA-524) Update KafkaSystemProducer after Kafka provides a flush behavior

[ https://issues.apache.org/jira/browse/SAMZA-524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-524: - Fix Version/s: 0.14.0 > Update KafkaSystemProducer after Kafka provides a flush behavior >

samza git commit: SAMZA-1283: Expose the buffered-message-size metric

Repository: samza Updated Branches: refs/heads/master 36b2f23bb -> 71930e22f SAMZA-1283: Expose the buffered-message-size metric Regardless of whether we enable size limit for the consumer buffer, this metric helps to see what's the buffer size and make configuring size limit easier. Author:

[jira] [Updated] (SAMZA-1185) Document async commit support in configuration table and feature information

[ https://issues.apache.org/jira/browse/SAMZA-1185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1185: -- Summary: Document async commit support in configuration table and feature information (

[jira] [Resolved] (SAMZA-1272) ZkCoordinationUtils deletes the entire Zk tree on reset

[ https://issues.apache.org/jira/browse/SAMZA-1272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh resolved SAMZA-1272. -- Resolution: Fixed > ZkCoordinationUtils deletes the entire Zk tree on reset > --

[jira] [Resolved] (SAMZA-1142) Create documentation for non blocking commit in AsyncRunLoop.

[ https://issues.apache.org/jira/browse/SAMZA-1142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1142. --- Resolution: Duplicate > Create documentation for non blocking commit in AsyncRunLoop.

[jira] [Reopened] (SAMZA-1272) ZkCoordinationUtils deletes the entire Zk tree on reset

[ https://issues.apache.org/jira/browse/SAMZA-1272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh reopened SAMZA-1272: -- > ZkCoordinationUtils deletes the entire Zk tree on reset >

[jira] [Commented] (SAMZA-1185) Document async commit support in configuration table

[ https://issues.apache.org/jira/browse/SAMZA-1185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005656#comment-16005656 ] Prateek Maheshwari commented on SAMZA-1185: --- [~spvenkat] This ticket is also for

[jira] [Updated] (SAMZA-1279) list of children in onProcessorsChange throws NPE when there an exception in ZK

[ https://issues.apache.org/jira/browse/SAMZA-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh updated SAMZA-1279: - Issue Type: Bug (was: Sub-task) Parent: (was: SAMZA-1064) > list of children in onPro

[jira] [Updated] (SAMZA-1183) Fix TestAsyncRunLoop flaky tests

[ https://issues.apache.org/jira/browse/SAMZA-1183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1183: -- Priority: Major (was: Minor) > Fix TestAsyncRunLoop flaky tests > -

[jira] [Commented] (SAMZA-1283) Expose the buffered-message-size metric from BlockingEnvelopeMap

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

[jira] [Updated] (SAMZA-1283) Expose the buffered-message-size metric from BlockingEnvelopeMap

[ https://issues.apache.org/jira/browse/SAMZA-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1283: - Affects Version/s: 0.13.0 > Expose the buffered-message-size metric from BlockingEnvelopeMap > ---

[jira] [Created] (SAMZA-1283) Expose the buffered-message-size metric from BlockingEnvelopeMap

Xinyu Liu created SAMZA-1283: Summary: Expose the buffered-message-size metric from BlockingEnvelopeMap Key: SAMZA-1283 URL: https://issues.apache.org/jira/browse/SAMZA-1283 Project: Samza Issue

[jira] [Assigned] (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 ] Bharath Kumarasubramanian reassigned SAMZA-1282: Assignee: Navina Ramesh > Spinning up more containers than the numb

[jira] [Created] (SAMZA-1282) Spinning up more containers than the number task kills leader

Bharath Kumarasubramanian created SAMZA-1282: Summary: Spinning up more containers than the number task kills leader Key: SAMZA-1282 URL: https://issues.apache.org/jira/browse/SAMZA-1282 P

[jira] [Updated] (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 ] Bharath Kumarasubramanian updated SAMZA-1282: - Summary: Spinning up more containers than the number of tasks kills leader

[jira] [Commented] (SAMZA-1281) Flaky test: TestBrokerProxy brokerProxyUpdateLatencyMetrics

[ https://issues.apache.org/jira/browse/SAMZA-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005597#comment-16005597 ] Prateek Maheshwari commented on SAMZA-1281: --- Not disabling right now since this

[jira] [Created] (SAMZA-1281) Flaky test: TestBrokerProxy brokerProxyUpdateLatencyMetrics

Prateek Maheshwari created SAMZA-1281: - Summary: Flaky test: TestBrokerProxy brokerProxyUpdateLatencyMetrics Key: SAMZA-1281 URL: https://issues.apache.org/jira/browse/SAMZA-1281 Project: Samza

[jira] [Created] (SAMZA-1280) add documentation for general resource localization support in yarn

Fred Ji created SAMZA-1280: -- Summary: add documentation for general resource localization support in yarn Key: SAMZA-1280 URL: https://issues.apache.org/jira/browse/SAMZA-1280 Project: Samza Issue

[jira] [Commented] (SAMZA-1277) Add a static merge() operator that takes all streams to merge as input

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

[jira] [Resolved] (SAMZA-1277) Add a static merge() operator that takes all streams to merge as input

[ https://issues.apache.org/jira/browse/SAMZA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes resolved SAMZA-1277. -- Resolution: Fixed Issue resolved by pull request 182 [https://github.com/apache/samza/pull/182] > Add a

samza git commit: SAMZA-1277: Add a static merge() operator that takes all streams to merge as input

Repository: samza Updated Branches: refs/heads/master 601c11d87 -> 36b2f23bb SAMZA-1277: Add a static merge() operator that takes all streams to merge as input Also updated documentation for join and partitionBy. Author: Prateek Maheshwari Reviewers: Jacob Maes Closes #182 from prateekm/

[jira] [Commented] (SAMZA-1269) Flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop

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

[jira] [Commented] (SAMZA-1277) Add a static merge() operator that takes all streams to merge as input

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

[jira] [Commented] (SAMZA-1269) Flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop

[ https://issues.apache.org/jira/browse/SAMZA-1269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005459#comment-16005459 ] Prateek Maheshwari commented on SAMZA-1269: --- Another test in this class failed:

[jira] [Assigned] (SAMZA-1277) Add a static merge() operator that takes all streams to merge as input

[ https://issues.apache.org/jira/browse/SAMZA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari reassigned SAMZA-1277: - Assignee: Prateek Maheshwari > Add a static merge() operator that takes all strea

[jira] [Updated] (SAMZA-1277) Add a static merge() operator that takes all streams to merge as input

[ https://issues.apache.org/jira/browse/SAMZA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1277: -- Fix Version/s: (was: 0.14.0) 0.13.0 > Add a static merge() operat

[jira] [Updated] (SAMZA-1277) Add a static merge() operator that takes all streams to merge as input

[ https://issues.apache.org/jira/browse/SAMZA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari updated SAMZA-1277: -- Summary: Add a static merge() operator that takes all streams to merge as input (was: m

samza git commit: Minor: Re-word a couple of lines in javadoc with explicit notes about failures

Repository: samza Updated Branches: refs/heads/master 5eb470c02 -> 601c11d87 Minor: Re-word a couple of lines in javadoc with explicit notes about failures Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/601c11d8 Tree: htt

[jira] [Updated] (SAMZA-1278) Add Adjunct Data Store for Unbounded DataSets

[ https://issues.apache.org/jira/browse/SAMZA-1278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Song updated SAMZA-1278: Description: Samza today supports RocksDB and MemDB as local data stores, which enables users to cache data

samza git commit: Revert "Disable flaky tests."

Repository: samza Updated Branches: refs/heads/master df5aa6c4e -> 5eb470c02 Revert "Disable flaky tests." This reverts commit df5aa6c4eeb9b89a40780b19e08bb6d96b97730b. Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/5eb4

[jira] [Commented] (SAMZA-1279) list of children in onProcessorsChange throws NPE when there an exception in ZK

[ https://issues.apache.org/jira/browse/SAMZA-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16005199#comment-16005199 ] Navina Ramesh commented on SAMZA-1279: -- [~boryas] Is the exception in ZkClient? What

[jira] [Commented] (SAMZA-1193) Fix the flaky test TestZkBarrierForVersionUpgrade.testZkBarrierForVersionUpgrade

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

[jira] [Created] (SAMZA-1279) list of children in onProcessorsChange throws NPE when there an exception in ZK

Boris Shkolnik created SAMZA-1279: - Summary: list of children in onProcessorsChange throws NPE when there an exception in ZK Key: SAMZA-1279 URL: https://issues.apache.org/jira/browse/SAMZA-1279 Proje

[jira] [Commented] (SAMZA-1064) Standalone Samza with Zookeeper for Coordination

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

[jira] [Created] (SAMZA-1278) Add Adjunct Data Store for Unbounded DataSets

Wei Song created SAMZA-1278: --- Summary: Add Adjunct Data Store for Unbounded DataSets Key: SAMZA-1278 URL: https://issues.apache.org/jira/browse/SAMZA-1278 Project: Samza Issue Type: Improvement

samza git commit: Disable flaky tests.

Repository: samza Updated Branches: refs/heads/master c50dd080b -> df5aa6c4e Disable flaky tests. Author: Shanthoosh Venkataraman Reviewers: Navina Ramesh Closes #158 from shanthoosh/master Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/rep