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-2192) ComplexIntegrationTest.complexIntegrationTest1 fails
Date Wed, 10 Jun 2015 09:27:00 GMT

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

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

It is a duplicate, because the failing part is the streaming iteration. Because currently
there is no other way of determining that a streaming iteration has finished if no data is
received for configurable time the iteration terminates. If the test is halted for that much
time becuase of the other tests running concurrently you end up with an empty collection in
the output.

> ComplexIntegrationTest.complexIntegrationTest1 fails 
> -----------------------------------------------------
>
>                 Key: FLINK-2192
>                 URL: https://issues.apache.org/jira/browse/FLINK-2192
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>    Affects Versions: 0.9
>            Reporter: Fabian Hueske
>
> I observed a fail of ComplexIntegrationTest.complexIntegrationTest1 on a local build
(OS X, Java 8) due to incorrectly computed results.
> {code}
> Tests run: 7, Failures: 1, Errors: 1, Skipped: 1, Time elapsed: 9.997 sec <<<
FAILURE! - in org.apache.flink.streaming.api.complex.ComplexIntegrationTest
> complexIntegrationTest1(org.apache.flink.streaming.api.complex.ComplexIntegrationTest)
 Time elapsed: 1.104 sec  <<< ERROR!
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 	at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:315)
> 	at scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
> 	at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
> 	at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
> 	at org.apache.flink.runtime.testingUtils.TestingJobManager$$anonfun$receiveTestingMessages$1.applyOrElse(TestingJobManager.scala:160)
> 	at scala.PartialFunction$OrElse.apply(PartialFunction.scala:162)
> 	at org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:36)
> 	at org.apache.flink.runtime.ActorLogMessages$$anon$1.apply(ActorLogMessages.scala:29)
> 	at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
> 	at org.apache.flink.runtime.ActorLogMessages$$anon$1.applyOrElse(ActorLogMessages.scala:29)
> 	at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
> 	at org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:94)
> 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
> 	at akka.actor.ActorCell.invoke(ActorCell.scala:487)
> 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
> 	at akka.dispatch.Mailbox.run(Mailbox.scala:221)
> 	at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
> 	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> 	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> 	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> 	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> Caused by: java.lang.NullPointerException: null
> 	at org.apache.flink.core.fs.local.LocalFileSystem.delete(LocalFileSystem.java:206)
> 	at org.apache.flink.core.fs.local.LocalFileSystem.delete(LocalFileSystem.java:189)
> 	at org.apache.flink.core.fs.FileSystem.initOutPathLocalFS(FileSystem.java:581)
> 	at org.apache.flink.api.common.io.FileOutputFormat.open(FileOutputFormat.java:233)
> 	at org.apache.flink.api.java.io.TextOutputFormat.open(TextOutputFormat.java:77)
> 	at org.apache.flink.streaming.api.functions.sink.FileSinkFunction.open(FileSinkFunction.java:58)
> 	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:33)
> 	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:56)
> 	at org.apache.flink.streaming.runtime.tasks.StreamTask.openOperator(StreamTask.java:161)
> 	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.invoke(OneInputStreamTask.java:97)
> 	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
> 	at java.lang.Thread.run(Thread.java:745)
> complexIntegrationTest1(org.apache.flink.streaming.api.complex.ComplexIntegrationTest)
 Time elapsed: 1.104 sec  <<< FAILURE!
> java.lang.AssertionError: Different number of lines in expected and obtained result.
expected:<9> but was:<1>
> 	at org.junit.Assert.fail(Assert.java:88)
> 	at org.junit.Assert.failNotEquals(Assert.java:743)
> 	at org.junit.Assert.assertEquals(Assert.java:118)
> 	at org.junit.Assert.assertEquals(Assert.java:555)
> 	at org.apache.flink.test.util.TestBaseUtils.compareResultsByLinesInMemory(TestBaseUtils.java:270)
> 	at org.apache.flink.test.util.TestBaseUtils.compareResultsByLinesInMemory(TestBaseUtils.java:256)
> 	at org.apache.flink.streaming.api.complex.ComplexIntegrationTest.after(ComplexIntegrationTest.java:91)
> Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.399 sec - in org.apache.flink.streaming.runtime.tasks.SourceStreamTaskTest
> Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.773 sec - in org.apache.flink.streaming.runtime.io.BarrierBufferIOTest
> Results :
> Failed tests: 
>   ComplexIntegrationTest.after:91->TestBaseUtils.compareResultsByLinesInMemory:256->TestBaseUtils.compareResultsByLinesInMemory:270
Different number of lines in expected and obtained result. expected:<9> but was:<1>
> {code}



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

Mime
View raw message