[
https://issues.apache.org/jira/browse/FLINK-2498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2498:
---------------------------------
Description:
I noticed a failure of
{{testCorrectnessOfGroupReduceOnCustomTypeWithTypeExtractor}} test.
Here's the build: https://travis-ci.org/apache/flink/jobs/74576231
{code}
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
at
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:364)
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$handleTestingMessage$1.applyOrElse(TestingJobManager.scala:225)
at scala.PartialFunction$OrElse.apply(PartialFunction.scala:162)
at
org.apache.flink.runtime.LeaderSessionMessages$$anonfun$receive$1.applyOrElse(LeaderSessionMessages.scala:40)
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.LogMessages$$anon$1.apply(LogMessages.scala:33)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
at
org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at
org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:101)
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.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.io.FileNotFoundException:
/tmp/junit5086413501724507831/junit1610283772376223329.tmp/2 (No such file or
directory)
at java.io.FileOutputStream.open(Native Method)
at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
at
org.apache.flink.core.fs.local.LocalDataOutputStream.<init>(LocalDataOutputStream.java:56)
at
org.apache.flink.core.fs.local.LocalFileSystem.create(LocalFileSystem.java:256)
at
org.apache.flink.core.fs.local.LocalFileSystem.create(LocalFileSystem.java:263)
at
org.apache.flink.api.common.io.FileOutputFormat.open(FileOutputFormat.java:246)
at
org.apache.flink.api.java.io.TextOutputFormat.open(TextOutputFormat.java:77)
at
org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:187)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:581)
at java.lang.Thread.run(Thread.java:745)
Tests run: 44, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.699 sec - in
org.apache.flink.api.scala.operators.JoinITCase
Running org.apache.flink.api.scala.operators.MapITCase
Tests run: 60, Failures: 1, Errors: 0, Skipped: 3, Time elapsed: 12.016 sec <<<
FAILURE! - in org.apache.flink.api.scala.operators.GroupReduceITCase
testCorrectnessOfGroupReduceOnCustomTypeWithTypeExtractor[Execution mode =
CLUSTER](org.apache.flink.api.scala.operators.GroupReduceITCase) Time elapsed:
0.234 sec <<< FAILURE!
java.lang.AssertionError: Job execution failed!
at org.junit.Assert.fail(Assert.java:88)
at
org.apache.flink.test.util.TestEnvironment.execute(TestEnvironment.java:62)
at
org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:789)
at
org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:576)
at
org.apache.flink.api.scala.operators.GroupReduceITCase.testCorrectnessOfGroupReduceOnCustomTypeWithTypeExtractor(GroupReduceITCase.scala:165)
{code}
was:
I noticed a failure of
{{testCorrectnessOfGroupReduceOnCustomTypeWithTypeExtractor}} test.
Here's the build: https://travis-ci.org/apache/flink/jobs/74576231
> GroupReduceITCase failure
> -------------------------
>
> Key: FLINK-2498
> URL: https://issues.apache.org/jira/browse/FLINK-2498
> Project: Flink
> Issue Type: Bug
> Reporter: Sachin Goel
>
> I noticed a failure of
> {{testCorrectnessOfGroupReduceOnCustomTypeWithTypeExtractor}} test.
> Here's the build: https://travis-ci.org/apache/flink/jobs/74576231
> {code}
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> at
> org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1.applyOrElse(JobManager.scala:364)
> 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$handleTestingMessage$1.applyOrElse(TestingJobManager.scala:225)
> at scala.PartialFunction$OrElse.apply(PartialFunction.scala:162)
> at
> org.apache.flink.runtime.LeaderSessionMessages$$anonfun$receive$1.applyOrElse(LeaderSessionMessages.scala:40)
> 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.LogMessages$$anon$1.apply(LogMessages.scala:33)
> at
> org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
> at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
> at
> org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
> at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
> at
> org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:101)
> 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.pollAndExecAll(ForkJoinPool.java:1253)
> at
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
> at
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> Caused by: java.io.FileNotFoundException:
> /tmp/junit5086413501724507831/junit1610283772376223329.tmp/2 (No such file or
> directory)
> at java.io.FileOutputStream.open(Native Method)
> at java.io.FileOutputStream.<init>(FileOutputStream.java:221)
> at java.io.FileOutputStream.<init>(FileOutputStream.java:171)
> at
> org.apache.flink.core.fs.local.LocalDataOutputStream.<init>(LocalDataOutputStream.java:56)
> at
> org.apache.flink.core.fs.local.LocalFileSystem.create(LocalFileSystem.java:256)
> at
> org.apache.flink.core.fs.local.LocalFileSystem.create(LocalFileSystem.java:263)
> at
> org.apache.flink.api.common.io.FileOutputFormat.open(FileOutputFormat.java:246)
> at
> org.apache.flink.api.java.io.TextOutputFormat.open(TextOutputFormat.java:77)
> at
> org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:187)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:581)
> at java.lang.Thread.run(Thread.java:745)
> Tests run: 44, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.699 sec -
> in org.apache.flink.api.scala.operators.JoinITCase
> Running org.apache.flink.api.scala.operators.MapITCase
> Tests run: 60, Failures: 1, Errors: 0, Skipped: 3, Time elapsed: 12.016 sec
> <<< FAILURE! - in org.apache.flink.api.scala.operators.GroupReduceITCase
> testCorrectnessOfGroupReduceOnCustomTypeWithTypeExtractor[Execution mode =
> CLUSTER](org.apache.flink.api.scala.operators.GroupReduceITCase) Time
> elapsed: 0.234 sec <<< FAILURE!
> java.lang.AssertionError: Job execution failed!
> at org.junit.Assert.fail(Assert.java:88)
> at
> org.apache.flink.test.util.TestEnvironment.execute(TestEnvironment.java:62)
> at
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:789)
> at
> org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:576)
> at
> org.apache.flink.api.scala.operators.GroupReduceITCase.testCorrectnessOfGroupReduceOnCustomTypeWithTypeExtractor(GroupReduceITCase.scala:165)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
