[
https://issues.apache.org/jira/browse/FLINK-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15224054#comment-15224054
]
Robert Metzger commented on FLINK-3283:
---------------------------------------
The problem happened again:
https://s3.amazonaws.com/archive.travis-ci.org/jobs/120565812/log.txt
I suspect its a timing issue of the test.
> Failed Kafka 0.9 test on duplicate message
> ------------------------------------------
>
> Key: FLINK-3283
> URL: https://issues.apache.org/jira/browse/FLINK-3283
> Project: Flink
> Issue Type: Test
> Reporter: Ufuk Celebi
>
> On a branch with unrelated changes
> {{Kafka09ITCase.testMultipleSourcesOnePartition:82->KafkaConsumerTestBase.runMultipleSourcesOnePartitionExactlyOnceTest}}
> failed.
> https://s3.amazonaws.com/archive.travis-ci.org/jobs/104582020/log.txt
> {code}
> Caused by: java.lang.Exception: Received a duplicate: 1712
> at
> org.apache.flink.streaming.connectors.kafka.testutils.ValidatingExactlyOnceSink.invoke(ValidatingExactlyOnceSink.java:53)
> at
> org.apache.flink.streaming.connectors.kafka.testutils.ValidatingExactlyOnceSink.invoke(ValidatingExactlyOnceSink.java:30)
> at
> org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:37)
> at
> org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:166)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:63)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:232)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
