[
https://issues.apache.org/jira/browse/FLINK-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3283:
-------------------------------------
Assignee: Robert Metzger
> 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
> Assignee: Robert Metzger
>
> 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)
