[
https://issues.apache.org/jira/browse/SAMZA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2334:
Description: Changes in partition count of input Kafka topic that is not a
multiple of
Daniel Nishimura created SAMZA-2334:
---
Summary: ProxyGrouper selection based on Host Affinity not whether
job is stateful
Key: SAMZA-2334
URL: https://issues.apache.org/jira/browse/SAMZA-2334
[
https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-1990:
Description:
Consider the following scenario: A StreamApplication containing two pipelines
Daniel Nishimura created SAMZA-2323:
---
Summary: Provide option to stop/fail single containers
Key: SAMZA-2323
URL: https://issues.apache.org/jira/browse/SAMZA-2323
Project: Samza
Issue
Daniel Nishimura created SAMZA-2322:
---
Summary: Startpoints ZK Standalone Integration test.
Key: SAMZA-2322
URL: https://issues.apache.org/jira/browse/SAMZA-2322
Project: Samza
Issue Type:
Daniel Nishimura created SAMZA-2317:
---
Summary: ProcessJobFactory does not hook in
CoordinatorStreamStore#stop()
Key: SAMZA-2317
URL: https://issues.apache.org/jira/browse/SAMZA-2317
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-2149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2149.
---
> Generalize startpoint SSP to task fanout API
>
>
[
https://issues.apache.org/jira/browse/SAMZA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2143.
---
> NPE in CoordinatorStreamMessage#equals and some clean-up to
> CoordinatorStreamSystemConsumer
[
https://issues.apache.org/jira/browse/SAMZA-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2138.
---
> Incorrect logging when task to container mapping is written.
>
[
https://issues.apache.org/jira/browse/SAMZA-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2144.
---
> In TaskInstance, bypass "SSP caught-up" check if offset is set by a
> startpoint
>
[
https://issues.apache.org/jira/browse/SAMZA-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2215.
---
> StartpointManager fix for previous CoordinatorStreamStore refactor
>
[
https://issues.apache.org/jira/browse/SAMZA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2171.
---
> Encapsulate creation and loading of metadata streams
>
[
https://issues.apache.org/jira/browse/SAMZA-2266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2266.
---
> Introduce a backoff when there are repeated failures for host-affinity
> allocations
>
[
https://issues.apache.org/jira/browse/SAMZA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2260.
---
> Standalone: Share metadata store between StreamProcessor and JobCoordinator
>
[
https://issues.apache.org/jira/browse/SAMZA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2220.
---
> Startpoints - Fully encapsulate resolution of starting offsets in
> OffsetManager
>
[
https://issues.apache.org/jira/browse/SAMZA-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2296.
---
> Metadata streams not created in Standalone
> --
>
>
[
https://issues.apache.org/jira/browse/SAMZA-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2294.
---
> LocalApplicationRunner support for missing coordinator stream
>
[
https://issues.apache.org/jira/browse/SAMZA-2277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2277.
---
> Semantics for cluster-manager.container.retry.window.ms not reflected in code
>
[
https://issues.apache.org/jira/browse/SAMZA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2278.
---
> Add a "delete all" for startpoint manager
> -
>
>
[
https://issues.apache.org/jira/browse/SAMZA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2298.
---
> Fix CoordinatorStreamStore creation for LocalApplicationRunner
>
[
https://issues.apache.org/jira/browse/SAMZA-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura reassigned SAMZA-2310:
---
Assignee: (was: Daniel Nishimura)
> Samza framework should differentiate
[
https://issues.apache.org/jira/browse/SAMZA-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916893#comment-16916893
]
Daniel Nishimura commented on SAMZA-2310:
-
Thanks [~atoomula] . Will create a mirror ticket in LI
[
https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914336#comment-16914336
]
Daniel Nishimura commented on SAMZA-1990:
-
Thanks @Aditya for the investigation. Can you create a
[
https://issues.apache.org/jira/browse/SAMZA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2298:
Summary: Fix CoordinatorStreamStore creation for LocalApplicationRunner
(was: Underlying
Daniel Nishimura created SAMZA-2298:
---
Summary: Underlying coordinator stream needs to be created with
CoordinatorStreamStore for LocalApplicationRunner
Key: SAMZA-2298
URL:
[
https://issues.apache.org/jira/browse/SAMZA-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2296:
Summary: Metadata streams not created in Standalone (was: Checkpoint
Manager not created
[
https://issues.apache.org/jira/browse/SAMZA-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2296:
Description: The config to create the checkpoint manager is being read from
the job model
Daniel Nishimura created SAMZA-2296:
---
Summary: Checkpoint Manager not created in Standalone
Key: SAMZA-2296
URL: https://issues.apache.org/jira/browse/SAMZA-2296
Project: Samza
Issue Type:
Daniel Nishimura created SAMZA-2294:
---
Summary: LocalApplicationRunner support for missing coordinator
stream
Key: SAMZA-2294
URL: https://issues.apache.org/jira/browse/SAMZA-2294
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura closed SAMZA-2273.
---
> ZkJobCoordinator: Async publishing of configs to coordinator stream store.
>
Daniel Nishimura created SAMZA-2286:
---
Summary: Integrate MetadataStore#putAll where appropriate
Key: SAMZA-2286
URL: https://issues.apache.org/jira/browse/SAMZA-2286
Project: Samza
Issue
[
https://issues.apache.org/jira/browse/SAMZA-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2049:
Fix Version/s: (was: 1.1)
> Startpoints user documentation
>
Daniel Nishimura created SAMZA-2278:
---
Summary: Add a "delete all" for startpoint manager
Key: SAMZA-2278
URL: https://issues.apache.org/jira/browse/SAMZA-2278
Project: Samza
Issue Type:
Daniel Nishimura created SAMZA-2276:
---
Summary: Metadata store putAll
Key: SAMZA-2276
URL: https://issues.apache.org/jira/browse/SAMZA-2276
Project: Samza
Issue Type: Improvement
Daniel Nishimura created SAMZA-2273:
---
Summary: ZkJobCoordinator: Async publishing of configs to
coordinator stream store.
Key: SAMZA-2273
URL: https://issues.apache.org/jira/browse/SAMZA-2273
[
https://issues.apache.org/jira/browse/SAMZA-2273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura reassigned SAMZA-2273:
---
Assignee: Daniel Nishimura
> ZkJobCoordinator: Async publishing of configs to
Daniel Nishimura created SAMZA-2272:
---
Summary: Metadata store: Consolidate metadata store types in
ZkJobCoordinator standalone jobs
Key: SAMZA-2272
URL: https://issues.apache.org/jira/browse/SAMZA-2272
Daniel Nishimura created SAMZA-2266:
---
Summary: Introduce a backoff when there are repeated failures for
host-affinity allocations
Key: SAMZA-2266
URL: https://issues.apache.org/jira/browse/SAMZA-2266
[
https://issues.apache.org/jira/browse/SAMZA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2260:
Description: Currently the coordinator stream metadata store init() method
is expensive
Daniel Nishimura created SAMZA-2260:
---
Summary: Standalone: Share metadata store between StreamProcessor
and JobCoordinator
Key: SAMZA-2260
URL: https://issues.apache.org/jira/browse/SAMZA-2260
[
https://issues.apache.org/jira/browse/SAMZA-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura resolved SAMZA-2214.
-
Resolution: Not A Problem
> KafkaSystemConsumer: Log seek position directly from the
[
https://issues.apache.org/jira/browse/SAMZA-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura resolved SAMZA-1983.
-
Resolution: Fixed
Fix Version/s: (was: 1.1)
> SEP-18 : Startpoints
[
https://issues.apache.org/jira/browse/SAMZA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2220:
Summary: Startpoints - Fully encapsulate resolution of starting offsets in
OffsetManager
[
https://issues.apache.org/jira/browse/SAMZA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2220:
Description:
Currently when a startpoint is set, the consumers are registered with the
Daniel Nishimura created SAMZA-2220:
---
Summary: Startpoints - sync TaskInstance offset caught up logic
with Startpoints
Key: SAMZA-2220
URL: https://issues.apache.org/jira/browse/SAMZA-2220
Project:
[
https://issues.apache.org/jira/browse/SAMZA-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2215:
Summary: StartpointManager fix for previous CoordinatorStreamStore refactor
(was:
[
https://issues.apache.org/jira/browse/SAMZA-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2215:
Summary: StartpointManager fix for previous CoordinatorStreamStore
refactoring (was:
Daniel Nishimura created SAMZA-2216:
---
Summary: Reintegrate MetadataStoreFactory for creating metadata
store objects.
Key: SAMZA-2216
URL: https://issues.apache.org/jira/browse/SAMZA-2216
Project:
[
https://issues.apache.org/jira/browse/SAMZA-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2215:
Description: StartpointManager does not instantiate in the
ContainerLaunchUtil due to the
[
https://issues.apache.org/jira/browse/SAMZA-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2215:
Summary: StartpointManager fix due to CoordinatorStreamStore refactoring
(was:
[
https://issues.apache.org/jira/browse/SAMZA-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2215:
Description: The metadata store is currently instantiated directly due to
some near term
[
https://issues.apache.org/jira/browse/SAMZA-2215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2215:
Summary: Instantiate metadata stores from factory (was: Removal of unused
MetadataStore
Daniel Nishimura created SAMZA-2215:
---
Summary: Removal of unused MetadataStore factories
Key: SAMZA-2215
URL: https://issues.apache.org/jira/browse/SAMZA-2215
Project: Samza
Issue Type:
Daniel Nishimura created SAMZA-2214:
---
Summary: KafkaSystemConsumer: Log seek position directly from the
underlying consumer
Key: SAMZA-2214
URL: https://issues.apache.org/jira/browse/SAMZA-2214
[
https://issues.apache.org/jira/browse/SAMZA-2149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura resolved SAMZA-2149.
-
Resolution: Fixed
> Generalize startpoint SSP to task fanout API
>
Daniel Nishimura created SAMZA-2201:
---
Summary: Startpoints - Integrate fan out with job coordinators
Key: SAMZA-2201
URL: https://issues.apache.org/jira/browse/SAMZA-2201
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura resolved SAMZA-2144.
-
Resolution: Won't Do
API enhancements will make this no longer required.
> In
[
https://issues.apache.org/jira/browse/SAMZA-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2182:
Description: The issue with the current implementation of the metadata
store is that the
[
https://issues.apache.org/jira/browse/SAMZA-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2182:
Description: The issue with the current implementation of the metadata
store is that the
[
https://issues.apache.org/jira/browse/SAMZA-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2181:
Summary: Ensure consistency of coordinator store creation and
initialization (was: Ensure
[
https://issues.apache.org/jira/browse/SAMZA-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2181:
Description: Ensure that the metadata store is instantiated consistently
and the
[
https://issues.apache.org/jira/browse/SAMZA-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2181:
Summary: Ensure consistency of metadata store creation and initialization
(was: Ensure
Daniel Nishimura created SAMZA-2182:
---
Summary: Metadata store: disconnect between creation and usage of
the underlying storage
Key: SAMZA-2182
URL: https://issues.apache.org/jira/browse/SAMZA-2182
Daniel Nishimura created SAMZA-2181:
---
Summary: Ensure consistency of metadata store usage across all Job
Coordinators
Key: SAMZA-2181
URL: https://issues.apache.org/jira/browse/SAMZA-2181
Project:
Daniel Nishimura created SAMZA-2171:
---
Summary: Encapsulate creation and loading of metadata streams
Key: SAMZA-2171
URL: https://issues.apache.org/jira/browse/SAMZA-2171
Project: Samza
Daniel Nishimura created SAMZA-2149:
---
Summary: Generalize startpoint SSP to task fanout API
Key: SAMZA-2149
URL: https://issues.apache.org/jira/browse/SAMZA-2149
Project: Samza
Issue Type:
Daniel Nishimura created SAMZA-2144:
---
Summary: In TaskInstance, bypass "SSP caught-up" check if offset
is set by a startpoint
Key: SAMZA-2144
URL: https://issues.apache.org/jira/browse/SAMZA-2144
[
https://issues.apache.org/jira/browse/SAMZA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2143:
Description:
1) NPE exposed in CoordinatorStreamMessage#equals now that the metadata store
[
https://issues.apache.org/jira/browse/SAMZA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2143:
Description:
NPE exposed in CoordinatorStreamMessage#equals now that the metadata store
Daniel Nishimura created SAMZA-2143:
---
Summary: NPE in CoordinatorStreamMessage#equals and some clean-up
to CoordinatorStreamSystemConsumer
Key: SAMZA-2143
URL: https://issues.apache.org/jira/browse/SAMZA-2143
[
https://issues.apache.org/jira/browse/SAMZA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2143:
Issue Type: Bug (was: Improvement)
> NPE in CoordinatorStreamMessage#equals and some
Daniel Nishimura created SAMZA-2138:
---
Summary: Incorrect logging when task to container mapping is
written.
Key: SAMZA-2138
URL: https://issues.apache.org/jira/browse/SAMZA-2138
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796298#comment-16796298
]
Daniel Nishimura commented on SAMZA-2052:
-
[~pmaheshwari] - nope it was merged in. Resolved
Daniel Nishimura created SAMZA-2132:
---
Summary: Startpoint - flatten serialized key
Key: SAMZA-2132
URL: https://issues.apache.org/jira/browse/SAMZA-2132
Project: Samza
Issue Type:
Daniel Nishimura created SAMZA-2115:
---
Summary: EventHubsSystemDescriptor - expose interceptors
configuration
Key: SAMZA-2115
URL: https://issues.apache.org/jira/browse/SAMZA-2115
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura reassigned SAMZA-1990:
---
Assignee: Daniel Nishimura
> Samza framework should let using the same system
[
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
Daniel Nishimura created SAMZA-2052:
---
Summary: Update sonar-scanner in .travis.yml file to work problem
with Travis-CI again.
Key: SAMZA-2052
URL: https://issues.apache.org/jira/browse/SAMZA-2052
Daniel Nishimura created SAMZA-2049:
---
Summary: Startpoints user documentation
Key: SAMZA-2049
URL: https://issues.apache.org/jira/browse/SAMZA-2049
Project: Samza
Issue Type: Task
[
https://issues.apache.org/jira/browse/SAMZA-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2022:
Issue Type: New Feature (was: Bug)
> Startpoints - SystemConsumers (not to be confused
[
https://issues.apache.org/jira/browse/SAMZA-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2024:
Issue Type: New Feature (was: Bug)
> Startpoints - Implement
>
[
https://issues.apache.org/jira/browse/SAMZA-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2038:
Issue Type: New Feature (was: Bug)
> Add and implement new interface
>
[
https://issues.apache.org/jira/browse/SAMZA-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-2023:
Issue Type: New Feature (was: Bug)
> Startpoints - Implement
[
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
[
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
[
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:
[
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
[
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)
Daniel Nishimura created SAMZA-2046:
---
Summary: Startpoints - job coordinators need to re-map startpoints
from SSP key to SSP+TaskName key
Key: SAMZA-2046
URL: https://issues.apache.org/jira/browse/SAMZA-2046
Daniel Nishimura created SAMZA-2045:
---
Summary: Startpoints integration tests
Key: SAMZA-2045
URL: https://issues.apache.org/jira/browse/SAMZA-2045
Project: Samza
Issue Type: New Feature
Daniel Nishimura created SAMZA-2038:
---
Summary: Add and implement new interface
TaskContext#setStartingOffset(SystemStreamPartition, Startpoint)
Key: SAMZA-2038
URL:
[
https://issues.apache.org/jira/browse/SAMZA-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-1983:
Description:
Umbrella Jira ticket for the SEP-18 implementation.
[
https://issues.apache.org/jira/browse/SAMZA-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-1983:
Description: Umbrella Jira ticket for the SEP-18 implementation.
> SEP-18 : Startpoints
[
https://issues.apache.org/jira/browse/SAMZA-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-1983:
Summary: SEP-18 : Startpoints implementation in the core framework (was:
Startpoints
Daniel Nishimura created SAMZA-2024:
---
Summary: Startpoints - Implement
EventHubSystemConsumer#register(SystemStreamPartition, Startpoint) interface.
Key: SAMZA-2024
URL:
Daniel Nishimura created SAMZA-2023:
---
Summary: Startpoints - Implement
KafkaSystemConsumer#register(SystemStreamPartition, Startpoint) interface.
Key: SAMZA-2023
URL:
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
[
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
[
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
>
[
https://issues.apache.org/jira/browse/SAMZA-1988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Nishimura updated SAMZA-1988:
Description:
The following modules have direct Scala dependencies and info where the
1 - 100 of 133 matches
Mail list logo
