Discussion:
Build failed in Jenkins: Mahout-Quality #3355
Apache Jenkins Server
2016-05-12 12:24:39 UTC
Permalink
See <https://builds.apache.org/job/Mahout-Quality/3355/changes>

Changes:

[smarthi] 1. Upgrade to Flink 1.0.3 2. Minor fixes in code

------------------------------------------
[...truncated 110080 lines...]
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELING
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELING
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELING
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELING
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELING
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to FAILED
java.io.IOException: Insufficient number of network buffers: required 24, but only 5 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:327)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:469)
at java.lang.Thread.run(Thread.java:745)

05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELING
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELING
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 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
05/12/2016 12:24:16 DataSink (***@3274635)(1/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(2/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(3/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(4/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(5/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(6/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(7/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(8/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(9/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(10/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(11/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(12/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(13/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(14/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(15/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(16/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(17/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(18/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(19/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(20/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(21/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(22/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(23/24) switched to CANCELED
05/12/2016 12:24:16 DataSink (***@3274635)(24/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
05/12/2016 12:24:16 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
05/12/2016 12:24:16 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
05/12/2016 12:24:16 Job execution switched to status FAILED.
- dsqDist(X) *** FAILED ***
 org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
 at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply$mcV$sp(JobManager.scala:717)
 at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:663)
 at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:663)
 at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
 at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
 at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
 at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
 at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
 at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
 at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
 ...
 Cause: java.io.IOException: Insufficient number of network buffers: required 24, but only 5 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:327)
 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:469)
 at java.lang.Thread.run(Thread.java:745)
 ...
Run completed in 3 minutes, 23 seconds.
Total number of tests run: 105
Suites: completed 11, aborted 0
Tests: succeeded 85, failed 20, canceled 0, ignored 1, pending 0
*** 20 TESTS FAILED ***
[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 [ 3.347 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.410 s]
[INFO] Mahout Math ........................................ SUCCESS [01:06 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 5.700 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:13 min]
[INFO] Mahout Integration ................................. SUCCESS [ 41.695 s]
[INFO] Mahout Examples .................................... SUCCESS [ 20.824 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:23 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:19 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [03:02 min]
[INFO] Mahout Flink bindings .............................. FAILURE [04:30 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 29:50 min
[INFO] Finished at: 2016-05-12T12:24:17+00:00
[INFO] Final Memory: 66M/421M
[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 173.76 MB of artifacts by 87.0% relative to #3354
Recording test results
Publishing Javadoc
Apache Jenkins Server
2016-05-18 18:24:30 UTC
Permalink
See <https://builds.apache.org/job/Mahout-Quality/3356/changes>

Changes:

[apalumbo] MAHOUT-1859: temporariliy disable msurf and mgrid for 0.12.1 release.

------------------------------------------
[...truncated 61986 lines...]
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(3/4) switched to SCHEDULED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(3/4) switched to DEPLOYING
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(2/4) switched to FINISHED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(3/4) switched to RUNNING
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(3/4) switched to FINISHED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(4/4) switched to SCHEDULED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(1/4) switched to SCHEDULED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(4/4) switched to DEPLOYING
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(1/4) switched to DEPLOYING
05/18/2016 18:23:29 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to FINISHED
05/18/2016 18:23:29 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to FINISHED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(4/4) switched to RUNNING
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(1/4) switched to RUNNING
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(4/4) switched to FINISHED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@14f53a1b)(1/4) switched to FINISHED
05/18/2016 18:23:29 Job execution switched to status FINISHED.
05/18/2016 18:23:29 Job execution switched to status RUNNING.
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to FINISHED
05/18/2016 18:23:29 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
05/18/2016 18:23:29 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
05/18/2016 18:23:29 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to FINISHED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@704668c9)(1/1) switched to SCHEDULED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@704668c9)(1/1) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (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/4) switched to FINISHED
05/18/2016 18:23:29 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@704668c9)(1/1) switched to RUNNING
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@704668c9)(1/1) switched to FINISHED
05/18/2016 18:23:29 Job execution switched to status FINISHED.
(1,2)
11196 [ScalaTest-main-running-UseCasesSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
- use case: OLS Regression
05/18/2016 18:23:29 Job execution switched to status RUNNING.
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to DEPLOYING
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to RUNNING
05/18/2016 18:23:29 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to SCHEDULED
05/18/2016 18:23:29 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to FINISHED
05/18/2016 18:23:29 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to RUNNING
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to FINISHED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@27d619a7)(1/1) switched to SCHEDULED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@27d619a7)(1/1) switched to DEPLOYING
05/18/2016 18:23:29 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to FINISHED
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@27d619a7)(1/1) switched to RUNNING
05/18/2016 18:23:29 DataSink (org.apache.flink.api.java.Utils$***@27d619a7)(1/1) switched to FINISHED
05/18/2016 18:23:29 Job execution switched to status FINISHED.
05/18/2016 18:23:29 Job execution switched to status RUNNING.
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to SCHEDULED
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to DEPLOYING
05/18/2016 18:23:29 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: LocalSample(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to RUNNING
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to DEPLOYING
05/18/2016 18:23:29 RangePartition: GlobalSample(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to FINISHED
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: Histogram(1/1) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(1/4) switched to SCHEDULED
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(2/4) switched to SCHEDULED
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(1/4) switched to DEPLOYING
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(2/4) switched to DEPLOYING
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(3/4) switched to SCHEDULED
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(4/4) switched to SCHEDULED
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(3/4) switched to DEPLOYING
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(4/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(1/4) switched to RUNNING
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(2/4) switched to RUNNING
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(4/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
05/18/2016 18:23:29 RangePartition: PreparePartition(1/1) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
05/18/2016 18:23:29 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(3/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
05/18/2016 18:23:29 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000007e4e00000, 270008320, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (malloc) failed to allocate 270008320 bytes for committing reserved memory.
# An error report file with more information is saved as:
# <https://builds.apache.org/job/Mahout-Quality/ws/flink/hs_err_pid1561.log>
[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 [ 4.273 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.194 s]
[INFO] Mahout Math ........................................ SUCCESS [01:27 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 8.344 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [13:25 min]
[INFO] Mahout Integration ................................. SUCCESS [ 59.925 s]
[INFO] Mahout Examples .................................... SUCCESS [ 24.393 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:43 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:30 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:26 min]
[INFO] Mahout Flink bindings .............................. FAILURE [01:18 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 28:33 min
[INFO] Finished at: 2016-05-18T18:23:30+00:00
[INFO] Final Memory: 70M/499M
[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 173.76 MB of artifacts by 87.0% relative to #3354
Recording test results
Publishing Javadoc
Updating MAHOUT-1859
Apache Jenkins Server
2016-05-18 22:27:57 UTC
Permalink
See <https://builds.apache.org/job/Mahout-Quality/3357/changes>

Loading...