[ 
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14492079#comment-14492079
 ] 

Robert Metzger commented on FLINK-1865:
---------------------------------------

FLINK-1784 is a similar / same issue.

> Unstable test KafkaITCase
> -------------------------
>
>                 Key: FLINK-1865
>                 URL: https://issues.apache.org/jira/browse/FLINK-1865
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming, Tests
>    Affects Versions: 0.9
>            Reporter: Stephan Ewen
>
> {code}
> Running org.apache.flink.streaming.connectors.kafka.KafkaITCase
> 04/10/2015 13:46:53   Job execution switched to status RUNNING.
> 04/10/2015 13:46:53   Custom Source -> Stream Sink(1/1) switched to SCHEDULED 
> 04/10/2015 13:46:53   Custom Source -> Stream Sink(1/1) switched to DEPLOYING 
> 04/10/2015 13:46:53   Custom Source -> Stream Sink(1/1) switched to SCHEDULED 
> 04/10/2015 13:46:53   Custom Source -> Stream Sink(1/1) switched to DEPLOYING 
> 04/10/2015 13:46:53   Custom Source -> Stream Sink(1/1) switched to RUNNING 
> 04/10/2015 13:46:53   Custom Source -> Stream Sink(1/1) switched to RUNNING 
> 04/10/2015 13:47:04   Custom Source -> Stream Sink(1/1) switched to FAILED 
> java.lang.RuntimeException: java.lang.RuntimeException: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:145)
>       at 
> org.apache.flink.streaming.api.invokable.SourceInvokable.invoke(SourceInvokable.java:37)
>       at 
> org.apache.flink.streaming.api.streamvertex.StreamVertex.invoke(StreamVertex.java:168)
>       at 
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:221)
>       at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:145)
>       at 
> org.apache.flink.streaming.api.invokable.ChainableInvokable.collect(ChainableInvokable.java:54)
>       at 
> org.apache.flink.streaming.api.collector.CollectorWrapper.collect(CollectorWrapper.java:39)
>       at 
> org.apache.flink.streaming.connectors.kafka.api.KafkaSource.run(KafkaSource.java:196)
>       at 
> org.apache.flink.streaming.api.invokable.SourceInvokable.callUserFunction(SourceInvokable.java:42)
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:139)
>       ... 4 more
> Caused by: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$1.invoke(KafkaITCase.java:166)
>       at 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$1.invoke(KafkaITCase.java:141)
>       at 
> org.apache.flink.streaming.api.invokable.SinkInvokable.callUserFunction(SinkInvokable.java:41)
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:139)
>       ... 9 more
> 04/10/2015 13:47:04   Job execution switched to status FAILING.
> 04/10/2015 13:47:04   Custom Source -> Stream Sink(1/1) switched to CANCELING 
> 04/10/2015 13:47:04   Custom Source -> Stream Sink(1/1) switched to CANCELED 
> 04/10/2015 13:47:04   Job execution switched to status FAILED.
> 04/10/2015 13:47:05   Job execution switched to status RUNNING.
> 04/10/2015 13:47:05   Custom Source -> Stream Sink(1/1) switched to SCHEDULED 
> 04/10/2015 13:47:05   Custom Source -> Stream Sink(1/1) switched to DEPLOYING 
> 04/10/2015 13:47:05   Custom Source -> Stream Sink(1/1) switched to SCHEDULED 
> 04/10/2015 13:47:05   Custom Source -> Stream Sink(1/1) switched to DEPLOYING 
> 04/10/2015 13:47:05   Custom Source -> Stream Sink(1/1) switched to RUNNING 
> 04/10/2015 13:47:05   Custom Source -> Stream Sink(1/1) switched to RUNNING 
> 04/10/2015 13:47:15   Custom Source -> Stream Sink(1/1) switched to FAILED 
> java.lang.RuntimeException: java.lang.RuntimeException: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:145)
>       at 
> org.apache.flink.streaming.api.invokable.SourceInvokable.invoke(SourceInvokable.java:37)
>       at 
> org.apache.flink.streaming.api.streamvertex.StreamVertex.invoke(StreamVertex.java:168)
>       at 
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:221)
>       at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:145)
>       at 
> org.apache.flink.streaming.api.invokable.ChainableInvokable.collect(ChainableInvokable.java:54)
>       at 
> org.apache.flink.streaming.api.collector.CollectorWrapper.collect(CollectorWrapper.java:39)
>       at 
> org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource.run(PersistentKafkaSource.java:215)
>       at 
> org.apache.flink.streaming.api.invokable.SourceInvokable.callUserFunction(SourceInvokable.java:42)
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:139)
>       ... 4 more
> Caused by: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$7.invoke(KafkaITCase.java:480)
>       at 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$7.invoke(KafkaITCase.java:458)
>       at 
> org.apache.flink.streaming.api.invokable.SinkInvokable.callUserFunction(SinkInvokable.java:41)
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:139)
>       ... 9 more
> 04/10/2015 13:47:15   Job execution switched to status FAILING.
> 04/10/2015 13:47:15   Custom Source -> Stream Sink(1/1) switched to CANCELING 
> 04/10/2015 13:47:15   Custom Source -> Stream Sink(1/1) switched to CANCELED 
> 04/10/2015 13:47:15   Job execution switched to status FAILED.
> 04/10/2015 13:47:16   Job execution switched to status RUNNING.
> 04/10/2015 13:47:16   Custom Source -> Stream Sink(1/1) switched to SCHEDULED 
> 04/10/2015 13:47:16   Custom Source -> Stream Sink(1/1) switched to DEPLOYING 
> 04/10/2015 13:47:16   Custom Source -> Stream Sink(1/1) switched to SCHEDULED 
> 04/10/2015 13:47:16   Custom Source -> Stream Sink(1/1) switched to DEPLOYING 
> 04/10/2015 13:47:16   Custom Source -> Stream Sink(1/1) switched to RUNNING 
> 04/10/2015 13:47:16   Custom Source -> Stream Sink(1/1) switched to RUNNING 
> 04/10/2015 13:47:26   Custom Source -> Stream Sink(1/1) switched to FAILED 
> java.lang.RuntimeException: java.lang.RuntimeException: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:145)
>       at 
> org.apache.flink.streaming.api.invokable.SourceInvokable.invoke(SourceInvokable.java:37)
>       at 
> org.apache.flink.streaming.api.streamvertex.StreamVertex.invoke(StreamVertex.java:168)
>       at 
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:221)
>       at java.lang.Thread.run(Thread.java:701)
> Caused by: java.lang.RuntimeException: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:145)
>       at 
> org.apache.flink.streaming.api.invokable.ChainableInvokable.collect(ChainableInvokable.java:54)
>       at 
> org.apache.flink.streaming.api.collector.CollectorWrapper.collect(CollectorWrapper.java:39)
>       at 
> org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource.run(PersistentKafkaSource.java:215)
>       at 
> org.apache.flink.streaming.api.invokable.SourceInvokable.callUserFunction(SourceInvokable.java:42)
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:139)
>       ... 4 more
> Caused by: 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$SuccessException
>       at 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$3.invoke(KafkaITCase.java:252)
>       at 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase$3.invoke(KafkaITCase.java:227)
>       at 
> org.apache.flink.streaming.api.invokable.SinkInvokable.callUserFunction(SinkInvokable.java:41)
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.callUserFunctionAndLogException(StreamInvokable.java:139)
>       ... 9 more
> 04/10/2015 13:47:26   Job execution switched to status FAILING.
> 04/10/2015 13:47:26   Custom Source -> Stream Sink(1/1) switched to CANCELING 
> 04/10/2015 13:47:26   Custom Source -> Stream Sink(1/1) switched to CANCELED 
> 04/10/2015 13:47:26   Job execution switched to status FAILED.
> 04/10/2015 13:47:27   Job execution switched to status RUNNING.
> 04/10/2015 13:47:27   Custom Source -> Stream Sink(1/1) switched to SCHEDULED 
> 04/10/2015 13:47:27   Custom Source -> Stream Sink(1/1) switched to DEPLOYING 
> 04/10/2015 13:47:27   Custom Source -> Stream Sink(1/1) switched to SCHEDULED 
> 04/10/2015 13:47:27   Custom Source -> Stream Sink(1/1) switched to DEPLOYING 
> 04/10/2015 13:47:27   Custom Source -> Stream Sink(1/1) switched to RUNNING 
> 04/10/2015 13:47:27   Custom Source -> Stream Sink(1/1) switched to RUNNING 
> 04/10/2015 13:47:29   Custom Source -> Stream Sink(1/1) switched to FAILED 
> java.util.NoSuchElementException: next on empty iterator
>       at scala.collection.Iterator$$anon$2.next(Iterator.scala:39)
>       at scala.collection.Iterator$$anon$2.next(Iterator.scala:37)
>       at scala.collection.LinearSeqLike$$anon$1.next(LinearSeqLike.scala:62)
>       at 
> scala.collection.convert.Wrappers$IteratorWrapper.next(Wrappers.scala:30)
>       at 
> org.apache.flink.streaming.connectors.kafka.api.simple.KafkaTopicUtils.getLeaderBrokerAddressForTopic(KafkaTopicUtils.java:83)
>       at 
> org.apache.flink.streaming.connectors.kafka.api.KafkaSink.open(KafkaSink.java:117)
>       at 
> org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:33)
>       at 
> org.apache.flink.streaming.api.invokable.StreamInvokable.open(StreamInvokable.java:158)
>       at 
> org.apache.flink.streaming.api.streamvertex.StreamVertex.openOperator(StreamVertex.java:204)
>       at 
> org.apache.flink.streaming.api.streamvertex.StreamVertex.invoke(StreamVertex.java:166)
>       at 
> org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:221)
>       at java.lang.Thread.run(Thread.java:701)
> 04/10/2015 13:47:29   Job execution switched to status FAILING.
> 04/10/2015 13:47:29   Custom Source -> Stream Sink(1/1) switched to CANCELING 
> 04/10/2015 13:47:29   Custom Source -> Stream Sink(1/1) switched to CANCELED 
> Tests run: 4, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 40.615 sec 
> <<< FAILURE! - in org.apache.flink.streaming.connectors.kafka.KafkaITCase
> customPartitioningTestTopology(org.apache.flink.streaming.connectors.kafka.KafkaITCase)
>   Time elapsed: 2.73 sec  <<< ERROR!
> java.lang.NullPointerException: null
>       at 
> org.apache.flink.streaming.connectors.kafka.KafkaITCase.customPartitioningTestTopology(KafkaITCase.java:394)
> Results :
> Tests in error: 
>   KafkaITCase.customPartitioningTestTopology:394 NullPointer
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to