[
https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125415#comment-17125415
]
Chai Nadig commented on BEAM-6466:
--
Hi, I'm running into this problem when using KafkaIO with fixed
[
https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17122956#comment-17122956
]
Beam JIRA Bot commented on BEAM-6466:
-
This issue is P2 but has been unassigned without any comment
[
https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754706#comment-16754706
]
Jozef Vilcek commented on BEAM-6466:
Yes, I agree it can be different ticket. Just wanted to say this
[
https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747715#comment-16747715
]
Raghu Angadi commented on BEAM-6466:
BoundedReadFromUnboundedSource does not seem to be waiting till
[
https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747410#comment-16747410
]
Jozef Vilcek commented on BEAM-6466:
I see checkpoint being finalised in ReadFn processElements after
[
https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746519#comment-16746519
]
Raghu Angadi commented on BEAM-6466:
Added this comment to the above thread:
Yeah, there is a timing
