[jira] [Resolved] (SAMZA-2026) Refactor remote table API to separate retry policy settings

2018-12-04 Thread Wei Song (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Song resolved SAMZA-2026. - Resolution: Fixed Fix Version/s: 1.1 Issue resolved by pull request 842 [https://github.com/apache

[jira] [Commented] (SAMZA-2026) Refactor remote table API to separate retry policy settings

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

samza git commit: SAMZA-2026: Refactor remote table API to separate retry policy settings

2018-12-04 Thread weisong44
Repository: samza Updated Branches: refs/heads/master cc314be3b -> c7e5dcba4 SAMZA-2026: Refactor remote table API to separate retry policy settings As per subject, the goal is to make configuration of retry policies consistent with other API's. Author: Wei Song Reviewers: Aditya Toomula

[jira] [Commented] (SAMZA-2021) Samza-sql: Adding an API to rel converter to filter out system messages.

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

samza git commit: SAMZA-2021: Adding an API to rel converter to filter out system messages.

2018-12-04 Thread atoomula
Repository: samza Updated Branches: refs/heads/master e47edbe55 -> cc314be3b SAMZA-2021: Adding an API to rel converter to filter out system messages. Author: Aditya Toomula Reviewers: srinipunuru Closes #839 from atoomula/system and squashes the following commits: 0dcba87b [Aditya Toomula

[jira] [Commented] (SAMZA-2025) InputOperatorImpl should work with filtering InputTransformer

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

samza git commit: SAMZA-2025: InputOperatorImpl should work with filtering InputTransformer

2018-12-04 Thread atoomula
Repository: samza Updated Branches: refs/heads/master 0dc9dd24f -> e47edbe55 SAMZA-2025: InputOperatorImpl should work with filtering InputTransformer InputOperatorImpl should handle the case where InputTransformer returns null record. It makes having simple filtering operation as part of the

[jira] [Commented] (SAMZA-2026) Refactor remote table API to separate retry policy settings

2018-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709392#comment-16709392 ] ASF GitHub Bot commented on SAMZA-2026: --- GitHub user weisong44 opened a pull reques

[jira] [Created] (SAMZA-2026) Refactor remote table API to separate retry policy settings

2018-12-04 Thread Wei Song (JIRA)
Wei Song created SAMZA-2026: --- Summary: Refactor remote table API to separate retry policy settings Key: SAMZA-2026 URL: https://issues.apache.org/jira/browse/SAMZA-2026 Project: Samza Issue Type:

[jira] [Commented] (SAMZA-2025) InputOperatorImpl should work with filtering InputTransformer

2018-12-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16709346#comment-16709346 ] ASF GitHub Bot commented on SAMZA-2025: --- GitHub user DEEPTHIKORAT opened a pull req

[jira] [Updated] (SAMZA-2025) InputOperatorImpl should work with filtering InputTransformer

2018-12-04 Thread Deepthi Sridharan (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepthi Sridharan updated SAMZA-2025: - Summary: InputOperatorImpl should work with filtering InputTransformer (was: Allow Input

[jira] [Updated] (SAMZA-2025) Allow InputOperatorImpl to work with filtering InputTransformer

2018-12-04 Thread Deepthi Sridharan (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepthi Sridharan updated SAMZA-2025: - Summary: Allow InputOperatorImpl to work with filtering InputTransformer (was: Allow Inp

samza git commit: Minor fix to some config variable names and accessor methods.

2018-12-04 Thread jagadish
Repository: samza Updated Branches: refs/heads/master 8a22e05c9 -> 0dc9dd24f Minor fix to some config variable names and accessor methods. Author: Prateek Maheshwari Reviewers: Jagadish Closes #840 from prateekm/fix-config-names Project: http://git-wip-us.apache.org/repos/asf/samza/repo C

[jira] [Created] (SAMZA-2025) Allow InputOperatorImpl to filter records

2018-12-04 Thread Deepthi Sridharan (JIRA)
Deepthi Sridharan created SAMZA-2025: Summary: Allow InputOperatorImpl to filter records Key: SAMZA-2025 URL: https://issues.apache.org/jira/browse/SAMZA-2025 Project: Samza Issue Type: I

[jira] [Commented] (SAMZA-1989) SystemStreamGrouper interface change for SEP-5

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

[2/2] samza git commit: SAMZA-1989: SystemStreamGrouper interface change for SEP-5

2018-12-04 Thread jagadish
SAMZA-1989: SystemStreamGrouper interface change for SEP-5 Samza users may need to increase the partition count of the input streams of their stateful samza jobs. For example, Kafka needs to limit the maximum size of each partition to scale up its performance. Thus the number of partitions of a

[1/2] samza git commit: SAMZA-1989: SystemStreamGrouper interface change for SEP-5

2018-12-04 Thread jagadish
Repository: samza Updated Branches: refs/heads/master f4ba9cdc1 -> 8a22e05c9 http://git-wip-us.apache.org/repos/asf/samza/blob/8a22e05c/samza-core/src/test/java/org/apache/samza/container/grouper/stream/TestGroupBySystemStreamPartition.java --

[jira] [Created] (SAMZA-2024) Startpoints - Implement EventHubSystemConsumer#register(SystemStreamPartition, Startpoint) interface.

2018-12-04 Thread Daniel Nishimura (JIRA)
Daniel Nishimura created SAMZA-2024: --- Summary: Startpoints - Implement EventHubSystemConsumer#register(SystemStreamPartition, Startpoint) interface. Key: SAMZA-2024 URL: https://issues.apache.org/jira/browse/SAM

[jira] [Created] (SAMZA-2023) Startpoints - Implement KafkaSystemConsumer#register(SystemStreamPartition, Startpoint) interface.

2018-12-04 Thread Daniel Nishimura (JIRA)
Daniel Nishimura created SAMZA-2023: --- Summary: Startpoints - Implement KafkaSystemConsumer#register(SystemStreamPartition, Startpoint) interface. Key: SAMZA-2023 URL: https://issues.apache.org/jira/browse/SAMZA-

[jira] [Created] (SAMZA-2022) Startpoints - SystemConsumer interface modifications required for Startpoints

2018-12-04 Thread Daniel Nishimura (JIRA)
Daniel Nishimura created SAMZA-2022: --- Summary: Startpoints - SystemConsumer interface modifications required for Startpoints Key: SAMZA-2022 URL: https://issues.apache.org/jira/browse/SAMZA-2022 Pro

[jira] [Updated] (SAMZA-1985) Implement Startpoints model and StartpointManager

2018-12-04 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-1985: Summary: Implement Startpoints model and StartpointManager (was: Implement Startpoints mod

[jira] [Updated] (SAMZA-1985) Implement Startpoints model and StartpointManager

2018-12-04 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-1985: Description: SEP-18 related work. > Implement Startpoints model and StartpointManager > ---