[CONF] Apache Samza > SEP-18: Startpoints - Manipulating Starting Offsets for Input Streams

2018-12-19 Thread Daniel Nishimura (Confluence)
Title: Message Title There's 1 new edit on this page   SEP-18: Startpoints - Manipulating Starting Offsets for Input Streams Daniel Nishimura edited this page

[jira] [Commented] (SAMZA-1787) Refactor TaskStorageManager to use SSPMetadataCache during init

2018-12-19 Thread Cameron Lee (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725372#comment-16725372 ] Cameron Lee commented on SAMZA-1787: This ticket is not complete. The original PR was closed since

[jira] [Resolved] (SAMZA-1714) Creating shared context factory for shared context objects

2018-12-19 Thread Cameron Lee (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cameron Lee resolved SAMZA-1714. Resolution: Fixed > Creating shared context factory for shared context objects >

[jira] [Assigned] (SAMZA-1923) Update ProcessorLifecycleListenerFactory API to use correct context

2018-12-19 Thread Cameron Lee (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cameron Lee reassigned SAMZA-1923: -- Assignee: (was: Cameron Lee) > Update ProcessorLifecycleListenerFactory API to use

[jira] [Resolved] (SAMZA-1858) Public APIs for shared context

2018-12-19 Thread Cameron Lee (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cameron Lee resolved SAMZA-1858. Resolution: Fixed > Public APIs for shared context > -- > >

[jira] [Resolved] (SAMZA-2012) Add API for wiring an external context through to application processing code

2018-12-19 Thread Cameron Lee (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cameron Lee resolved SAMZA-2012. Resolution: Fixed > Add API for wiring an external context through to application processing code

[jira] [Commented] (SAMZA-1787) Refactor TaskStorageManager to use SSPMetadataCache during init

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

[jira] [Assigned] (SAMZA-1787) Refactor TaskStorageManager to use SSPMetadataCache during init

2018-12-19 Thread Cameron Lee (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cameron Lee reassigned SAMZA-1787: -- Assignee: (was: Cameron Lee) > Refactor TaskStorageManager to use SSPMetadataCache during

[jira] [Updated] (SAMZA-2022) Startpoints - SystemConsumers (not to be confused with SystemConsumer) modifications including integration with MessageChooser.

2018-12-19 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-2022: Description: SystemConsumers multiplexes the register with offset calls to each

[jira] [Updated] (SAMZA-2022) Startpoints - SystemConsumers (not to be confused with SystemConsumer) modifications including integration with MessageChooser.

2018-12-19 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-2022: Description: SystemConsumers multiplexes the register with offset calls to each

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

2018-12-19 Thread Cameron Lee (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-1798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725245#comment-16725245 ] Cameron Lee commented on SAMZA-1798: Ok, it sounds like you are not currently working on this. If

[jira] [Updated] (SAMZA-2046) Startpoints - Fanout of SSP-only keyed Startpoints to SSP+TaskName

2018-12-19 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-2046: Summary: Startpoints - Fanout of SSP-only keyed Startpoints to SSP+TaskName (was:

[jira] [Updated] (SAMZA-2046) Startpoints - Fanout of SSP-only keyed Startpoints to SSP+TaskName

2018-12-19 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-2046: Description: The job coordinators need to call the

[jira] [Updated] (SAMZA-2022) Startpoints - SystemConsumers (not to be confused with SystemConsumer) modifications including integration with MessageChooser.

2018-12-19 Thread Daniel Nishimura (JIRA)
[ https://issues.apache.org/jira/browse/SAMZA-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-2022: Summary: Startpoints - SystemConsumers (not to be confused with SystemConsumer)