[
https://issues.apache.org/jira/browse/SAMZA-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15299227#comment-15299227
]
Yi Pan (Data Infrastructure) commented on SAMZA-951:
Merged and submitt
Jake Maes created SAMZA-952:
---
Summary: Add validation for broadcast inputs configured for
partitions that don't exist
Key: SAMZA-952
URL: https://issues.apache.org/jira/browse/SAMZA-952
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15298945#comment-15298945
]
Tao Feng commented on SAMZA-949:
Got it. Thanks for the explanation.
> KafkaCheckpointMan
[
https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15298927#comment-15298927
]
Yi Pan (Data Infrastructure) commented on SAMZA-949:
[~TaoFeng], it is
[
https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15298921#comment-15298921
]
Tao Feng commented on SAMZA-949:
Will fix for Samza-807 work for this?
> KafkaCheckpointMa
[
https://issues.apache.org/jira/browse/SAMZA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Branislav Cogic reassigned SAMZA-949:
-
Assignee: Branislav Cogic
> KafkaCheckpointManager should not try forever for non-recovera
[
https://issues.apache.org/jira/browse/SAMZA-856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15297872#comment-15297872
]
Branislav Cogic commented on SAMZA-856:
---
The patch is attached.
Here is a RB link: ht
[
https://issues.apache.org/jira/browse/SAMZA-856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Branislav Cogic updated SAMZA-856:
--
Attachment: SAMZA-856.0.patch
> Optionally automatically commit based on number of processed mess
