You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@mahout.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2016/08/09 01:34:55 UTC
Build failed in Jenkins: Mahout-Quality #3382
See <https://builds.apache.org/job/Mahout-Quality/3382/changes>
Changes:
[smarthi] MAHOUT-1877: Switch to Flink 1.1.0, this closes apache/mahout#249
------------------------------------------
[...truncated 109761 lines...]
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELING
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELING
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(1/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(2/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(3/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(4/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(5/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(6/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to FAILED
java.io.IOException: Insufficient number of network buffers: required 24, but only 11 available. The total number of network buffers is currently set to 2048. You can increase this number by setting the configuration key 'taskmanager.network.numberOfBuffers'.
at org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:196)
at org.apache.flink.runtime.io.network.NetworkEnvironment.registerTask(NetworkEnvironment.java:298)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:495)
at java.lang.Thread.run(Thread.java:745)
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to FAILED
java.io.IOException: Insufficient number of network buffers: required 24, but only 11 available. The total number of network buffers is currently set to 2048. You can increase this number by setting the configuration key 'taskmanager.network.numberOfBuffers'.
at org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:196)
at org.apache.flink.runtime.io.network.NetworkEnvironment.registerTask(NetworkEnvironment.java:298)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:495)
at java.lang.Thread.run(Thread.java:745)
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(7/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(8/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to FAILED
java.io.IOException: Insufficient number of network buffers: required 24, but only 11 available. The total number of network buffers is currently set to 2048. You can increase this number by setting the configuration key 'taskmanager.network.numberOfBuffers'.
at org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:196)
at org.apache.flink.runtime.io.network.NetworkEnvironment.registerTask(NetworkEnvironment.java:298)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:495)
at java.lang.Thread.run(Thread.java:745)
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(9/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(10/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(11/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(12/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(13/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(14/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(15/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(16/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(17/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(18/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(19/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(20/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(21/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(22/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(23/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(24/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(17/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(18/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(19/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(20/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(21/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(22/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(23/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(24/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(1/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(2/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(3/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(4/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(5/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(6/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(7/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(8/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(9/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(10/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(11/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(12/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(13/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(14/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(15/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(16/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(17/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(18/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(19/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(20/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(21/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(22/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(23/24) switched to CANCELED
08/09/2016 01:34:37 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4b8ecee5)(24/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
08/09/2016 01:34:37 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
08/09/2016 01:34:37 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
08/09/2016 01:34:37 Job execution switched to status FAILED.
[31m- dsqDist(X) *** FAILED ***[0m
[31m org.apache.flink.runtime.client.JobExecutionException: Job execution failed.[0m
[31m at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply$mcV$sp(JobManager.scala:822)[0m
[31m at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:768)[0m
[31m at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:768)[0m
[31m at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)[0m
[31m at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)[0m
[31m at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)[0m
[31m at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)[0m
[31m at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)[0m
[31m at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)[0m
[31m at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)[0m
[31m ...[0m
[31m Cause: java.io.IOException: Insufficient number of network buffers: required 24, but only 11 available. The total number of network buffers is currently set to 2048. You can increase this number by setting the configuration key 'taskmanager.network.numberOfBuffers'.[0m
[31m at org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:196)[0m
[31m at org.apache.flink.runtime.io.network.NetworkEnvironment.registerTask(NetworkEnvironment.java:298)[0m
[31m at org.apache.flink.runtime.taskmanager.Task.run(Task.java:495)[0m
[31m at java.lang.Thread.run(Thread.java:745)[0m
[31m ...[0m
[36mRun completed in 3 minutes, 48 seconds.[0m
[36mTotal number of tests run: 105[0m
[36mSuites: completed 11, aborted 0[0m
[36mTests: succeeded 86, failed 19, canceled 0, ignored 1, pending 0[0m
[31m*** 19 TESTS FAILED ***[0m
[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 [ 5.360 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.276 s]
[INFO] Mahout Math ........................................ SUCCESS [01:16 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 6.191 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [14:20 min]
[INFO] Mahout Integration ................................. SUCCESS [ 53.914 s]
[INFO] Mahout Examples .................................... SUCCESS [ 23.677 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:06 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:30 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [03:32 min]
[INFO] Mahout Flink bindings .............................. FAILURE [04:54 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 34:14 min
[INFO] Finished at: 2016-08-09T01:34:38+00:00
[INFO] Final Memory: 63M/476M
[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
Build step 'Invoke top-level Maven targets' marked build as failure
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
Compressed 171.08 MB of artifacts by 87.8% relative to #3381
Recording test results
Publishing Javadoc
Updating MAHOUT-1877
Jenkins build is back to normal : Mahout-Quality #3384
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3384/changes>
Build failed in Jenkins: Mahout-Quality #3383
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3383/changes>
Changes:
[smarthi] MAHOUT-1877: Fix for Flink 1.1.0 and hadoop 2 compatibility, fixed by
------------------------------------------
[...truncated 124046 lines...]
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(5/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(6/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(7/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(8/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(10/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(9/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(12/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(11/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(9/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(8/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(10/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to RUNNING
08/11/2016 05:52:31 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(12/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(11/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(6/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(5/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(7/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2b00ce90)(1/1) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2b00ce90)(1/1) switched to DEPLOYING
08/11/2016 05:52:31 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2b00ce90)(1/1) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2b00ce90)(1/1) switched to FINISHED
08/11/2016 05:52:31 Job execution switched to status FINISHED.
(100,100)
08/11/2016 05:52:31 Job execution switched to status RUNNING.
08/11/2016 05:52:31 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
08/11/2016 05:52:31 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
08/11/2016 05:52:31 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
08/11/2016 05:52:31 RangePartition: LocalSample(1/1) switched to SCHEDULED
08/11/2016 05:52:31 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
08/11/2016 05:52:31 RangePartition: LocalSample(1/1) switched to DEPLOYING
08/11/2016 05:52:31 RangePartition: PreparePartition(1/1) switched to SCHEDULED
08/11/2016 05:52:31 RangePartition: PreparePartition(1/1) switched to DEPLOYING
08/11/2016 05:52:31 RangePartition: LocalSample(1/1) switched to RUNNING
08/11/2016 05:52:31 RangePartition: PreparePartition(1/1) switched to RUNNING
08/11/2016 05:52:31 RangePartition: GlobalSample(1/1) switched to SCHEDULED
08/11/2016 05:52:31 RangePartition: GlobalSample(1/1) switched to DEPLOYING
08/11/2016 05:52:31 RangePartition: LocalSample(1/1) switched to FINISHED
08/11/2016 05:52:31 RangePartition: GlobalSample(1/1) switched to RUNNING
08/11/2016 05:52:31 RangePartition: Histogram(1/1) switched to SCHEDULED
08/11/2016 05:52:31 RangePartition: Histogram(1/1) switched to DEPLOYING
08/11/2016 05:52:31 RangePartition: GlobalSample(1/1) switched to FINISHED
08/11/2016 05:52:31 RangePartition: Histogram(1/1) switched to RUNNING
08/11/2016 05:52:31 RangePartition: Histogram(1/1) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED
08/11/2016 05:52:31 RangePartition: PreparePartition(1/1) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(2/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(2/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(8/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(1/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(8/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(5/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(9/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(1/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(3/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(5/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(3/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(9/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(6/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(6/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(16/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(4/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(15/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(16/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(4/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(15/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(13/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(13/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(14/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(14/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(10/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(10/16) switched to DEPLOYING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(12/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(12/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(11/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(11/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(7/16) switched to SCHEDULED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(7/16) switched to DEPLOYING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(2/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(8/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(5/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(1/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(3/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(9/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(6/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(16/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(4/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(15/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(13/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(14/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(10/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(12/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(11/16) switched to RUNNING
08/11/2016 05:52:31 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(7/16) switched to RUNNING
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(5/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(9/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(8/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(13/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(6/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(16/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(15/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(11/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(4/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(7/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(1/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(2/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(14/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(3/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(10/16) switched to FINISHED
08/11/2016 05:52:31 DataSink (org.apache.flink.api.java.Utils$CollectHelper@120e30)(12/16) switched to FINISHED
08/11/2016 05:52:31 Job execution switched to status FINISHED.
(7,100)
391656 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
[32m- dsqDist(X)[0m
[36mRun completed in 6 minutes, 43 seconds.[0m
[36mTotal number of tests run: 105[0m
[36mSuites: completed 11, aborted 0[0m
[36mTests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0[0m
[31m*** 1 TEST FAILED ***[0m
[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.625 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.161 s]
[INFO] Mahout Math ........................................ SUCCESS [01:20 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 11.022 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:28 min]
[INFO] Mahout Integration ................................. SUCCESS [ 55.679 s]
[INFO] Mahout Examples .................................... SUCCESS [ 25.620 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:03 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:30 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:26 min]
[INFO] Mahout Flink bindings .............................. FAILURE [07:47 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 34:18 min
[INFO] Finished at: 2016-08-11T05:52:32+00:00
[INFO] Final Memory: 64M/795M
[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
Build step 'Invoke top-level Maven targets' marked build as failure
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
Compressed 171.06 MB of artifacts by 91.3% relative to #3381
Recording test results
Publishing Javadoc
Updating MAHOUT-1877