[ https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robert Metzger updated FLINK-1865: ---------------------------------- Component/s: Streaming Affects Version/s: 0.9 > Unstable test KafkaITCase > ------------------------- > > Key: FLINK-1865 > URL: https://issues.apache.org/jira/browse/FLINK-1865 > Project: Flink > Issue Type: Bug > Components: Streaming > 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)