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

["Robert Metzger (JIRA)" <ji...@apache.org>]

     [ 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)