[jira] [Resolved] (SAMZA-1782) Make getTableSpecs API in TableConfigGenerator util class public

2018-09-10 Thread Prateek Maheshwari (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1782. --- Resolution: Fixed > Make getTableSpecs API in TableConfigGenerator util class public

[jira] [Resolved] (SAMZA-1803) Make InMemoryManager system aware

2018-09-10 Thread Prateek Maheshwari (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1803. --- Resolution: Fixed > Make InMemoryManager system aware >

[jira] [Resolved] (SAMZA-1806) Configuring task.broadcast.inputs to an empty string raises IllegalArgumentException

2018-09-10 Thread Prateek Maheshwari (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari resolved SAMZA-1806. --- Resolution: Fixed > Configuring task.broadcast.inputs to an empty string raises >

[jira] [Updated] (SAMZA-1868) Refactor KafkaSystemAdmin from using SimpleConsumer

2018-09-10 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1868: -- Description: Convert it into using KafkaSystemConsumer. Aslo, move getClientId into

[jira] [Created] (SAMZA-1869) Refactor KafkaSystemConsumer from using SImpleConsumer

2018-09-10 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1869: - Summary: Refactor KafkaSystemConsumer from using SImpleConsumer Key: SAMZA-1869 URL: https://issues.apache.org/jira/browse/SAMZA-1869 Project: Samza Issue

[jira] [Updated] (SAMZA-1868) Refactor KafkaSystemAdmin from using SimpleConsumer

2018-09-10 Thread Boris Shkolnik (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1868: -- Issue Type: Sub-task (was: Bug) Parent: SAMZA-1793 > Refactor KafkaSystemAdmin from

[jira] [Assigned] (SAMZA-1852) Clean up TestRunner APIs to auto-generate configs

2018-09-10 Thread Prateek Maheshwari (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prateek Maheshwari reassigned SAMZA-1852: - Assignee: Sanil Jain > Clean up TestRunner APIs to auto-generate configs >

[jira] [Created] (SAMZA-1868) Refactor KafkaSystemAdmin from using SimpleConsumer

2018-09-10 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1868: - Summary: Refactor KafkaSystemAdmin from using SimpleConsumer Key: SAMZA-1868 URL: https://issues.apache.org/jira/browse/SAMZA-1868 Project: Samza Issue

[jira] [Commented] (SAMZA-1865) Flaky test: TestZkLocalApplicationRunner shouldReElectLeaderWhenLeaderDies

2018-09-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16609511#comment-16609511 ] ASF GitHub Bot commented on SAMZA-1865: --- GitHub user shanthoosh opened a pull request:

[jira] [Created] (SAMZA-1867) make KafkaSystemAdmin compareOffset method static

2018-09-10 Thread Boris Shkolnik (JIRA)
Boris Shkolnik created SAMZA-1867: - Summary: make KafkaSystemAdmin compareOffset method static Key: SAMZA-1867 URL: https://issues.apache.org/jira/browse/SAMZA-1867 Project: Samza Issue

[jira] [Assigned] (SAMZA-1865) Flaky test: TestZkLocalApplicationRunner shouldReElectLeaderWhenLeaderDies

2018-09-10 Thread Shanthoosh Venkataraman (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shanthoosh Venkataraman reassigned SAMZA-1865: -- Assignee: Shanthoosh Venkataraman > Flaky test:

[jira] [Commented] (SAMZA-1824) Samza AM does not handle some failures during container launch

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

samza git commit: SAMZA-1824: Handle errors from the async-NMClient when launching containers

2018-09-10 Thread jagadish
Repository: samza Updated Branches: refs/heads/master ed621b269 -> 666835186 SAMZA-1824: Handle errors from the async-NMClient when launching containers - Updated internal state that tracks "pending" containers correctly - Refactored `YarnClusterResourceManager` for testability. Add an unit

[jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer

2018-09-10 Thread Jake Maes (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16609486#comment-16609486 ] Jake Maes commented on SAMZA-1866: -- [~voronenko-da] Dong is going to take a look at SAMZA-839 > Invalid

[jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer

2018-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16609455#comment-16609455 ] Dong Lin commented on SAMZA-1866: - [~jmakes] Of course. I will work on that JIRA. > Invalid partition

[jira] [Assigned] (SAMZA-839) KafkaSystemProducer should use the same partitioning hash function as Kafka's producer

2018-09-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned SAMZA-839: -- Assignee: Dong Lin > KafkaSystemProducer should use the same partitioning hash function as Kafka's >

[jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer

2018-09-10 Thread Voronenko Dmitriy (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16609392#comment-16609392 ] Voronenko Dmitriy commented on SAMZA-1866: -- First I'll put out the fire in the production. After

[jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer

2018-09-10 Thread Jake Maes (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16609367#comment-16609367 ] Jake Maes commented on SAMZA-1866: -- [~voronenko-da] agreed. [~lindong] would you be able to pick up

[jira] [Resolved] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer

2018-09-10 Thread Voronenko Dmitriy (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Voronenko Dmitriy resolved SAMZA-1866. -- Resolution: Duplicate Duplicate https://issues.apache.org/jira/browse/SAMZA-839 this

[jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer

2018-09-10 Thread Voronenko Dmitriy (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16609098#comment-16609098 ] Voronenko Dmitriy commented on SAMZA-1866: -- Duplicate

[jira] [Created] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer

2018-09-10 Thread Voronenko Dmitriy (JIRA)
Voronenko Dmitriy created SAMZA-1866: Summary: Invalid partition calculation in KafkaSystemProducer Key: SAMZA-1866 URL: https://issues.apache.org/jira/browse/SAMZA-1866 Project: Samza