[
https://issues.apache.org/jira/browse/BEAM-1240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16568164#comment-16568164
]
Akanksha commented on BEAM-1240:
--------------------------------
Hello Mr. Jeroren
I have tested Apache Beam RmqIO with Flink runner. If the source is unbounded
and checkpoint interval is declared, the finalizeCheckpoint method gets called
and My RMQ message is getting acknowledged.
Moreover, i have another issue of my Rmq Connection is closing automatically
and Job gets finished.
Although Queue has data.
Close method of UnboundedRabbitMqReader class get called Which causes a
connection to stop
Any help or suggestion will be appreciated.
> Create RabbitMqIO
> -----------------
>
> Key: BEAM-1240
> URL: https://issues.apache.org/jira/browse/BEAM-1240
> Project: Beam
> Issue Type: New Feature
> Components: io-ideas
> Reporter: Jean-Baptiste Onofré
> Assignee: Jean-Baptiste Onofré
> Priority: Major
> Fix For: 2.6.0
>
> Time Spent: 11h 40m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
