Created
October 20, 2015 16:43
-
-
Save dlyubimov/bfe0c7356ff775a8852b to your computer and use it in GitHub Desktop.
Full Flink test report
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Discovery starting. | |
| Discovery completed in 668 milliseconds. | |
| Run starting. Expected test count is: 98 | |
| DrmLikeOpsSuite: | |
| - norm (2 seconds, 429 milliseconds) | |
| - colSums (714 milliseconds) | |
| - rowSums (673 milliseconds) | |
| - rowMeans (604 milliseconds) | |
| - numNonZeroElementsPerColumn (666 milliseconds) | |
| - drmParallelizeEmpty (617 milliseconds) | |
| LATestSuite: | |
| - Ax blockified (1 second, 653 milliseconds) | |
| - At sparseTrick (772 milliseconds) | |
| - AtB notZippable (889 milliseconds) | |
| - AewScalar opScalarNoSideEffect (583 milliseconds) | |
| - AewB rowWiseJoinNoSideEffect (671 milliseconds) | |
| - Cbind (676 milliseconds) | |
| - CbindScalar left (557 milliseconds) | |
| - CbindScalar right (511 milliseconds) | |
| - slice (528 milliseconds) | |
| - A times inCoreB (569 milliseconds) | |
| - At A slim (518 milliseconds) | |
| - At A fat (610 milliseconds) | |
| UseCasesSuite: | |
| - use case: Power interation 1000 x 1000 matrix (6 seconds, 909 milliseconds) | |
| - use case: OLS Regression (1 second, 552 milliseconds) | |
| - use case: Ridge Regression (2 seconds, 112 milliseconds) | |
| - use case: trimmed-EVD via power iteration !!! IGNORED !!! | |
| RLikeOpsSuite: | |
| - A %*% x (552 milliseconds) | |
| - A.t (582 milliseconds) | |
| - A.t %*% x (567 milliseconds) | |
| - A.t %*% B (540 milliseconds) | |
| - A %*% B.t (640 milliseconds) | |
| - A.t %*% A (987 milliseconds) | |
| - A %*% B (613 milliseconds) | |
| - A %*% B.t test 2 (695 milliseconds) | |
| - ABt test (617 milliseconds) | |
| - A * scalar (485 milliseconds) | |
| - A / scalar (504 milliseconds) | |
| - A + scalar (490 milliseconds) | |
| - A - scalar (498 milliseconds) | |
| - A * B (519 milliseconds) | |
| - A / B (521 milliseconds) | |
| - A + B (530 milliseconds) | |
| - A - B (482 milliseconds) | |
| - A cbind B (518 milliseconds) | |
| - 1 cbind A (463 milliseconds) | |
| - A cbind 1 (482 milliseconds) | |
| - A rbind B (501 milliseconds) | |
| - A row slice (482 milliseconds) | |
| - A column slice (507 milliseconds) | |
| - A %*% inCoreB (516 milliseconds) | |
| - drmBroadcast (511 milliseconds) | |
| - A.t %*% B with Long keys (529 milliseconds) | |
| FlinkByteBCastSuite: | |
| - BCast vector (0 milliseconds) | |
| - BCast matrix (1 millisecond) | |
| DrmLikeSuite: | |
| - DRM DFS i/o (local) *** FAILED *** (1 second, 919 milliseconds) | |
| org.apache.flink.runtime.client.JobExecutionException: Job execution failed. | |
| at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:314) | |
| 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.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:92) | |
| 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) | |
| Cause: java.io.IOException: wrong key class: org.apache.hadoop.io.IntWritable is not class org.apache.hadoop.io.LongWritable | |
| at org.apache.hadoop.io.SequenceFile$Writer.append(SequenceFile.java:1305) | |
| at org.apache.hadoop.mapred.SequenceFileOutputFormat$1.write(SequenceFileOutputFormat.java:76) | |
| at org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat.writeRecord(HadoopOutputFormat.java:50) | |
| at org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat.writeRecord(HadoopOutputFormat.java:35) | |
| at org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:200) | |
| at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
| at java.lang.Thread.run(Thread.java:745) | |
| - DRM parallelizeEmpty (629 milliseconds) | |
| RLikeDrmOpsSuite: | |
| - A.t (692 milliseconds) | |
| - C = A %*% B (1 second, 508 milliseconds) | |
| - C = A %*% B mapBlock {} (3 seconds, 996 milliseconds) | |
| - C = A %*% B incompatible B keys (3 milliseconds) | |
| - Spark-specific C = At %*% B , join (509 milliseconds) | |
| - C = At %*% B , join, String-keyed (563 milliseconds) | |
| - C = At %*% B , zippable, String-keyed (517 milliseconds) | |
| - C = A %*% B.t (542 milliseconds) | |
| - C = A %*% inCoreB (491 milliseconds) | |
| - C = inCoreA %*%: B (535 milliseconds) | |
| - C = A.t %*% A (965 milliseconds) | |
| - C = A.t %*% A fat non-graph (24 seconds, 284 milliseconds) | |
| - C = A.t %*% A non-int key (625 milliseconds) | |
| - C = A + B (560 milliseconds) | |
| - C = A + B, identically partitioned *** FAILED *** (986 milliseconds) | |
| 1.3931277623666953 was not less than 1.0E-10 (RLikeDrmOpsSuiteBase.scala:366) | |
| org.scalatest.exceptions.TestFailedException: | |
| at org.scalatest.MatchersHelper$.newTestFailedException(MatchersHelper.scala:160) | |
| at org.scalatest.Matchers$ShouldMethodHelper$.shouldMatcher(Matchers.scala:6231) | |
| at org.scalatest.Matchers$AnyShouldWrapper.should(Matchers.scala:6265) | |
| at org.apache.mahout.math.drm.RLikeDrmOpsSuiteBase$$anonfun$15.apply$mcV$sp(RLikeDrmOpsSuiteBase.scala:366) | |
| at org.apache.mahout.math.drm.RLikeDrmOpsSuiteBase$$anonfun$15.apply(RLikeDrmOpsSuiteBase.scala:335) | |
| at org.apache.mahout.math.drm.RLikeDrmOpsSuiteBase$$anonfun$15.apply(RLikeDrmOpsSuiteBase.scala:335) | |
| at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22) | |
| at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85) | |
| at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104) | |
| at org.scalatest.Transformer.apply(Transformer.scala:22) | |
| at org.scalatest.Transformer.apply(Transformer.scala:20) | |
| at org.scalatest.FunSuiteLike$$anon$1.apply(FunSuiteLike.scala:166) | |
| at org.scalatest.Suite$class.withFixture(Suite.scala:1122) | |
| at org.scalatest.FunSuite.withFixture(FunSuite.scala:1555) | |
| at org.scalatest.FunSuiteLike$class.invokeWithFixture$1(FunSuiteLike.scala:163) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:175) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:175) | |
| at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306) | |
| at org.scalatest.FunSuiteLike$class.runTest(FunSuiteLike.scala:175) | |
| at org.apache.mahout.flinkbindings.standard.RLikeDrmOpsSuite.org$scalatest$BeforeAndAfterEach$$super$runTest(RLikeDrmOpsSuite.scala:16) | |
| at org.scalatest.BeforeAndAfterEach$class.runTest(BeforeAndAfterEach.scala:255) | |
| at org.apache.mahout.flinkbindings.standard.RLikeDrmOpsSuite.runTest(RLikeDrmOpsSuite.scala:16) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:208) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:208) | |
| at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:413) | |
| at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401) | |
| at scala.collection.immutable.List.foreach(List.scala:318) | |
| at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401) | |
| at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:396) | |
| at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:483) | |
| at org.scalatest.FunSuiteLike$class.runTests(FunSuiteLike.scala:208) | |
| at org.scalatest.FunSuite.runTests(FunSuite.scala:1555) | |
| at org.scalatest.Suite$class.run(Suite.scala:1424) | |
| at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1555) | |
| at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:212) | |
| at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:212) | |
| at org.scalatest.SuperEngine.runImpl(Engine.scala:545) | |
| at org.scalatest.FunSuiteLike$class.run(FunSuiteLike.scala:212) | |
| at org.apache.mahout.flinkbindings.standard.RLikeDrmOpsSuite.org$scalatest$BeforeAndAfterAllConfigMap$$super$run(RLikeDrmOpsSuite.scala:16) | |
| at org.scalatest.BeforeAndAfterAllConfigMap$class.liftedTree1$1(BeforeAndAfterAllConfigMap.scala:248) | |
| at org.scalatest.BeforeAndAfterAllConfigMap$class.run(BeforeAndAfterAllConfigMap.scala:247) | |
| at org.apache.mahout.flinkbindings.standard.RLikeDrmOpsSuite.run(RLikeDrmOpsSuite.scala:16) | |
| at org.scalatest.Suite$class.callExecuteOnSuite$1(Suite.scala:1492) | |
| at org.scalatest.Suite$$anonfun$runNestedSuites$1.apply(Suite.scala:1528) | |
| at org.scalatest.Suite$$anonfun$runNestedSuites$1.apply(Suite.scala:1526) | |
| at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) | |
| at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108) | |
| at org.scalatest.Suite$class.runNestedSuites(Suite.scala:1526) | |
| at org.scalatest.tools.DiscoverySuite.runNestedSuites(DiscoverySuite.scala:29) | |
| at org.scalatest.Suite$class.run(Suite.scala:1421) | |
| at org.scalatest.tools.DiscoverySuite.run(DiscoverySuite.scala:29) | |
| at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:55) | |
| at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2563) | |
| at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2557) | |
| at scala.collection.immutable.List.foreach(List.scala:318) | |
| at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:2557) | |
| at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1044) | |
| at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1043) | |
| at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:2722) | |
| at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:1043) | |
| at org.scalatest.tools.Runner$.main(Runner.scala:860) | |
| at org.scalatest.tools.Runner.main(Runner.scala) | |
| - C = A + B side test 1 (991 milliseconds) | |
| - C = A + B side test 2 (1 second, 3 milliseconds) | |
| - C = A + B side test 3 (1 second, 53 milliseconds) | |
| - Ax (482 milliseconds) | |
| - A'x (517 milliseconds) | |
| - colSums, colMeans (951 milliseconds) | |
| - rowSums, rowMeans (967 milliseconds) | |
| - A.diagv (487 milliseconds) | |
| - numNonZeroElementsPerColumn (482 milliseconds) | |
| - C = A cbind B, cogroup (500 milliseconds) | |
| - C = A cbind B, zip (530 milliseconds) | |
| - B = 1 cbind A (476 milliseconds) | |
| - B = A cbind 1 (491 milliseconds) | |
| - B = A + 1.0 (462 milliseconds) | |
| - C = A rbind B (491 milliseconds) | |
| - C = A rbind B, with empty (480 milliseconds) | |
| - scalarOps (547 milliseconds) | |
| - A * A -> sqr(A) rewrite (502 milliseconds) | |
| - B = 1 + 2 * (A * A) ew unary function fusion (476 milliseconds) | |
| DrmLikeOpsSuite: | |
| - mapBlock (505 milliseconds) | |
| - allReduceBlock (2 milliseconds) | |
| - col range (488 milliseconds) | |
| - row range (508 milliseconds) | |
| - col, row range (496 milliseconds) | |
| - dsqDist(X,Y) *** FAILED *** (1 second, 911 milliseconds) | |
| org.apache.flink.runtime.client.JobExecutionException: Job execution failed. | |
| at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:314) | |
| 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.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:92) | |
| 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) | |
| Cause: java.lang.ArrayIndexOutOfBoundsException: 9 | |
| at org.apache.mahout.math.drm.package$$anonfun$4$$anonfun$apply$3.apply(package.scala:318) | |
| at org.apache.mahout.math.drm.package$$anonfun$4$$anonfun$apply$3.apply(package.scala:318) | |
| at org.apache.mahout.math.scalabindings.MatrixOps$$anonfun$$colon$eq$3$$anonfun$apply$2.apply(MatrixOps.scala:163) | |
| at org.apache.mahout.math.scalabindings.MatrixOps$$anonfun$$colon$eq$3$$anonfun$apply$2.apply(MatrixOps.scala:163) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:727) | |
| at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) | |
| at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) | |
| at scala.collection.AbstractIterable.foreach(Iterable.scala:54) | |
| at org.apache.mahout.math.scalabindings.MatrixOps$$anonfun$$colon$eq$3.apply(MatrixOps.scala:163) | |
| at org.apache.mahout.math.scalabindings.MatrixOps$$anonfun$$colon$eq$3.apply(MatrixOps.scala:163) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:727) | |
| at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) | |
| at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) | |
| at scala.collection.AbstractIterable.foreach(Iterable.scala:54) | |
| at org.apache.mahout.math.scalabindings.MatrixOps.$colon$eq(MatrixOps.scala:163) | |
| at org.apache.mahout.math.drm.package$$anonfun$4.apply(package.scala:318) | |
| at org.apache.mahout.math.drm.package$$anonfun$4.apply(package.scala:312) | |
| at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$$anon$1.map(FlinkOpMapBlock.scala:39) | |
| at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$$anon$1.map(FlinkOpMapBlock.scala:37) | |
| at org.apache.flink.runtime.operators.chaining.ChainedMapDriver.collect(ChainedMapDriver.java:78) | |
| at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$$anon$2.reduce(FlinkOpAtB.scala:91) | |
| at org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator$TupleUnwrappingNonCombinableGroupReducer.reduce(PlanUnwrappingReduceGroupOperator.java:101) | |
| at org.apache.flink.runtime.operators.GroupReduceDriver.run(GroupReduceDriver.java:125) | |
| at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) | |
| at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) | |
| at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
| at java.lang.Thread.run(Thread.java:745) | |
| - dsqDist(X) *** FAILED *** (1 second, 142 milliseconds) | |
| org.apache.flink.runtime.client.JobExecutionException: Job execution failed. | |
| at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:314) | |
| 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.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:92) | |
| 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) | |
| Cause: java.lang.ArrayIndexOutOfBoundsException: 7 | |
| at org.apache.mahout.math.drm.package$$anonfun$3$$anonfun$apply$2.apply(package.scala:277) | |
| at org.apache.mahout.math.drm.package$$anonfun$3$$anonfun$apply$2.apply(package.scala:277) | |
| at org.apache.mahout.math.scalabindings.MatrixOps$$anonfun$$colon$eq$3$$anonfun$apply$2.apply(MatrixOps.scala:163) | |
| at org.apache.mahout.math.scalabindings.MatrixOps$$anonfun$$colon$eq$3$$anonfun$apply$2.apply(MatrixOps.scala:163) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:727) | |
| at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) | |
| at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) | |
| at scala.collection.AbstractIterable.foreach(Iterable.scala:54) | |
| at org.apache.mahout.math.scalabindings.MatrixOps$$anonfun$$colon$eq$3.apply(MatrixOps.scala:163) | |
| at org.apache.mahout.math.scalabindings.MatrixOps$$anonfun$$colon$eq$3.apply(MatrixOps.scala:163) | |
| at scala.collection.Iterator$class.foreach(Iterator.scala:727) | |
| at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) | |
| at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) | |
| at scala.collection.AbstractIterable.foreach(Iterable.scala:54) | |
| at org.apache.mahout.math.scalabindings.MatrixOps.$colon$eq(MatrixOps.scala:163) | |
| at org.apache.mahout.math.drm.package$$anonfun$3.apply(package.scala:277) | |
| at org.apache.mahout.math.drm.package$$anonfun$3.apply(package.scala:271) | |
| at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$$anon$1.map(FlinkOpMapBlock.scala:39) | |
| at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$$anon$1.map(FlinkOpMapBlock.scala:37) | |
| at org.apache.flink.runtime.operators.chaining.ChainedMapDriver.collect(ChainedMapDriver.java:78) | |
| at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$$anon$2.reduce(FlinkOpAtB.scala:91) | |
| at org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceGroupOperator$TupleUnwrappingNonCombinableGroupReducer.reduce(PlanUnwrappingReduceGroupOperator.java:101) | |
| at org.apache.flink.runtime.operators.GroupReduceDriver.run(GroupReduceDriver.java:125) | |
| at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) | |
| at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) | |
| at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
| at java.lang.Thread.run(Thread.java:745) | |
| DistributedDecompositionsSuite: | |
| - thin distributed qr (1 second, 545 milliseconds) | |
| - dssvd - the naive-est - q=0 *** FAILED *** (1 second, 561 milliseconds) | |
| org.apache.flink.runtime.client.JobExecutionException: Job execution failed. | |
| at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:314) | |
| 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.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:92) | |
| 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) | |
| Cause: java.util.NoSuchElementException: head of empty list | |
| at scala.collection.immutable.Nil$.head(List.scala:337) | |
| at scala.collection.immutable.Nil$.head(List.scala:334) | |
| at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm$$anon$1.mapPartition(FlinkDrm.scala:68) | |
| at org.apache.flink.runtime.operators.MapPartitionDriver.run(MapPartitionDriver.java:98) | |
| at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) | |
| at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) | |
| at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
| at java.lang.Thread.run(Thread.java:745) | |
| - ddsvd - naive - q=1 *** FAILED *** (1 second, 699 milliseconds) | |
| org.apache.flink.runtime.client.JobExecutionException: Job execution failed. | |
| at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:314) | |
| 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.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:92) | |
| 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) | |
| Cause: java.util.NoSuchElementException: head of empty list | |
| at scala.collection.immutable.Nil$.head(List.scala:337) | |
| at scala.collection.immutable.Nil$.head(List.scala:334) | |
| at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm$$anon$1.mapPartition(FlinkDrm.scala:68) | |
| at org.apache.flink.runtime.operators.MapPartitionDriver.run(MapPartitionDriver.java:98) | |
| at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) | |
| at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) | |
| at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
| at java.lang.Thread.run(Thread.java:745) | |
| - ddsvd - naive - q=2 *** FAILED *** (1 second, 650 milliseconds) | |
| org.apache.flink.runtime.client.JobExecutionException: Job execution failed. | |
| at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$receiveWithLogMessages$1.applyOrElse(JobManager.scala:314) | |
| 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.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:92) | |
| 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) | |
| Cause: java.util.NoSuchElementException: head of empty list | |
| at scala.collection.immutable.Nil$.head(List.scala:337) | |
| at scala.collection.immutable.Nil$.head(List.scala:334) | |
| at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm$$anon$1.mapPartition(FlinkDrm.scala:68) | |
| at org.apache.flink.runtime.operators.MapPartitionDriver.run(MapPartitionDriver.java:98) | |
| at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496) | |
| at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362) | |
| at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559) | |
| at java.lang.Thread.run(Thread.java:745) | |
| - dspca *** FAILED *** (13 seconds, 369 milliseconds) | |
| 31.57794242060118 was not less than 1.0E-5 (DistributedDecompositionsSuiteBase.scala:177) | |
| org.scalatest.exceptions.TestFailedException: | |
| at org.scalatest.MatchersHelper$.newTestFailedException(MatchersHelper.scala:160) | |
| at org.scalatest.Matchers$ShouldMethodHelper$.shouldMatcher(Matchers.scala:6231) | |
| at org.scalatest.Matchers$AnyShouldWrapper.should(Matchers.scala:6265) | |
| at org.apache.mahout.math.decompositions.DistributedDecompositionsSuiteBase$$anonfun$5.apply$mcV$sp(DistributedDecompositionsSuiteBase.scala:177) | |
| at org.apache.mahout.math.decompositions.DistributedDecompositionsSuiteBase$$anonfun$5.apply(DistributedDecompositionsSuiteBase.scala:133) | |
| at org.apache.mahout.math.decompositions.DistributedDecompositionsSuiteBase$$anonfun$5.apply(DistributedDecompositionsSuiteBase.scala:133) | |
| at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22) | |
| at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85) | |
| at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104) | |
| at org.scalatest.Transformer.apply(Transformer.scala:22) | |
| at org.scalatest.Transformer.apply(Transformer.scala:20) | |
| at org.scalatest.FunSuiteLike$$anon$1.apply(FunSuiteLike.scala:166) | |
| at org.scalatest.Suite$class.withFixture(Suite.scala:1122) | |
| at org.scalatest.FunSuite.withFixture(FunSuite.scala:1555) | |
| at org.scalatest.FunSuiteLike$class.invokeWithFixture$1(FunSuiteLike.scala:163) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:175) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:175) | |
| at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306) | |
| at org.scalatest.FunSuiteLike$class.runTest(FunSuiteLike.scala:175) | |
| at org.apache.mahout.flinkbindings.standard.DistributedDecompositionsSuite.org$scalatest$BeforeAndAfterEach$$super$runTest(DistributedDecompositionsSuite.scala:16) | |
| at org.scalatest.BeforeAndAfterEach$class.runTest(BeforeAndAfterEach.scala:255) | |
| at org.apache.mahout.flinkbindings.standard.DistributedDecompositionsSuite.runTest(DistributedDecompositionsSuite.scala:16) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:208) | |
| at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:208) | |
| at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:413) | |
| at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401) | |
| at scala.collection.immutable.List.foreach(List.scala:318) | |
| at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401) | |
| at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:396) | |
| at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:483) | |
| at org.scalatest.FunSuiteLike$class.runTests(FunSuiteLike.scala:208) | |
| at org.scalatest.FunSuite.runTests(FunSuite.scala:1555) | |
| at org.scalatest.Suite$class.run(Suite.scala:1424) | |
| at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1555) | |
| at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:212) | |
| at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:212) | |
| at org.scalatest.SuperEngine.runImpl(Engine.scala:545) | |
| at org.scalatest.FunSuiteLike$class.run(FunSuiteLike.scala:212) | |
| at org.apache.mahout.flinkbindings.standard.DistributedDecompositionsSuite.org$scalatest$BeforeAndAfterAllConfigMap$$super$run(DistributedDecompositionsSuite.scala:16) | |
| at org.scalatest.BeforeAndAfterAllConfigMap$class.liftedTree1$1(BeforeAndAfterAllConfigMap.scala:248) | |
| at org.scalatest.BeforeAndAfterAllConfigMap$class.run(BeforeAndAfterAllConfigMap.scala:247) | |
| at org.apache.mahout.flinkbindings.standard.DistributedDecompositionsSuite.run(DistributedDecompositionsSuite.scala:16) | |
| at org.scalatest.Suite$class.callExecuteOnSuite$1(Suite.scala:1492) | |
| at org.scalatest.Suite$$anonfun$runNestedSuites$1.apply(Suite.scala:1528) | |
| at org.scalatest.Suite$$anonfun$runNestedSuites$1.apply(Suite.scala:1526) | |
| at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) | |
| at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108) | |
| at org.scalatest.Suite$class.runNestedSuites(Suite.scala:1526) | |
| at org.scalatest.tools.DiscoverySuite.runNestedSuites(DiscoverySuite.scala:29) | |
| at org.scalatest.Suite$class.run(Suite.scala:1421) | |
| at org.scalatest.tools.DiscoverySuite.run(DiscoverySuite.scala:29) | |
| at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:55) | |
| at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2563) | |
| at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2557) | |
| at scala.collection.immutable.List.foreach(List.scala:318) | |
| at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:2557) | |
| at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1044) | |
| at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1043) | |
| at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:2722) | |
| at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:1043) | |
| at org.scalatest.tools.Runner$.main(Runner.scala:860) | |
| at org.scalatest.tools.Runner.main(Runner.scala) | |
| *** RUN ABORTED *** (1 minute, 58 seconds) | |
| java.lang.OutOfMemoryError: Java heap space | |
| at java.util.Arrays.copyOf(Arrays.java:2271) | |
| at java.io.ByteArrayOutputStream.grow(ByteArrayOutputStream.java:113) | |
| at java.io.ByteArrayOutputStream.ensureCapacity(ByteArrayOutputStream.java:93) | |
| at java.io.ByteArrayOutputStream.write(ByteArrayOutputStream.java:140) | |
| at java.io.ObjectOutputStream$BlockDataOutputStream.write(ObjectOutputStream.java:1852) | |
| at java.io.ObjectOutputStream.write(ObjectOutputStream.java:708) | |
| at org.apache.flink.core.memory.OutputViewObjectOutputStreamWrapper.write(OutputViewObjectOutputStreamWrapper.java:59) | |
| at org.apache.flink.api.java.typeutils.runtime.DataOutputViewStream.write(DataOutputViewStream.java:39) | |
| at com.esotericsoftware.kryo.io.Output.flush(Output.java:163) | |
| at com.esotericsoftware.kryo.io.Output.require(Output.java:142) | |
| at com.esotericsoftware.kryo.io.Output.writeLong(Output.java:501) | |
| at com.esotericsoftware.kryo.io.Output.writeDouble(Output.java:630) | |
| at com.esotericsoftware.kryo.io.Output.writeDoubles(Output.java:711) | |
| at com.esotericsoftware.kryo.serializers.DefaultArraySerializers$DoubleArraySerializer.write(DefaultArraySerializers.java:198) | |
| at com.esotericsoftware.kryo.serializers.DefaultArraySerializers$DoubleArraySerializer.write(DefaultArraySerializers.java:187) | |
| at com.esotericsoftware.kryo.Kryo.writeObjectOrNull(Kryo.java:577) | |
| at com.esotericsoftware.kryo.serializers.DefaultArraySerializers$ObjectArraySerializer.write(DefaultArraySerializers.java:320) | |
| at com.esotericsoftware.kryo.serializers.DefaultArraySerializers$ObjectArraySerializer.write(DefaultArraySerializers.java:289) | |
| at com.esotericsoftware.kryo.Kryo.writeObjectOrNull(Kryo.java:577) | |
| at com.esotericsoftware.kryo.serializers.ObjectField.write(ObjectField.java:68) | |
| at com.esotericsoftware.kryo.serializers.FieldSerializer.write(FieldSerializer.java:495) | |
| at com.esotericsoftware.kryo.Kryo.writeObject(Kryo.java:523) | |
| at com.esotericsoftware.kryo.serializers.ObjectField.write(ObjectField.java:61) | |
| at com.esotericsoftware.kryo.serializers.FieldSerializer.write(FieldSerializer.java:495) | |
| at com.esotericsoftware.kryo.Kryo.writeClassAndObject(Kryo.java:599) | |
| at com.twitter.chill.Tuple2Serializer.write(TupleSerializers.scala:37) | |
| at com.twitter.chill.Tuple2Serializer.write(TupleSerializers.scala:33) | |
| at com.esotericsoftware.kryo.Kryo.writeClassAndObject(Kryo.java:599) | |
| at org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.serialize(KryoSerializer.java:186) | |
| at org.apache.flink.api.java.io.CollectionInputFormat.writeObject(CollectionInputFormat.java:88) | |
| at sun.reflect.GeneratedMethodAccessor11.invoke(Unknown Source) | |
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
That's what I am seeing too.