See
<https://builds.apache.org/job/Mahout-Quality/3431/display/redirect?page=changes>
Changes:
[rawkintrevo] Add Trevor Grant (rawkintrevo) to Signing Keys
------------------------------------------
[...truncated 22.29 MB...]
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24)
switched to CANCELING
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24)
switched to CANCELING
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24)
switched to CANCELING
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24)
switched to CANCELING
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24)
switched to CANCELING
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24)
switched to CANCELING
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24)
switched to CANCELING
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(1/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(2/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(3/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(4/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(5/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(6/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(7/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(8/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(9/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(10/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(11/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(12/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(13/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(14/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(15/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(16/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(17/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(18/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(19/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(20/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(21/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(22/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(23/24)
switched to CANCELED
02/27/2017 05:50:34 DataSink
(org.apache.flink.api.java.io.TypeSerializerOutputFormat@40770e7a)(24/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24)
switched to CANCELED
02/27/2017 05:50:34 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
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24)
switched to CANCELED
02/27/2017 05:50:34 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
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24)
switched to CANCELED
208529 [Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(23/24)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))
(23/24)
java.lang.Exception: The data preparation for task 'Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))'
, caused an error: Error obtaining the sorted input: Thread 'SortMerger
Reading Thread' terminated due to an exception: Consumed partition
PipelinedSubpartitionView(index: 22) of ResultPartition
a33bb711da6bb50490b28307ea6808b2@a1c0388b676d1833d28a091dc2adfda1 has been
released.
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:462)
at
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:351)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:642)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.RuntimeException: Error obtaining the sorted input: Thread
'SortMerger Reading Thread' terminated due to an exception: Consumed partition
PipelinedSubpartitionView(index: 22) of ResultPartition
a33bb711da6bb50490b28307ea6808b2@a1c0388b676d1833d28a091dc2adfda1 has been
released.
at
org.apache.flink.runtime.operators.sort.UnilateralSortMerger.getIterator(UnilateralSortMerger.java:619)
at
org.apache.flink.runtime.operators.BatchTask.getInput(BatchTask.java:1098)
at
org.apache.flink.runtime.operators.ReduceDriver.prepare(ReduceDriver.java:95)
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:456)
... 3 more
Caused by: java.io.IOException: Thread 'SortMerger Reading Thread' terminated
due to an exception: Consumed partition PipelinedSubpartitionView(index: 22) of
ResultPartition
a33bb711da6bb50490b28307ea6808b2@a1c0388b676d1833d28a091dc2adfda1 has been
released.
at
org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:800)
Caused by: org.apache.flink.runtime.execution.CancelTaskException: Consumed
partition PipelinedSubpartitionView(index: 22) of ResultPartition
a33bb711da6bb50490b28307ea6808b2@a1c0388b676d1833d28a091dc2adfda1 has been
released.
at
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.getNextBuffer(LocalInputChannel.java:186)
at
org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:444)
at
org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:87)
at
org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:42)
at
org.apache.flink.runtime.operators.util.ReaderIterator.next(ReaderIterator.java:59)
at
org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ReadingThread.go(UnilateralSortMerger.java:973)
at
org.apache.flink.runtime.operators.sort.UnilateralSortMerger$ThreadBase.run(UnilateralSortMerger.java:796)
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24)
switched to CANCELED
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24)
switched to CANCELED
02/27/2017 05:50:34 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
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24)
switched to CANCELED
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24)
switched to CANCELED
02/27/2017 05:50:34 Reduce(Reduce at
org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24)
switched to CANCELED
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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
02/27/2017 05:50:34 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:805)[0m
[31m at
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:751)[0m
[31m at
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:751)[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 12 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:296)[0m
[31m at org.apache.flink.runtime.taskmanager.Task.run(Task.java:549)[0m
[31m at java.lang.Thread.run(Thread.java:745)[0m
[31m ...[0m
[36mRun completed in 3 minutes, 39 seconds.[0m
[36mTotal number of tests run: 112[0m
[36mSuites: completed 14, aborted 0[0m
[36mTests: succeeded 89, failed 23, canceled 0, ignored 1, pending 0[0m
[31m*** 23 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 [ 2.048 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.116 s]
[INFO] Mahout Math ........................................ SUCCESS [01:14 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 3.776 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [10:57 min]
[INFO] Mahout Integration ................................. SUCCESS [ 42.130 s]
[INFO] Mahout Examples .................................... SUCCESS [ 21.575 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:06 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:23 min]
[INFO] Mahout Release Package ............................. SUCCESS [ 1.229 s]
[INFO] Mahout Flink bindings .............................. FAILURE [04:21 min]
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 24:16 min
[INFO] Finished at: 2017-02-27T05:50:34+00:00
[INFO] Final Memory: 69M/624M
[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 160.75 MB of artifacts by 55.0% relative to #3418
Recording test results
Publishing Javadoc
