Ufuk Celebi created FLINK-3283:
----------------------------------
Summary: 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)
