[jira] [Created] (FLINK-1865) Unstable test KafkaITCase

[Shang Yuanchun (Jira)]

Stephan Ewen created FLINK-1865:
-----------------------------------

             Summary: Unstable test KafkaITCase
                 Key: FLINK-1865
                 URL: https://issues.apache.org/jira/browse/FLINK-1865
             Project: Flink
          Issue Type: Bug
            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)