[jira] [Updated] (SAMZA-1252) LocalApplicationRunner.run() should be asynchronous with support of waitUntilFinish()

2017-05-01 Thread Xinyu Liu (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyu Liu updated SAMZA-1252: - Affects Version/s: 0.13.0 > LocalApplicationRunner.run() should be asynchronous with support of >

[jira] [Created] (SAMZA-1252) LocalApplicationRunner.run() should be asynchronous with support of waitUntilFinish()

2017-05-01 Thread Xinyu Liu (JIRA)
Xinyu Liu created SAMZA-1252: Summary: LocalApplicationRunner.run() should be asynchronous with support of waitUntilFinish() Key: SAMZA-1252 URL: https://issues.apache.org/jira/browse/SAMZA-1252 Project:

samza git commit: SAMZA-1248 - Fix StandAlone barrier start list.

2017-05-01 Thread navina
Repository: samza Updated Branches: refs/heads/master 81b173246 -> ad1f16175 SAMZA-1248 - Fix StandAlone barrier start list. Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/ad1f1617 Tree:

[jira] [Updated] (SAMZA-1248) Fix StandAlone barrier start list.

2017-05-01 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1248: -- Attachment: rb58866.patch > Fix StandAlone barrier start list. >

[jira] [Commented] (SAMZA-1246) ApplicatonRunner.stats() should include exception in case of failure

2017-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991669#comment-15991669 ] ASF GitHub Bot commented on SAMZA-1246: --- GitHub user xinyuiscool opened a pull request:

[jira] [Commented] (SAMZA-1251) Remove DebounceTimer dependency from ZkLeaderElector

2017-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991530#comment-15991530 ] ASF GitHub Bot commented on SAMZA-1251: --- GitHub user navina opened a pull request:

[jira] [Commented] (SAMZA-1249) Fix equality for WindowKey for Non-keyed tumbling windows

2017-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991515#comment-15991515 ] ASF GitHub Bot commented on SAMZA-1249: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (SAMZA-1249) Fix equality for WindowKey for Non-keyed tumbling windows

2017-05-01 Thread Jake Maes (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes resolved SAMZA-1249. -- Resolution: Fixed Fix Version/s: 0.13.0 Issue resolved by pull request 149

samza git commit: SAMZA-1249: Fix equality for WindowKey for Non-keyed tumbling windows

2017-05-01 Thread jmakes
Repository: samza Updated Branches: refs/heads/master 20b427cc8 -> 81b173246 SAMZA-1249: Fix equality for WindowKey for Non-keyed tumbling windows - Fix a `ClassCastException` and an NPE when using Tumbling window without keys - Fix equality and hashCode for `WindowKey` - Refactor the

[jira] [Commented] (SAMZA-1214) Allow users to set a default replication.factor for intermediate topics.

2017-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991511#comment-15991511 ] ASF GitHub Bot commented on SAMZA-1214: --- Github user asfgit closed the pull request at:

samza git commit: SAMZA-1214: Bug - system-scoped stream default configs may not be honored

2017-05-01 Thread jmakes
Repository: samza Updated Branches: refs/heads/master a1e03af0d -> 20b427cc8 SAMZA-1214: Bug - system-scoped stream default configs may not be honored * Re-introduced deprecated system-stream configs into config table * Fixed position of task.consumer.batch.size in config table * Moved

[jira] [Commented] (SAMZA-1250) JobRunner.kill doesn't terminate cleanly with YarnJob.

2017-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991507#comment-15991507 ] ASF GitHub Bot commented on SAMZA-1250: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (SAMZA-1250) JobRunner.kill doesn't terminate cleanly with YarnJob.

2017-05-01 Thread Jake Maes (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes resolved SAMZA-1250. -- Resolution: Fixed Issue resolved by pull request 152 [https://github.com/apache/samza/pull/152] >

[jira] [Updated] (SAMZA-1251) Remove DebounceTimer dependency from ZkLeaderElector

2017-05-01 Thread Navina Ramesh (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Navina Ramesh updated SAMZA-1251: - Description: The debounce timer is currently being passed around in every class with no specific

[jira] [Created] (SAMZA-1251) Remove DebounceTimer dependency from ZkLeaderElector

2017-05-01 Thread Navina Ramesh (JIRA)
Navina Ramesh created SAMZA-1251: Summary: Remove DebounceTimer dependency from ZkLeaderElector Key: SAMZA-1251 URL: https://issues.apache.org/jira/browse/SAMZA-1251 Project: Samza Issue

[jira] [Commented] (SAMZA-1250) JobRunner.kill doesn't terminate cleanly with YarnJob.

2017-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991283#comment-15991283 ] ASF GitHub Bot commented on SAMZA-1250: --- GitHub user jmakes opened a pull request:

[jira] [Created] (SAMZA-1250) JobRunner.kill doesn't terminate cleanly with YarnJob.

2017-05-01 Thread Jake Maes (JIRA)
Jake Maes created SAMZA-1250: Summary: JobRunner.kill doesn't terminate cleanly with YarnJob. Key: SAMZA-1250 URL: https://issues.apache.org/jira/browse/SAMZA-1250 Project: Samza Issue Type: Bug

[jira] [Commented] (SAMZA-1214) Allow users to set a default replication.factor for intermediate topics.

2017-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15991075#comment-15991075 ] ASF GitHub Bot commented on SAMZA-1214: --- GitHub user jmakes opened a pull request:

[jira] [Commented] (SAMZA-1249) Fix equality for WindowKey for Non-keyed tumbling windows

2017-05-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990947#comment-15990947 ] ASF GitHub Bot commented on SAMZA-1249: --- GitHub user vjagadish1989 opened a pull request:

[jira] [Updated] (SAMZA-1249) Fix equality for WindowKey for Non-keyed tumbling windows

2017-05-01 Thread Jagadish (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1249: Description: The following exception results when we check equality between the `WindowKey` in the message

[jira] [Assigned] (SAMZA-1249) Fix equality for WindowKey for Non-keyed tumbling windows

2017-05-01 Thread Jagadish (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish reassigned SAMZA-1249: --- Assignee: Jagadish > Fix equality for WindowKey for Non-keyed tumbling windows >

[jira] [Updated] (SAMZA-1249) Fix equality for WindowKey for Non-keyed tumbling windows

2017-05-01 Thread Jagadish (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1249: Description: The following exception results when we attempt to check equality for WindowKey in the

[jira] [Created] (SAMZA-1249) Fix equality for WindowKey for Non-keyed tumbling windows

2017-05-01 Thread Jagadish (JIRA)
Jagadish created SAMZA-1249: --- Summary: Fix equality for WindowKey for Non-keyed tumbling windows Key: SAMZA-1249 URL: https://issues.apache.org/jira/browse/SAMZA-1249 Project: Samza Issue Type: