flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi (JIRA) <j...@apache.org>
Subject [jira] [Commented] (FLINK-1865) Unstable test KafkaITCase
Date Wed, 22 Apr 2015 16:34:59 GMT

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

Márton Balassi commented on FLINK-1865:
---------------------------------------

Go ahead.

> 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
>            Assignee: Márton Balassi
>
> {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)

Mime
View raw message