[jira] [Updated] (SAMZA-1795) Add retry mechanism to Samza Table

2018-08-01 Thread Peng Du (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Du updated SAMZA-1795: --- Description: Currently, there is no built-in retry mechanism in either local/remote tables. For local table,

[jira] [Created] (SAMZA-1795) Add retry mechanism to Samza Table

2018-08-01 Thread Peng Du (JIRA)
Peng Du created SAMZA-1795: -- Summary: Add retry mechanism to Samza Table Key: SAMZA-1795 URL: https://issues.apache.org/jira/browse/SAMZA-1795 Project: Samza Issue Type: Improvement Repo

[jira] [Updated] (SAMZA-1795) Add retry mechanism to Samza Table

2018-08-01 Thread Peng Du (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Du updated SAMZA-1795: --- Description: Currently, there is no built-in retry mechanism in either local/remote tables. For local table,

samza git commit: SAMZA-1794: setting application acl in launch context

2018-08-01 Thread jagadish
Repository: samza Updated Branches: refs/heads/master 01a1795e5 -> 1d2f054ab SAMZA-1794: setting application acl in launch context Currently we don't set application acl for container launch context. See https://hadoop.apache.org/docs/r2.6.4/api/org/apache/hadoop/yarn/api/records/ContainerLau

[jira] [Commented] (SAMZA-1794) setting application acl in launch context for secured YARN cluster

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566082#comment-16566082 ] ASF GitHub Bot commented on SAMZA-1794: --- Github user asfgit closed the pull request

[jira] [Created] (SAMZA-1796) PassthroughJobCoordinator doesn't create changelog streams

2018-08-01 Thread Xinyu Liu (JIRA)
Xinyu Liu created SAMZA-1796: Summary: PassthroughJobCoordinator doesn't create changelog streams Key: SAMZA-1796 URL: https://issues.apache.org/jira/browse/SAMZA-1796 Project: Samza Issue Type:

[jira] [Resolved] (SAMZA-1794) setting application acl in launch context for secured YARN cluster

2018-08-01 Thread Hai (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai resolved SAMZA-1794. Resolution: Fixed > setting application acl in launch context for secured YARN cluster > --

[jira] [Created] (SAMZA-1797) Move retry logic from EventHubs consumer to BEM

2018-08-01 Thread Jagadish (JIRA)
Jagadish created SAMZA-1797: --- Summary: Move retry logic from EventHubs consumer to BEM Key: SAMZA-1797 URL: https://issues.apache.org/jira/browse/SAMZA-1797 Project: Samza Issue Type: Bug

[jira] [Commented] (SAMZA-1796) PassthroughJobCoordinator doesn't create changelog streams

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566113#comment-16566113 ] ASF GitHub Bot commented on SAMZA-1796: --- GitHub user xinyuiscool opened a pull requ

[jira] [Commented] (SAMZA-1796) PassthroughJobCoordinator doesn't create changelog streams

2018-08-01 Thread Jake Maes (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566120#comment-16566120 ] Jake Maes commented on SAMZA-1796: -- [~xinyu], I assume it doesn't create changelog strea

samza git commit: SAMZA-1796: PassthroughJobCoordinator doesn't create changelog streams

2018-08-01 Thread xinyu
Repository: samza Updated Branches: refs/heads/master 1d2f054ab -> 5587ebfec SAMZA-1796: PassthroughJobCoordinator doesn't create changelog streams Currently only the ClusterBasedJobCoordinator and ZkJobCoordinator are creating changelog streams. The Passthrough one should also do it. Author

[jira] [Commented] (SAMZA-1796) PassthroughJobCoordinator doesn't create changelog streams

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566131#comment-16566131 ] ASF GitHub Bot commented on SAMZA-1796: --- Github user asfgit closed the pull request

samza git commit: SAMZA-1759: Stream Assert utilities for low level and high level api for TestFramework

2018-08-01 Thread boryas
Repository: samza Updated Branches: refs/heads/master 5587ebfec -> 13e26fb45 SAMZA-1759: Stream Assert utilities for low level and high level api for TestFramework Adding utilities and corresponding test for low and high level api Author: Sanil Jain Reviewers: Shanthoosh Venkataraman Clo

[jira] [Resolved] (SAMZA-1759) Stream Assert utilities for low level and high level api for TestFramework

2018-08-01 Thread Sanil Jain (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanil Jain resolved SAMZA-1759. --- Resolution: Fixed > Stream Assert utilities for low level and high level api for TestFramework >

[jira] [Created] (SAMZA-1798) Bugs in MessageStreamAsset does not propagate exceptions to main

2018-08-01 Thread Sanil Jain (JIRA)
Sanil Jain created SAMZA-1798: - Summary: Bugs in MessageStreamAsset does not propagate exceptions to main Key: SAMZA-1798 URL: https://issues.apache.org/jira/browse/SAMZA-1798 Project: Samza Iss

[jira] [Commented] (SAMZA-1733) Improvements to MetricsSnapshotReporter

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566203#comment-16566203 ] ASF GitHub Bot commented on SAMZA-1733: --- GitHub user rmatharu opened a pull request

samza git commit: SAMZA-1733: Adding filter mechanism to MetricsSnapshotReporter

2018-08-01 Thread jagadish
Repository: samza Updated Branches: refs/heads/master 13e26fb45 -> 0c488bbb8 SAMZA-1733: Adding filter mechanism to MetricsSnapshotReporter This regex based filter mechanism allow for blacklisting of metrics being reporter by the Snapshot Reporter, by specifying the blacklist in config. * Ba

[jira] [Commented] (SAMZA-1733) Improvements to MetricsSnapshotReporter

2018-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566239#comment-16566239 ] ASF GitHub Bot commented on SAMZA-1733: --- Github user asfgit closed the pull request

[jira] [Commented] (SAMZA-1796) PassthroughJobCoordinator doesn't create changelog streams

2018-08-01 Thread Bharath Kumarasubramanian (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566400#comment-16566400 ] Bharath Kumarasubramanian commented on SAMZA-1796: -- [~jmakes] One of the