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