See <https://builds.apache.org/job/Mahout-Quality/3371/changes>
Changes:
[smarthi] [maven-release-plugin] prepare release mahout-0.12.2
[smarthi] [maven-release-plugin] prepare for next development iteration
------------------------------------------
[...truncated 63686 lines...]
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(7/16)
switched to RUNNING
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(4/16)
switched to SCHEDULED
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/16)
switched to RUNNING
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(4/16)
switched to DEPLOYING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/16)
switched to RUNNING
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(2/16)
switched to FINISHED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(2/16)
switched to SCHEDULED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(2/16)
switched to DEPLOYING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(16/16)
switched to FAILED
java.lang.Exception: Failed to deploy the task to slot SimpleSlot (0)(1) -
09bf0280e80b04bbb5f206c11daef115 @ localhost - 16 slots - URL:
akka://flink/user/taskmanager_1 - ALLOCATED/ALIVE: Response was not of type
Acknowledge
at
org.apache.flink.runtime.executiongraph.Execution$2.onComplete(Execution.java:395)
at akka.dispatch.OnComplete.internal(Future.scala:247)
at akka.dispatch.OnComplete.internal(Future.scala:244)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:174)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:171)
at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
at
scala.concurrent.impl.ExecutionContextImpl$$anon$3.exec(ExecutionContextImpl.scala:107)
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)
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/16)
switched to RUNNING
06/11/2016 15:40:02 Job execution switched to status FAILING.
java.lang.Exception: Failed to deploy the task to slot SimpleSlot (0)(1) -
09bf0280e80b04bbb5f206c11daef115 @ localhost - 16 slots - URL:
akka://flink/user/taskmanager_1 - ALLOCATED/ALIVE: Response was not of type
Acknowledge
at
org.apache.flink.runtime.executiongraph.Execution$2.onComplete(Execution.java:395)
at akka.dispatch.OnComplete.internal(Future.scala:247)
at akka.dispatch.OnComplete.internal(Future.scala:244)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:174)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:171)
at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
at
scala.concurrent.impl.ExecutionContextImpl$$anon$3.exec(ExecutionContextImpl.scala:107)
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)
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(8/16)
switched to FINISHED
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(11/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(12/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(13/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(14/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(15/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(16/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(8/16)
switched to RUNNING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(5/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(6/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(7/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(8/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(9/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(10/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(11/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(12/16)
switched to CANCELING
436346 [flink-akka.actor.default-dispatcher-15] ERROR
org.apache.flink.runtime.taskmanager.TaskManager - SubmitTask failed
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
org.apache.flink.runtime.taskmanager.Task.startTaskThread(Task.java:401)
at
org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.scala:1043)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$handleTaskMessage(TaskManager.scala:411)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$handleMessage$1.applyOrElse(TaskManager.scala:265)
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.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
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.taskmanager.TaskManager.aroundReceive(TaskManager.scala:119)
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)
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(13/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(14/16)
switched to CANCELING
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(11/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(15/16)
switched to CANCELING
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(1/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(2/16)
switched to CANCELING
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(3/16)
switched to CANCELING
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(4/16)
switched to CANCELING
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(5/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(6/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(7/16)
switched to CANCELING
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(8/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(9/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(10/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(11/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(12/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(13/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(14/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(15/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(16/16)
switched to CANCELED
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(7/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(13/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(16/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(14/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/16)
switched to CANCELED
436348 [flink-akka.actor.default-dispatcher-7] ERROR
org.apache.flink.runtime.taskmanager.TaskManager - SubmitTask failed
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
org.apache.flink.runtime.taskmanager.Task.startTaskThread(Task.java:401)
at
org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.scala:1043)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$handleTaskMessage(TaskManager.scala:411)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$handleMessage$1.applyOrElse(TaskManager.scala:265)
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.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
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.taskmanager.TaskManager.aroundReceive(TaskManager.scala:119)
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)
06/11/2016 15:40:02 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@38784680)(4/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(15/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN RangePartition: Partition -> Partition(12/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(7/16)
switched to CANCELED
06/11/2016 15:40:02 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/16)
switched to CANCELED
442314 [Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(15/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(15/16)
org.apache.flink.runtime.io.network.partition.PartitionNotFoundException:
Partition d474fccf5ce3d836e060d1ee90d512c8@4b58fed97961f6963e2fadeaf97ae34e not
found.
at
org.apache.flink.runtime.io.network.partition.ResultPartitionManager.createSubpartitionView(ResultPartitionManager.java:76)
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.requestSubpartition(LocalInputChannel.java:103)
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel$1.run(LocalInputChannel.java:136)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
442315 [Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(15/16)] ERROR org.apache.flink.runtime.taskmanager.Task - FATAL - exception
in task resource cleanup
java.lang.IllegalStateException: Memory manager has been shut down.
at
org.apache.flink.runtime.memory.MemoryManager.releaseAll(MemoryManager.java:468)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:661)
at java.lang.Thread.run(Thread.java:745)
442317 [Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(6/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(6/16)
org.apache.flink.runtime.io.network.partition.PartitionNotFoundException:
Partition ac59c361e85adb032d116a6aa5e8e65c@5e4270569522bc026a0525ada9101c46 not
found.
at
org.apache.flink.runtime.io.network.partition.ResultPartitionManager.createSubpartitionView(ResultPartitionManager.java:76)
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.requestSubpartition(LocalInputChannel.java:103)
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel$1.run(LocalInputChannel.java:136)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
442318 [Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(6/16)] ERROR org.apache.flink.runtime.taskmanager.Task - FATAL - exception
in task resource cleanup
java.lang.IllegalStateException: Memory manager has been shut down.
at
org.apache.flink.runtime.memory.MemoryManager.releaseAll(MemoryManager.java:468)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:661)
at java.lang.Thread.run(Thread.java:745)
442329 [Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(11/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(11/16)
org.apache.flink.runtime.io.network.partition.PartitionNotFoundException:
Partition 2047d64a60ccdfe974ab92510e31a4bd@404e1b3c0f37f3b015ed3827da6163ba not
found.
at
org.apache.flink.runtime.io.network.partition.ResultPartitionManager.createSubpartitionView(ResultPartitionManager.java:76)
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.requestSubpartition(LocalInputChannel.java:103)
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel$1.run(LocalInputChannel.java:136)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
442330 [Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(11/16)] ERROR org.apache.flink.runtime.taskmanager.Task - FATAL - exception
in task resource cleanup
java.lang.IllegalStateException: Memory manager has been shut down.
at
org.apache.flink.runtime.memory.MemoryManager.releaseAll(MemoryManager.java:468)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:661)
at java.lang.Thread.run(Thread.java:745)
442332 [Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(5/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(5/16)
org.apache.flink.runtime.io.network.partition.PartitionNotFoundException:
Partition 27b902bc3f6bc85e348eacba15e202d1@6854e73192d275d789fa43d97afd9b23 not
found.
at
org.apache.flink.runtime.io.network.partition.ResultPartitionManager.createSubpartitionView(ResultPartitionManager.java:76)
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.requestSubpartition(LocalInputChannel.java:103)
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel$1.run(LocalInputChannel.java:136)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
442333 [Combine (Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(5/16)] ERROR org.apache.flink.runtime.taskmanager.Task - FATAL - exception
in task resource cleanup
java.lang.IllegalStateException: Memory manager has been shut down.
at
org.apache.flink.runtime.memory.MemoryManager.releaseAll(MemoryManager.java:468)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:661)
at java.lang.Thread.run(Thread.java:745)
06/11/2016 15:40:42 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(14/16)
switched to CANCELED
06/11/2016 15:40:42 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(12/16)
switched to CANCELED
06/11/2016 15:40:42 CHAIN MapPartition (MapPartition at
org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))
-> Map (Map at
org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))
-> FlatMap (FlatMap at
org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(15/16)
switched to CANCELED
Build timed out (after 223 minutes). Marking the build as failed.
Build was aborted
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Apache Mahout
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Mahout Build Tools
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO]
[INFO] Mahout Build Tools ................................. SUCCESS [ 2.424 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.144 s]
[INFO] Mahout Math ........................................ SUCCESS [01:19 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 4.194 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [13:05 min]
[INFO] Mahout Integration ................................. SUCCESS [ 46.705 s]
[INFO] Mahout Examples .................................... SUCCESS [ 24.518 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:17 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:32 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:26 min]
[INFO] Mahout Flink bindings .............................. FAILURE [ 03:15 h]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 03:42 h
[INFO] Finished at: 2016-06-11T18:47:34+00:00
[INFO] Final Memory: 62M/787M
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.scalatest:scalatest-maven-plugin:1.0:test
(test) on project mahout-flink_2.10: There are test failures -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e
switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]
[ERROR] For more information about the errors and possible solutions, please
read the following articles:
[ERROR] [Help 1]
http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
[ERROR]
[ERROR] After correcting the problems, you can resume the build with the command
[ERROR] mvn <goals> -rf :mahout-flink_2.10
Compressed 171.05 MB of artifacts by 86.9% relative to #3363
Recording test results
Publishing Javadoc
