[
https://issues.apache.org/jira/browse/BAHIR-204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817380#comment-16817380
]
ASF subversion and git services commented on BAHIR-204:
-------------------------------------------------------
Commit 3f1b3ba91d48d33214dd060fc3c1fda2f708484b in bahir-flink's branch
refs/heads/master from Konstantin Knauf
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=3f1b3ba ]
[BAHIR-204] [activemq] ActiveMQ Source only emits previously unprocessed
records now
> AMQSource is not at-least-once
> ------------------------------
>
> Key: BAHIR-204
> URL: https://issues.apache.org/jira/browse/BAHIR-204
> Project: Bahir
> Issue Type: Bug
> Reporter: Konstantin Knauf
> Priority: Major
>
> The {{AMQSource}} should only emit records, for which addIds(..) returned
> "true" in order to play along in checkpointing.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
