[jira] [Created] (FLINK-3283) Failed Kafka 0.9 test on duplicate message

["Ufuk Celebi (JIRA)" <ji...@apache.org>]

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)