[jira] [Commented] (BEAM-11251) Unfair lock/monitor in UnboundedSourceWrapper can starve checkpointing

[ https://issues.apache.org/jira/browse/BEAM-11251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231217#comment-17231217 ] josson paul kalapparambath commented on BEAM-11251: --- [~aljoscha] , I wi

[jira] [Issue Comment Deleted] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn

[ https://issues.apache.org/jira/browse/BEAM-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] josson paul kalapparambath updated BEAM-9977: - Comment: was deleted (was: [~boyuanz] . Looks like I don't need BEAM-10123

[jira] [Comment Edited] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn

[ https://issues.apache.org/jira/browse/BEAM-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128687#comment-17128687 ] josson paul kalapparambath edited comment on BEAM-9977 at 6/8/20, 10:21 PM:

[jira] [Commented] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn

[ https://issues.apache.org/jira/browse/BEAM-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128687#comment-17128687 ] josson paul kalapparambath commented on BEAM-9977: -- [~boyuanz] . Looks li

[jira] [Commented] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn

[ https://issues.apache.org/jira/browse/BEAM-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128479#comment-17128479 ] josson paul kalapparambath commented on BEAM-9977: -- [~boyuanz]  To try t

[jira] [Commented] (BEAM-727) KafkaIO should support dynamic addition of Kafka partitions to assigned topics.

[ https://issues.apache.org/jira/browse/BEAM-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127859#comment-17127859 ] josson paul kalapparambath commented on BEAM-727: - [~iemejia] [~jkff] I am