You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@mahout.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2016/04/20 20:16:56 UTC
Build failed in Jenkins: Mahout-Quality #3341
See <https://builds.apache.org/job/Mahout-Quality/3341/changes>
Changes:
[apalumbo] (nojira) travis: test math, hdfs, math-scala, spark only closes
------------------------------------------
[...truncated 94296 lines...]
04/20/2016 18:15:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41ef33c1)(1/1) switched to DEPLOYING
04/20/2016 18:15:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
04/20/2016 18:15:38 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
04/20/2016 18:15:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41ef33c1)(1/1) switched to RUNNING
04/20/2016 18:15:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41ef33c1)(1/1) switched to FINISHED
04/20/2016 18:15:38 Job execution switched to status FINISHED.
(40,40)
04/20/2016 18:15:39 Job execution switched to status RUNNING.
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to RUNNING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(1/4) switched to SCHEDULED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(1/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to FINISHED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(2/4) switched to SCHEDULED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(2/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(3/4) switched to SCHEDULED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(3/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(4/4) switched to SCHEDULED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(4/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to SCHEDULED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to SCHEDULED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to SCHEDULED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to SCHEDULED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to DEPLOYING
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to SCHEDULED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to DEPLOYING
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to SCHEDULED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(1/4) switched to RUNNING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(2/4) switched to RUNNING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(3/4) switched to RUNNING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to RUNNING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(4/4) switched to RUNNING
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to SCHEDULED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to RUNNING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to FINISHED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to FINISHED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to RUNNING
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to SCHEDULED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to DEPLOYING
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to RUNNING
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to FINISHED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to FINISHED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to RUNNING
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to FINISHED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(3/4) switched to FINISHED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to FINISHED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to FINISHED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to FINISHED
04/20/2016 18:15:39 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(3/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(3/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(2/4) switched to FINISHED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(1/4) switched to FINISHED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to FINISHED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37))(4/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(1/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(1/4) switched to DEPLOYING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(2/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(2/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(4/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(4/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(3/4) switched to RUNNING
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(2/4) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(1/4) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(3/4) switched to FINISHED
04/20/2016 18:15:39 CHAIN Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(4/4) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(1/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(2/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@7e4384b3)(4/4) switched to FINISHED
04/20/2016 18:15:39 Job execution switched to status FINISHED.
04/20/2016 18:15:39 Job execution switched to status RUNNING.
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to RUNNING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(1/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(1/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(2/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(2/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to FINISHED
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(1/4) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(1/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(2/4) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(3/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(3/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(3/4) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(2/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(3/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(4/4) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(4/4) switched to DEPLOYING
04/20/2016 18:15:39 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(4/4) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@373e9a13)(4/4) switched to FINISHED
04/20/2016 18:15:39 Job execution switched to status FINISHED.
04/20/2016 18:15:39 Job execution switched to status RUNNING.
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
04/20/2016 18:15:39 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
04/20/2016 18:15:39 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
04/20/2016 18:15:39 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
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@5d7a47b7)(1/1) switched to SCHEDULED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@5d7a47b7)(1/1) switched to DEPLOYING
04/20/2016 18:15:39 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@5d7a47b7)(1/1) switched to RUNNING
04/20/2016 18:15:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@5d7a47b7)(1/1) switched to FINISHED
04/20/2016 18:15:39 Job execution switched to status FINISHED.
(10,500)
pca:
{
0 => {0:2.090918733320634,1:2.012155789567859,2:-0.5978491551725623,3:0.3601839657907424,4:-0.4301796837135925,5:8.048373757734629E-4,6:0.008205552842679547,7:0.007107341025588364,8:0.00276261596161221,9:6.442554776006112E-4}
1 => {0:2.26604710233042,1:1.5285588530043563,2:-0.6135836929116393,3:0.3574403111361557,4:0.17478122499523338,5:0.15885341692040383,6:0.020306946838239377,7:0.004178602043814824,8:0.0018917370302710189,9:8.813987460367163E-4}
2 => {0:-14.592387596170045,1:-0.5836079619469777,2:-0.5989625958235241,3:0.3347183486023803,4:0.14766616006290462,5:-0.04655868461454374,6:0.0032368725845666486,7:0.003236847854859773,8:8.746686080017876E-4,9:-0.002749798090505071}
3 => {0:0.4284698281342152,1:2.171362446954195,2:-0.5872570690150916,3:0.3755253101985208,4:0.09393710522987284,5:-0.028725193357645725,6:0.02176539847903521,7:0.002883789121169779,8:0.0018883531853325722,9:-0.002811554681709644}
4 => {0:2.0764967782898682,1:3.5241066878884464,2:3.032062416077111,3:0.21445960781921905,4:0.1299247731515557,5:-0.05148555993781586,6:0.02348600827389116,7:0.004082065834064533,8:8.164485869492091E-4,9:0.0012621032347288708}
5 => {0:-14.153628534487789,1:-1.2092406591978648,2:-0.533866174430262,3:0.19088326279807227,4:0.07869112681485578,5:-0.01990446550191406,6:0.011131477999119734,7:-0.02376889432694065,8:-0.007952711446421788,9:8.712923434610288E-4}
6 => {0:1.9588955385466678,1:2.4636911448071532,2:3.052524727720007,3:0.16486966970402214,4:0.16480837174792065,5:0.16214108661407217,6:0.020029220465472203,7:0.002963419033708272,8:0.0020539196291761135,9:0.0013423909296310884}
7 => {0:0.9219332128821778,1:1.8821030811924497,2:-0.7199893511464792,3:0.41050988277699674,4:0.11892395058574491,5:-0.04224315734275653,6:-0.0633275264470881,7:0.005529076824967711,8:-0.009772183415388151,9:0.0013446416028830295}
8 => {0:-14.145818737538741,1:-1.1699969480728294,2:-0.40554521480483047,3:0.1976956942046447,4:0.06537963940467842,5:-0.01894089363231766,6:0.010931966226267275,7:0.00593724191726731,8:0.0023812421864912734,9:7.875535718017027E-4}
9 => {0:5.844317557785366,1:-4.916841499316033,2:3.223470334519887,3:0.038760720083132125,4:0.0939461395911826,5:-0.049637825744005847,6:0.025390881376977658,7:0.004472511975435314,8:-0.009071253447319405,9:9.358686242487825E-4}
... }
pcaControl:
{
0 => {0:2.0909187314835473,1:2.0121557867643767,2:-0.597849142573616,3:-0.36018395178354085,4:0.4301796656381306,5:-8.048004266410234E-4,6:0.008205552854618986,7:-0.007107340442498095,8:-0.002762618526126809,9:6.443143813706793E-4}
1 => {0:2.266047100111712,1:1.5285588523711118,2:-0.6135837033417864,3:-0.3574403142647051,4:-0.17478119958032384,5:-0.1588534634829475,6:0.020306966364173624,7:-0.0041786103324904355,8:-0.0018917557213346142,9:8.813214323054718E-4}
2 => {0:-14.592387597456128,1:-0.5836079631543104,2:-0.5989625927098118,3:-0.3347183503792681,4:-0.1476661678934028,5:0.046558699780707154,6:0.003236856382683882,7:-0.0032368403871433043,8:-8.746452449047834E-4,9:-0.0027497720319186866}
3 => {0:0.4284698116779148,1:2.1713624397963867,2:-0.5872570456802904,3:-0.3755253404900546,4:-0.09393716167302114,5:0.02872528110545159,6:0.021765318228849057,7:-0.002883731544123946,8:-0.0018882651059701813,9:-0.0028113401660610363}
4 => {0:2.076496776666685,1:3.524106681577826,2:3.0320624205534576,3:-0.2144595689805403,4:-0.12992475941961096,5:0.05148555183557413,6:0.023486054707418217,7:-0.004082100307487471,8:-8.164943767598199E-4,9:0.0012620449423510214}
5 => {0:-14.153628531635276,1:-1.2092406581048991,2:-0.533866189831533,3:-0.19088331124196403,4:-0.0786911346598924,5:0.01990446520306995,6:0.011131407594543848,7:0.023768929349666543,8:0.007952788393472247,9:8.712986623166462E-4}
6 => {0:1.958895542525016,1:2.463691152528346,2:3.0525247032241922,3:-0.16486974214701594,4:-0.16480837246800953,5:-0.16214110981599844,6:0.020029135145301413,7:-0.0029633666015461547,8:-0.002053817791555493,9:0.001342389206394915}
7 => {0:0.9219332012022166,1:1.8821030743958143,2:-0.7199893242805223,3:-0.4105098860961941,4:-0.11892399030638225,5:0.04224322321405938,6:-0.06332755567385973,7:-0.0055290561457208695,8:0.00977219438725887,9:0.0013448071029162514}
8 => {0:-14.145818737290206,1:-1.1699969497186093,2:-0.4055452071020734,3:-0.19769567343974745,4:-0.06537963764260095,5:0.01894089709026742,6:0.01093199314522763,7:-0.005937260047367135,8:-0.0023812805079388797,9:7.875470393318356E-4}
9 => {0:5.8443175626254025,1:-4.916841491024554,2:3.2234703036295165,3:-0.03876080042696709,4:-0.09394612950285214,5:0.04963778340175989,6:0.025390784437323847,7:-0.004472459688514453,8:0.009071381314498974,9:9.358398515440079E-4}
... }
[32m- dspca[0m
spectrum:{0:300.0,1:110.3638323514327,2:40.60058497098381,3:14.936120510359183,4:5.494691666620254,5:2.02138409972564,6:0.7436256529999076,7:0.2735645896663549,8:0.10063878837075356,9:0.037022941226003865,10:0.013619978928745457,11:0.005010510237073698,12:0.001843263705998463,13:0.001,14:0.001,15:0.001,16:0.001,17:0.001,18:0.001,19:0.001,20:0.001,21:0.001,22:0.001,23:0.001,24:0.001,25:0.001,26:0.001,27:0.001,28:0.001,29:0.001,30:0.001,31:0.001,32:0.001,33:0.001,34:0.001,35:0.001,36:0.001,37:0.001,38:0.001,39:0.001}
04/20/2016 18:15:42 Job execution switched to status RUNNING.
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to RUNNING
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000766600000, 509607936, 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 509607936 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_pid19890.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 [ 16.086 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.393 s]
[INFO] Mahout Math ........................................ SUCCESS [01:11 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 11.191 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [11:41 min]
[INFO] Mahout Integration ................................. SUCCESS [ 50.200 s]
[INFO] Mahout Examples .................................... SUCCESS [ 20.327 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [03:52 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:19 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [01:58 min]
[INFO] Mahout Flink bindings .............................. FAILURE [01:35 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 25:21 min
[INFO] Finished at: 2016-04-20T18:15:45+00:00
[INFO] Final Memory: 70M/441M
[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 170.96 MB of artifacts by 87.6% relative to #3340
Recording test results
Publishing Javadoc
Jenkins build is back to normal : Mahout-Quality #3345
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3345/changes>
Build failed in Jenkins: Mahout-Quality #3344
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3344/changes>
Changes:
[smarthi] MAHOUT-1835: Remove countsPerPartition in Flink/blas/package.scala
------------------------------------------
[...truncated 108379 lines...]
04/23/2016 14:58:38 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))(13/16) switched to DEPLOYING
04/23/2016 14:58:38 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))(14/16) switched to SCHEDULED
04/23/2016 14:58:38 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))(14/16) switched to DEPLOYING
04/23/2016 14:58:38 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))(15/16) switched to SCHEDULED
04/23/2016 14:58:38 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))(15/16) switched to DEPLOYING
04/23/2016 14:58:38 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))(16/16) switched to SCHEDULED
04/23/2016 14:58:38 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))(16/16) switched to DEPLOYING
04/23/2016 14:58:38 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/16) switched to RUNNING
04/23/2016 14:58:38 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/16) switched to RUNNING
04/23/2016 14:58:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
04/23/2016 14:58:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
04/23/2016 14:58:38 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/16) switched to RUNNING
04/23/2016 14:58:38 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/16) switched to RUNNING
04/23/2016 14:58:38 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))(5/16) switched to RUNNING
04/23/2016 14:58:38 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))(6/16) switched to RUNNING
04/23/2016 14:58:38 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))(7/16) switched to RUNNING
04/23/2016 14:58:38 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))(8/16) switched to RUNNING
04/23/2016 14:58:38 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))(9/16) switched to RUNNING
04/23/2016 14:58:38 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))(10/16) switched to RUNNING
04/23/2016 14:58:38 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))(11/16) switched to RUNNING
04/23/2016 14:58:38 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))(12/16) switched to RUNNING
04/23/2016 14:58:38 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))(13/16) switched to RUNNING
04/23/2016 14:58:38 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))(14/16) switched to RUNNING
04/23/2016 14:58:38 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))(15/16) switched to RUNNING
04/23/2016 14:58:38 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))(9/16) switched to FINISHED
04/23/2016 14:58:38 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))(16/16) switched to RUNNING
04/23/2016 14:58:38 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))(14/16) switched to FINISHED
04/23/2016 14:58:38 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))(13/16) switched to FINISHED
04/23/2016 14:58:38 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))(12/16) switched to FINISHED
04/23/2016 14:58:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
04/23/2016 14:58:38 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))(11/16) switched to FINISHED
04/23/2016 14:58:38 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))(15/16) switched to FINISHED
04/23/2016 14:58:38 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))(16/16) switched to FINISHED
04/23/2016 14:58:38 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))(10/16) switched to FINISHED
04/23/2016 14:58:38 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))(7/16) switched to FINISHED
04/23/2016 14:58:38 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/16) switched to FINISHED
04/23/2016 14:58:38 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/16) switched to FINISHED
04/23/2016 14:58:38 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/16) switched to FINISHED
04/23/2016 14:58:38 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))(5/16) switched to FINISHED
04/23/2016 14:58:38 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))(6/16) switched to FINISHED
04/23/2016 14:58:38 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/16) switched to FINISHED
04/23/2016 14:58:38 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))(8/16) switched to FINISHED
04/23/2016 14:58:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@36a3f5ad)(1/1) switched to SCHEDULED
04/23/2016 14:58:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@36a3f5ad)(1/1) switched to DEPLOYING
04/23/2016 14:58:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
04/23/2016 14:58:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@36a3f5ad)(1/1) switched to RUNNING
04/23/2016 14:58:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@36a3f5ad)(1/1) switched to FINISHED
04/23/2016 14:58:38 Job execution switched to status FINISHED.
(100,100)
04/23/2016 14:58:39 Job execution switched to status RUNNING.
04/23/2016 14:58:39 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/23/2016 14:58:39 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/23/2016 14:58:39 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/23/2016 14:58:39 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/23/2016 14:58:39 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/23/2016 14:58:39 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
04/23/2016 14:58:39 RangePartition: PreparePartition(1/1) switched to SCHEDULED
04/23/2016 14:58:39 RangePartition: PreparePartition(1/1) switched to DEPLOYING
04/23/2016 14:58:39 RangePartition: LocalSample(1/1) switched to RUNNING
04/23/2016 14:58:39 RangePartition: PreparePartition(1/1) switched to RUNNING
04/23/2016 14:58:39 RangePartition: GlobalSample(1/1) switched to SCHEDULED
04/23/2016 14:58:39 RangePartition: GlobalSample(1/1) switched to DEPLOYING
04/23/2016 14:58:39 RangePartition: LocalSample(1/1) switched to FINISHED
04/23/2016 14:58:39 RangePartition: GlobalSample(1/1) switched to RUNNING
04/23/2016 14:58:39 RangePartition: Histogram(1/1) switched to SCHEDULED
04/23/2016 14:58:39 RangePartition: Histogram(1/1) switched to DEPLOYING
04/23/2016 14:58:39 RangePartition: GlobalSample(1/1) switched to FINISHED
04/23/2016 14:58:39 RangePartition: Histogram(1/1) switched to RUNNING
04/23/2016 14:58:39 RangePartition: Histogram(1/1) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING
04/23/2016 14:58:39 RangePartition: PreparePartition(1/1) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(15/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(15/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(11/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(12/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(1/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(12/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(13/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(11/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(14/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(13/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(1/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(9/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(14/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(8/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(9/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(4/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(8/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(4/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(16/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(10/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(16/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(7/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(10/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(5/16) switched to SCHEDULED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(7/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(5/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(3/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(3/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(6/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(6/16) switched to DEPLOYING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(2/16) switched to SCHEDULED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(2/16) switched to DEPLOYING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(11/16) switched to RUNNING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(4/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(6/16) switched to RUNNING
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(12/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(1/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(15/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(3/16) switched to RUNNING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(2/16) switched to RUNNING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(7/16) switched to RUNNING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(13/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(16/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(4/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(8/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(5/16) switched to RUNNING
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(10/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(14/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(9/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(6/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED
04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(7/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(5/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(2/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(3/16) switched to FINISHED
04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(11/16) switched to FINISHED
04/23/2016 14:58:39 Job execution switched to status FINISHED.
(7,100)
431310 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
[32m- dsqDist(X)[0m
[36mRun completed in 7 minutes, 23 seconds.[0m
[36mTotal number of tests run: 105[0m
[36mSuites: completed 11, aborted 0[0m
[36mTests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0[0m
[31m*** 1 TEST FAILED ***[0m
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Apache Mahout
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Mahout Build Tools
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO]
[INFO] Mahout Build Tools ................................. SUCCESS [ 2.678 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.933 s]
[INFO] Mahout Math ........................................ SUCCESS [01:15 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 4.049 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:05 min]
[INFO] Mahout Integration ................................. SUCCESS [ 42.924 s]
[INFO] Mahout Examples .................................... SUCCESS [ 23.473 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:01 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:27 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:20 min]
[INFO] Mahout Flink bindings .............................. FAILURE [08:22 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 33:50 min
[INFO] Finished at: 2016-04-23T14:58:39+00:00
[INFO] Final Memory: 64M/792M
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.scalatest:scalatest-maven-plugin:1.0:test (test) on project mahout-flink_2.10: There are test failures -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]
[ERROR] For more information about the errors and possible solutions, please read the following articles:
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
[ERROR]
[ERROR] After correcting the problems, you can resume the build with the command
[ERROR] mvn <goals> -rf :mahout-flink_2.10
Build step 'Invoke top-level Maven targets' marked build as failure
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
Compressed 171.04 MB of artifacts by 87.8% relative to #3340
Recording test results
Publishing Javadoc
Updating MAHOUT-1835
Build failed in Jenkins: Mahout-Quality #3343
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3343/changes>
Changes:
[apalumbo] MAHOUT-1833: Enhance svec function to accept cardinality as parameter.
------------------------------------------
[...truncated 100400 lines...]
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELING
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELING
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 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
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(1/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(2/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(3/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(4/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(5/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(6/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(7/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(8/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(9/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(10/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(11/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(12/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(13/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(14/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(15/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(16/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(17/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(18/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(19/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(20/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(21/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(22/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(23/24) switched to CANCELED
04/22/2016 21:14:24 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@53d8a5ed)(24/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
04/22/2016 21:14:24 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
04/22/2016 21:14:24 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
04/22/2016 21:14:24 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$7.apply$mcV$sp(JobManager.scala:716)[0m
[31m at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:662)[0m
[31m at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:662)[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 9 available. The total number of network buffers is currently set to 2048. You can increase this number by setting the configuration key 'taskmanager.network.numberOfBuffers'.[0m
[31m at org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:196)[0m
[31m at org.apache.flink.runtime.io.network.NetworkEnvironment.registerTask(NetworkEnvironment.java:298)[0m
[31m at org.apache.flink.runtime.taskmanager.Task.run(Task.java:469)[0m
[31m at java.lang.Thread.run(Thread.java:745)[0m
[31m ...[0m
[36mRun completed in 3 minutes, 18 seconds.[0m
[36mTotal number of tests run: 105[0m
[36mSuites: completed 11, aborted 0[0m
[36mTests: succeeded 85, failed 20, canceled 0, ignored 1, pending 0[0m
[31m*** 20 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 [ 4.545 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.351 s]
[INFO] Mahout Math ........................................ SUCCESS [01:20 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 5.476 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [11:46 min]
[INFO] Mahout Integration ................................. SUCCESS [ 43.232 s]
[INFO] Mahout Examples .................................... SUCCESS [ 21.144 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:27 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:22 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [03:02 min]
[INFO] Mahout Flink bindings .............................. FAILURE [04:03 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 29:26 min
[INFO] Finished at: 2016-04-22T21:14:25+00:00
[INFO] Final Memory: 63M/543M
[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 170.97 MB of artifacts by 86.8% relative to #3340
Recording test results
Publishing Javadoc
Updating MAHOUT-1833
Build failed in Jenkins: Mahout-Quality #3342
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3342/changes>
Changes:
[smarthi] Updated the logo for Mahout 0.12.1 release
------------------------------------------
[...truncated 72888 lines...]
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
04/21/2016 00:30:32 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpAewScalar$.opScalarNoSideEffect(FlinkOpAewScalar.scala:46)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to RUNNING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
04/21/2016 00:30:32 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpAewScalar$.opScalarNoSideEffect(FlinkOpAewScalar.scala:46)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to RUNNING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
04/21/2016 00:30:32 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpAewScalar$.opScalarNoSideEffect(FlinkOpAewScalar.scala:46)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(4/4) switched to SCHEDULED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(4/4) switched to DEPLOYING
04/21/2016 00:30:32 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpAewScalar$.opScalarNoSideEffect(FlinkOpAewScalar.scala:46)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to FINISHED
04/21/2016 00:30:32 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpAewScalar$.opScalarNoSideEffect(FlinkOpAewScalar.scala:46)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(4/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(4/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(1/4) switched to SCHEDULED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(1/4) switched to DEPLOYING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(2/4) switched to SCHEDULED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(2/4) switched to DEPLOYING
04/21/2016 00:30:32 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpAewScalar$.opScalarNoSideEffect(FlinkOpAewScalar.scala:46)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(3/4) switched to SCHEDULED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(3/4) switched to DEPLOYING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(1/4) switched to RUNNING
04/21/2016 00:30:32 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpAewScalar$.opScalarNoSideEffect(FlinkOpAewScalar.scala:46)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(1/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(2/4) switched to RUNNING
04/21/2016 00:30:32 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpAewScalar$.opScalarNoSideEffect(FlinkOpAewScalar.scala:46)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(3/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(2/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@64ffe918)(3/4) switched to FINISHED
04/21/2016 00:30:32 Job execution switched to status FINISHED.
(2,3)
[32m- AewScalar opScalarNoSideEffect[0m
04/21/2016 00:30:32 Job execution switched to status RUNNING.
04/21/2016 00:30:32 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/21/2016 00:30:32 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/21/2016 00:30:32 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/21/2016 00:30:32 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/21/2016 00:30:32 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/21/2016 00:30:32 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
04/21/2016 00:30:32 RangePartition: PreparePartition(1/1) switched to SCHEDULED
04/21/2016 00:30:32 RangePartition: PreparePartition(1/1) switched to DEPLOYING
04/21/2016 00:30:32 RangePartition: LocalSample(1/1) switched to RUNNING
04/21/2016 00:30:32 RangePartition: PreparePartition(1/1) switched to RUNNING
04/21/2016 00:30:32 RangePartition: GlobalSample(1/1) switched to SCHEDULED
04/21/2016 00:30:32 RangePartition: GlobalSample(1/1) switched to DEPLOYING
04/21/2016 00:30:32 RangePartition: LocalSample(1/1) switched to FINISHED
04/21/2016 00:30:32 RangePartition: GlobalSample(1/1) switched to RUNNING
04/21/2016 00:30:32 RangePartition: Histogram(1/1) switched to SCHEDULED
04/21/2016 00:30:32 RangePartition: Histogram(1/1) switched to DEPLOYING
04/21/2016 00:30:32 RangePartition: GlobalSample(1/1) switched to FINISHED
04/21/2016 00:30:32 RangePartition: Histogram(1/1) switched to RUNNING
04/21/2016 00:30:32 RangePartition: Histogram(1/1) switched to FINISHED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING
04/21/2016 00:30:32 RangePartition: PreparePartition(1/1) switched to FINISHED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
04/21/2016 00:30:32 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(2/4) switched to SCHEDULED
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(1/4) switched to SCHEDULED
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(3/4) switched to SCHEDULED
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(2/4) switched to DEPLOYING
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(3/4) switched to DEPLOYING
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(1/4) switched to DEPLOYING
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(4/4) switched to SCHEDULED
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(4/4) switched to DEPLOYING
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(2/4) switched to RUNNING
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(1/4) switched to RUNNING
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(3/4) switched to RUNNING
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(4/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(3/4) switched to SCHEDULED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(1/4) switched to SCHEDULED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(3/4) switched to DEPLOYING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(1/4) switched to DEPLOYING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(3/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(1/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(3/4) switched to FINISHED
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(3/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(1/4) switched to FINISHED
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(1/4) switched to FINISHED
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(4/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(4/4) switched to SCHEDULED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(4/4) switched to DEPLOYING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(4/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(4/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(2/4) switched to SCHEDULED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(2/4) switched to DEPLOYING
04/21/2016 00:30:32 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpAewB$.rowWiseJoinNoSideEffect(FlinkOpAewB.scala:28))(2/4) switched to FINISHED
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(2/4) switched to RUNNING
04/21/2016 00:30:32 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2d05daca)(2/4) switched to FINISHED
04/21/2016 00:30:32 Job execution switched to status FINISHED.
(2,3)
[32m- AewB rowWiseJoinNoSideEffect[0m
04/21/2016 00:30:33 Job execution switched to status RUNNING.
04/21/2016 00:30:33 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/21/2016 00:30:33 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/21/2016 00:30:33 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/21/2016 00:30:33 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/21/2016 00:30:33 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/21/2016 00:30:33 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/21/2016 00:30:33 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
04/21/2016 00:30:33 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
04/21/2016 00:30:33 RangePartition: PreparePartition(1/1) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: PreparePartition(1/1) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: PreparePartition(1/1) switched to DEPLOYING
04/21/2016 00:30:33 RangePartition: PreparePartition(1/1) switched to DEPLOYING
04/21/2016 00:30:33 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/21/2016 00:30:33 RangePartition: LocalSample(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: PreparePartition(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: PreparePartition(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: LocalSample(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: GlobalSample(1/1) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: GlobalSample(1/1) switched to DEPLOYING
04/21/2016 00:30:33 RangePartition: GlobalSample(1/1) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: GlobalSample(1/1) switched to DEPLOYING
04/21/2016 00:30:33 RangePartition: LocalSample(1/1) switched to FINISHED
04/21/2016 00:30:33 RangePartition: GlobalSample(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: LocalSample(1/1) switched to FINISHED
04/21/2016 00:30:33 RangePartition: GlobalSample(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: Histogram(1/1) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: Histogram(1/1) switched to DEPLOYING
04/21/2016 00:30:33 RangePartition: GlobalSample(1/1) switched to FINISHED
04/21/2016 00:30:33 RangePartition: Histogram(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: Histogram(1/1) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: Histogram(1/1) switched to DEPLOYING
04/21/2016 00:30:33 RangePartition: GlobalSample(1/1) switched to FINISHED
04/21/2016 00:30:33 RangePartition: Histogram(1/1) switched to RUNNING
04/21/2016 00:30:33 RangePartition: Histogram(1/1) switched to FINISHED
04/21/2016 00:30:33 RangePartition: Histogram(1/1) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED
04/21/2016 00:30:33 RangePartition: PreparePartition(1/1) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(2/4) switched to SCHEDULED
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(4/4) switched to SCHEDULED
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(2/4) switched to DEPLOYING
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(4/4) switched to DEPLOYING
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(3/4) switched to SCHEDULED
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(3/4) switched to DEPLOYING
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(1/4) switched to SCHEDULED
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(1/4) switched to DEPLOYING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
04/21/2016 00:30:33 RangePartition: PreparePartition(1/1) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(4/4) switched to RUNNING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(3/4) switched to RUNNING
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(2/4) switched to RUNNING
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
04/21/2016 00:30:33 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
04/21/2016 00:30:33 CoGroup (CoGroup at org.apache.mahout.flinkbindings.blas.FlinkOpCBind$.cbind(FlinkOpCBind.scala:46))(1/4) switched to RUNNING
04/21/2016 00:30:33 DataSink (org.apache.flink.api.java.Utils$CollectHelper@47824081)(1/4) switched to SCHEDULED
04/21/2016 00:30:33 DataSink (org.apache.flink.api.java.Utils$CollectHelper@47824081)(1/4) switched to DEPLOYING
04/21/2016 00:30:33 DataSink (org.apache.flink.api.java.Utils$CollectHelper@47824081)(1/4) switched to RUNNING
04/21/2016 00:30:33 DataSink (org.apache.flink.api.java.Utils$CollectHelper@47824081)(2/4) switched to SCHEDULED
04/21/2016 00:30:33 DataSink (org.apache.flink.api.java.Utils$CollectHelper@47824081)(2/4) switched to DEPLOYING
04/21/2016 00:30:33 DataSink (org.apache.flink.api.java.Utils$CollectHelper@47824081)(2/4) switched to RUNNING
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000755f00000, 545783808, 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 545783808 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_pid10734.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.220 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.276 s]
[INFO] Mahout Math ........................................ SUCCESS [01:16 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 7.936 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [11:56 min]
[INFO] Mahout Integration ................................. SUCCESS [ 53.327 s]
[INFO] Mahout Examples .................................... SUCCESS [ 21.154 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:17 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:24 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:14 min]
[INFO] Mahout Flink bindings .............................. FAILURE [ 59.641 s]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 25:40 min
[INFO] Finished at: 2016-04-21T00:30:34+00:00
[INFO] Final Memory: 70M/418M
[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 170.96 MB of artifacts by 86.8% relative to #3340
Recording test results
Publishing Javadoc
Re: Build failed in Jenkins: Mahout-Quality #3341
Posted by Andrew Palumbo <ap...@outlook.com>.
Ok. this is just jenkins being jenkins I think.
________________________________________
From: Andrew Palumbo <ap...@outlook.com>
Sent: Wednesday, April 20, 2016 2:25 PM
To: mahout
Subject: Fw: Build failed in Jenkins: Mahout-Quality #3341
I have not seen this before. dspca failure in flink-bindings on Jenkins:
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000766600000, 509607936, 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 509607936 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_pid19890.log>
________________________________________
From: Apache Jenkins Server <je...@builds.apache.org>
Sent: Wednesday, April 20, 2016 2:16 PM
To: dev@mahout.apache.org
Subject: Build failed in Jenkins: Mahout-Quality #3341
See <https://builds.apache.org/job/Mahout-Quality/3341/changes>
Changes:
[apalumbo] (nojira) travis: test math, hdfs, math-scala, spark only closes
{...}
(10,500)
pca:
{
0 => {0:2.090918733320634,1:2.012155789567859,2:-0.5978491551725623,3:0.3601839657907424,4:-0.4301796837135925,5:8.048373757734629E-4,6:0.008205552842679547,7:0.007107341025588364,8:0.00276261596161221,9:6.442554776006112E-4}
1 => {0:2.26604710233042,1:1.5285588530043563,2:-0.6135836929116393,3:0.3574403111361557,4:0.17478122499523338,5:0.15885341692040383,6:0.020306946838239377,7:0.004178602043814824,8:0.0018917370302710189,9:8.813987460367163E-4}
2 => {0:-14.592387596170045,1:-0.5836079619469777,2:-0.5989625958235241,3:0.3347183486023803,4:0.14766616006290462,5:-0.04655868461454374,6:0.0032368725845666486,7:0.003236847854859773,8:8.746686080017876E-4,9:-0.002749798090505071}
3 => {0:0.4284698281342152,1:2.171362446954195,2:-0.5872570690150916,3:0.3755253101985208,4:0.09393710522987284,5:-0.028725193357645725,6:0.02176539847903521,7:0.002883789121169779,8:0.0018883531853325722,9:-0.002811554681709644}
4 => {0:2.0764967782898682,1:3.5241066878884464,2:3.032062416077111,3:0.21445960781921905,4:0.1299247731515557,5:-0.05148555993781586,6:0.02348600827389116,7:0.004082065834064533,8:8.164485869492091E-4,9:0.0012621032347288708}
5 => {0:-14.153628534487789,1:-1.2092406591978648,2:-0.533866174430262,3:0.19088326279807227,4:0.07869112681485578,5:-0.01990446550191406,6:0.011131477999119734,7:-0.02376889432694065,8:-0.007952711446421788,9:8.712923434610288E-4}
6 => {0:1.9588955385466678,1:2.4636911448071532,2:3.052524727720007,3:0.16486966970402214,4:0.16480837174792065,5:0.16214108661407217,6:0.020029220465472203,7:0.002963419033708272,8:0.0020539196291761135,9:0.0013423909296310884}
7 => {0:0.9219332128821778,1:1.8821030811924497,2:-0.7199893511464792,3:0.41050988277699674,4:0.11892395058574491,5:-0.04224315734275653,6:-0.0633275264470881,7:0.005529076824967711,8:-0.009772183415388151,9:0.0013446416028830295}
8 => {0:-14.145818737538741,1:-1.1699969480728294,2:-0.40554521480483047,3:0.1976956942046447,4:0.06537963940467842,5:-0.01894089363231766,6:0.010931966226267275,7:0.00593724191726731,8:0.0023812421864912734,9:7.875535718017027E-4}
9 => {0:5.844317557785366,1:-4.916841499316033,2:3.223470334519887,3:0.038760720083132125,4:0.0939461395911826,5:-0.049637825744005847,6:0.025390881376977658,7:0.004472511975435314,8:-0.009071253447319405,9:9.358686242487825E-4}
... }
pcaControl:
{
0 => {0:2.0909187314835473,1:2.0121557867643767,2:-0.597849142573616,3:-0.36018395178354085,4:0.4301796656381306,5:-8.048004266410234E-4,6:0.008205552854618986,7:-0.007107340442498095,8:-0.002762618526126809,9:6.443143813706793E-4}
1 => {0:2.266047100111712,1:1.5285588523711118,2:-0.6135837033417864,3:-0.3574403142647051,4:-0.17478119958032384,5:-0.1588534634829475,6:0.020306966364173624,7:-0.0041786103324904355,8:-0.0018917557213346142,9:8.813214323054718E-4}
2 => {0:-14.592387597456128,1:-0.5836079631543104,2:-0.5989625927098118,3:-0.3347183503792681,4:-0.1476661678934028,5:0.046558699780707154,6:0.003236856382683882,7:-0.0032368403871433043,8:-8.746452449047834E-4,9:-0.0027497720319186866}
3 => {0:0.4284698116779148,1:2.1713624397963867,2:-0.5872570456802904,3:-0.3755253404900546,4:-0.09393716167302114,5:0.02872528110545159,6:0.021765318228849057,7:-0.002883731544123946,8:-0.0018882651059701813,9:-0.0028113401660610363}
4 => {0:2.076496776666685,1:3.524106681577826,2:3.0320624205534576,3:-0.2144595689805403,4:-0.12992475941961096,5:0.05148555183557413,6:0.023486054707418217,7:-0.004082100307487471,8:-8.164943767598199E-4,9:0.0012620449423510214}
5 => {0:-14.153628531635276,1:-1.2092406581048991,2:-0.533866189831533,3:-0.19088331124196403,4:-0.0786911346598924,5:0.01990446520306995,6:0.011131407594543848,7:0.023768929349666543,8:0.007952788393472247,9:8.712986623166462E-4}
6 => {0:1.958895542525016,1:2.463691152528346,2:3.0525247032241922,3:-0.16486974214701594,4:-0.16480837246800953,5:-0.16214110981599844,6:0.020029135145301413,7:-0.0029633666015461547,8:-0.002053817791555493,9:0.001342389206394915}
7 => {0:0.9219332012022166,1:1.8821030743958143,2:-0.7199893242805223,3:-0.4105098860961941,4:-0.11892399030638225,5:0.04224322321405938,6:-0.06332755567385973,7:-0.0055290561457208695,8:0.00977219438725887,9:0.0013448071029162514}
8 => {0:-14.145818737290206,1:-1.1699969497186093,2:-0.4055452071020734,3:-0.19769567343974745,4:-0.06537963764260095,5:0.01894089709026742,6:0.01093199314522763,7:-0.005937260047367135,8:-0.0023812805079388797,9:7.875470393318356E-4}
9 => {0:5.8443175626254025,1:-4.916841491024554,2:3.2234703036295165,3:-0.03876080042696709,4:-0.09394612950285214,5:0.04963778340175989,6:0.025390784437323847,7:-0.004472459688514453,8:0.009071381314498974,9:9.358398515440079E-4}
... }
[32m- dspca[0m
spectrum:{0:300.0,1:110.3638323514327,2:40.60058497098381,3:14.936120510359183,4:5.494691666620254,5:2.02138409972564,6:0.7436256529999076,7:0.2735645896663549,8:0.10063878837075356,9:0.037022941226003865,10:0.013619978928745457,11:0.005010510237073698,12:0.001843263705998463,13:0.001,14:0.001,15:0.001,16:0.001,17:0.001,18:0.001,19:0.001,20:0.001,21:0.001,22:0.001,23:0.001,24:0.001,25:0.001,26:0.001,27:0.001,28:0.001,29:0.001,30:0.001,31:0.001,32:0.001,33:0.001,34:0.001,35:0.001,36:0.001,37:0.001,38:0.001,39:0.001}
04/20/2016 18:15:42 Job execution switched to status RUNNING.
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to RUNNING
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000766600000, 509607936, 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 509607936 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_pid19890.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 [ 16.086 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.393 s]
[INFO] Mahout Math ........................................ SUCCESS [01:11 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 11.191 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [11:41 min]
[INFO] Mahout Integration ................................. SUCCESS [ 50.200 s]
[INFO] Mahout Examples .................................... SUCCESS [ 20.327 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [03:52 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:19 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [01:58 min]
[INFO] Mahout Flink bindings .............................. FAILURE [01:35 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 25:21 min
[INFO] Finished at: 2016-04-20T18:15:45+00:00
[INFO] Final Memory: 70M/441M
[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 170.96 MB of artifacts by 87.6% relative to #3340
Recording test results
Publishing Javadoc
Fw: Build failed in Jenkins: Mahout-Quality #3341
Posted by Andrew Palumbo <ap...@outlook.com>.
I have not seen this before. dspca failure in flink-bindings on Jenkins:
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000766600000, 509607936, 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 509607936 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_pid19890.log>
________________________________________
From: Apache Jenkins Server <je...@builds.apache.org>
Sent: Wednesday, April 20, 2016 2:16 PM
To: dev@mahout.apache.org
Subject: Build failed in Jenkins: Mahout-Quality #3341
See <https://builds.apache.org/job/Mahout-Quality/3341/changes>
Changes:
[apalumbo] (nojira) travis: test math, hdfs, math-scala, spark only closes
{...}
(10,500)
pca:
{
0 => {0:2.090918733320634,1:2.012155789567859,2:-0.5978491551725623,3:0.3601839657907424,4:-0.4301796837135925,5:8.048373757734629E-4,6:0.008205552842679547,7:0.007107341025588364,8:0.00276261596161221,9:6.442554776006112E-4}
1 => {0:2.26604710233042,1:1.5285588530043563,2:-0.6135836929116393,3:0.3574403111361557,4:0.17478122499523338,5:0.15885341692040383,6:0.020306946838239377,7:0.004178602043814824,8:0.0018917370302710189,9:8.813987460367163E-4}
2 => {0:-14.592387596170045,1:-0.5836079619469777,2:-0.5989625958235241,3:0.3347183486023803,4:0.14766616006290462,5:-0.04655868461454374,6:0.0032368725845666486,7:0.003236847854859773,8:8.746686080017876E-4,9:-0.002749798090505071}
3 => {0:0.4284698281342152,1:2.171362446954195,2:-0.5872570690150916,3:0.3755253101985208,4:0.09393710522987284,5:-0.028725193357645725,6:0.02176539847903521,7:0.002883789121169779,8:0.0018883531853325722,9:-0.002811554681709644}
4 => {0:2.0764967782898682,1:3.5241066878884464,2:3.032062416077111,3:0.21445960781921905,4:0.1299247731515557,5:-0.05148555993781586,6:0.02348600827389116,7:0.004082065834064533,8:8.164485869492091E-4,9:0.0012621032347288708}
5 => {0:-14.153628534487789,1:-1.2092406591978648,2:-0.533866174430262,3:0.19088326279807227,4:0.07869112681485578,5:-0.01990446550191406,6:0.011131477999119734,7:-0.02376889432694065,8:-0.007952711446421788,9:8.712923434610288E-4}
6 => {0:1.9588955385466678,1:2.4636911448071532,2:3.052524727720007,3:0.16486966970402214,4:0.16480837174792065,5:0.16214108661407217,6:0.020029220465472203,7:0.002963419033708272,8:0.0020539196291761135,9:0.0013423909296310884}
7 => {0:0.9219332128821778,1:1.8821030811924497,2:-0.7199893511464792,3:0.41050988277699674,4:0.11892395058574491,5:-0.04224315734275653,6:-0.0633275264470881,7:0.005529076824967711,8:-0.009772183415388151,9:0.0013446416028830295}
8 => {0:-14.145818737538741,1:-1.1699969480728294,2:-0.40554521480483047,3:0.1976956942046447,4:0.06537963940467842,5:-0.01894089363231766,6:0.010931966226267275,7:0.00593724191726731,8:0.0023812421864912734,9:7.875535718017027E-4}
9 => {0:5.844317557785366,1:-4.916841499316033,2:3.223470334519887,3:0.038760720083132125,4:0.0939461395911826,5:-0.049637825744005847,6:0.025390881376977658,7:0.004472511975435314,8:-0.009071253447319405,9:9.358686242487825E-4}
... }
pcaControl:
{
0 => {0:2.0909187314835473,1:2.0121557867643767,2:-0.597849142573616,3:-0.36018395178354085,4:0.4301796656381306,5:-8.048004266410234E-4,6:0.008205552854618986,7:-0.007107340442498095,8:-0.002762618526126809,9:6.443143813706793E-4}
1 => {0:2.266047100111712,1:1.5285588523711118,2:-0.6135837033417864,3:-0.3574403142647051,4:-0.17478119958032384,5:-0.1588534634829475,6:0.020306966364173624,7:-0.0041786103324904355,8:-0.0018917557213346142,9:8.813214323054718E-4}
2 => {0:-14.592387597456128,1:-0.5836079631543104,2:-0.5989625927098118,3:-0.3347183503792681,4:-0.1476661678934028,5:0.046558699780707154,6:0.003236856382683882,7:-0.0032368403871433043,8:-8.746452449047834E-4,9:-0.0027497720319186866}
3 => {0:0.4284698116779148,1:2.1713624397963867,2:-0.5872570456802904,3:-0.3755253404900546,4:-0.09393716167302114,5:0.02872528110545159,6:0.021765318228849057,7:-0.002883731544123946,8:-0.0018882651059701813,9:-0.0028113401660610363}
4 => {0:2.076496776666685,1:3.524106681577826,2:3.0320624205534576,3:-0.2144595689805403,4:-0.12992475941961096,5:0.05148555183557413,6:0.023486054707418217,7:-0.004082100307487471,8:-8.164943767598199E-4,9:0.0012620449423510214}
5 => {0:-14.153628531635276,1:-1.2092406581048991,2:-0.533866189831533,3:-0.19088331124196403,4:-0.0786911346598924,5:0.01990446520306995,6:0.011131407594543848,7:0.023768929349666543,8:0.007952788393472247,9:8.712986623166462E-4}
6 => {0:1.958895542525016,1:2.463691152528346,2:3.0525247032241922,3:-0.16486974214701594,4:-0.16480837246800953,5:-0.16214110981599844,6:0.020029135145301413,7:-0.0029633666015461547,8:-0.002053817791555493,9:0.001342389206394915}
7 => {0:0.9219332012022166,1:1.8821030743958143,2:-0.7199893242805223,3:-0.4105098860961941,4:-0.11892399030638225,5:0.04224322321405938,6:-0.06332755567385973,7:-0.0055290561457208695,8:0.00977219438725887,9:0.0013448071029162514}
8 => {0:-14.145818737290206,1:-1.1699969497186093,2:-0.4055452071020734,3:-0.19769567343974745,4:-0.06537963764260095,5:0.01894089709026742,6:0.01093199314522763,7:-0.005937260047367135,8:-0.0023812805079388797,9:7.875470393318356E-4}
9 => {0:5.8443175626254025,1:-4.916841491024554,2:3.2234703036295165,3:-0.03876080042696709,4:-0.09394612950285214,5:0.04963778340175989,6:0.025390784437323847,7:-0.004472459688514453,8:0.009071381314498974,9:9.358398515440079E-4}
... }
[32m- dspca[0m
spectrum:{0:300.0,1:110.3638323514327,2:40.60058497098381,3:14.936120510359183,4:5.494691666620254,5:2.02138409972564,6:0.7436256529999076,7:0.2735645896663549,8:0.10063878837075356,9:0.037022941226003865,10:0.013619978928745457,11:0.005010510237073698,12:0.001843263705998463,13:0.001,14:0.001,15:0.001,16:0.001,17:0.001,18:0.001,19:0.001,20:0.001,21:0.001,22:0.001,23:0.001,24:0.001,25:0.001,26:0.001,27:0.001,28:0.001,29:0.001,30:0.001,31:0.001,32:0.001,33:0.001,34:0.001,35:0.001,36:0.001,37:0.001,38:0.001,39:0.001}
04/20/2016 18:15:42 Job execution switched to status RUNNING.
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/20/2016 18:15:42 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/20/2016 18:15:44 RangePartition: LocalSample(1/1) switched to RUNNING
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000766600000, 509607936, 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 509607936 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_pid19890.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 [ 16.086 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.393 s]
[INFO] Mahout Math ........................................ SUCCESS [01:11 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 11.191 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [11:41 min]
[INFO] Mahout Integration ................................. SUCCESS [ 50.200 s]
[INFO] Mahout Examples .................................... SUCCESS [ 20.327 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [03:52 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:19 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [01:58 min]
[INFO] Mahout Flink bindings .............................. FAILURE [01:35 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 25:21 min
[INFO] Finished at: 2016-04-20T18:15:45+00:00
[INFO] Final Memory: 70M/441M
[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 170.96 MB of artifacts by 87.6% relative to #3340
Recording test results
Publishing Javadoc