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/05/03 01:22:31 UTC
Build failed in Jenkins: Mahout-Quality #3352
See <https://builds.apache.org/job/Mahout-Quality/3352/changes>
Changes:
[smarthi] MAHOUT-1847: drmSampleRows in FlinkEngine doesn't wrap Int Keys when
------------------------------------------
[...truncated 93171 lines...]
05/02/2016 23:21:14 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1ca2865b)(1/1) switched to DEPLOYING
05/02/2016 23:21:14 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/4) switched to FINISHED
05/02/2016 23:21:14 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
05/02/2016 23:21:14 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1ca2865b)(1/1) switched to RUNNING
05/02/2016 23:21:14 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1ca2865b)(1/1) switched to FINISHED
05/02/2016 23:21:14 Job execution switched to status FINISHED.
(40,40)
05/02/2016 23:21:15 Job execution switched to status RUNNING.
05/02/2016 23:21:15 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to FINISHED
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to SCHEDULED
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to DEPLOYING
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to SCHEDULED
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to DEPLOYING
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to SCHEDULED
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to DEPLOYING
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to SCHEDULED
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to DEPLOYING
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to RUNNING
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to RUNNING
05/02/2016 23:21:15 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
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to FINISHED
05/02/2016 23:21:15 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to FINISHED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to FINISHED
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to FINISHED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to FINISHED
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to FINISHED
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to FINISHED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to FINISHED
05/02/2016 23:21:15 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to FINISHED
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(4/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(4/4) switched to DEPLOYING
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(3/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(3/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(4/4) switched to RUNNING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(1/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(1/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(2/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(2/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(3/4) switched to RUNNING
05/02/2016 23:21:15 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
05/02/2016 23:21:15 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
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(1/4) switched to RUNNING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(2/4) switched to RUNNING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(4/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(2/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(1/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@49f904bd)(3/4) switched to FINISHED
05/02/2016 23:21:15 Job execution switched to status FINISHED.
05/02/2016 23:21:15 Job execution switched to status RUNNING.
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to RUNNING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(1/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(1/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(2/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(2/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(3/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(3/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(1/4) switched to RUNNING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(2/4) switched to RUNNING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(3/4) switched to RUNNING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(2/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(1/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(3/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(4/4) switched to SCHEDULED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(4/4) switched to DEPLOYING
05/02/2016 23:21:15 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(4/4) switched to RUNNING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@41d2ad73)(4/4) switched to FINISHED
05/02/2016 23:21:15 Job execution switched to status FINISHED.
05/02/2016 23:21:15 Job execution switched to status RUNNING.
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/4) switched to SCHEDULED
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/4) switched to DEPLOYING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/4) switched to SCHEDULED
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/4) switched to DEPLOYING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/4) switched to SCHEDULED
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/4) switched to DEPLOYING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/4) switched to SCHEDULED
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/4) switched to DEPLOYING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/4) switched to RUNNING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/4) switched to RUNNING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/4) switched to RUNNING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/4) switched to RUNNING
05/02/2016 23:21:15 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
05/02/2016 23:21:15 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/4) switched to FINISHED
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/4) switched to FINISHED
05/02/2016 23:21:15 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/4) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1ea3df12)(1/1) switched to SCHEDULED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1ea3df12)(1/1) switched to DEPLOYING
05/02/2016 23:21:15 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/4) switched to FINISHED
05/02/2016 23:21:15 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1ea3df12)(1/1) switched to RUNNING
05/02/2016 23:21:15 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1ea3df12)(1/1) switched to FINISHED
05/02/2016 23:21:15 Job execution switched to status FINISHED.
(10,500)
pca:
{
0 => {0:3.9767727435958595,1:-2.657820858290339,2:2.697638893690178,3:0.04671322196669011,4:0.21223262541488389,5:0.019675314686686117,6:-0.013614816081465746,7:0.007626540412733843,8:-0.0016973406786142072,9:8.987537244885442E-4}
1 => {0:1.9652518877934158,1:-2.088364369991752,2:-0.8888173058554061,3:0.38448827436253663,4:0.11053314833842137,5:-0.1945188507083274,6:-0.012163971740398107,7:0.006405904812051101,8:-0.002929909556327743,9:-0.0028154430161871813}
2 => {0:3.250798422166486,1:-2.9215182683003325,2:2.694229258132298,3:0.12677820369989934,4:0.16280487973299423,5:0.02477155359883353,6:-0.02607639597638435,7:0.0036823120384877387,8:-3.369851601428194E-6,9:0.0010501097909612243}
3 => {0:3.513947587914985,1:-1.5985888782999778,2:-0.6320182528059491,3:0.17897800080873136,4:0.14947304382943594,5:0.05012035135619984,6:0.05820724527482285,7:0.0066416001252529435,8:-0.0021845911741476985,9:4.653913207342715E-4}
4 => {0:-14.459638218754176,1:-0.8022637754078745,2:3.097560312019507,3:0.09735158891847197,4:0.13697333600596093,5:0.04746284577309585,6:-0.02420799186876631,7:0.0035863119091703666,8:-4.764509546859861E-4,9:9.620480746053877E-4}
5 => {0:-9.237510481469275,1:8.61978150752179,2:0.30332939991332764,3:0.21521041353189693,4:0.06535412985927706,5:-0.16840714963153136,6:-0.004189670565643452,7:-0.023056809361563544,8:-0.003971001667852224,9:-0.002881679993076967}
6 => {0:3.2868232103618924,1:-2.739162979967588,2:2.670410138735838,3:0.08021621764928832,4:-0.37215973635389454,5:0.03594816911616029,6:0.05514777615598893,7:0.002317386653591846,8:-5.566626646925876E-4,9:7.245235528235362E-4}
7 => {0:8.604380939330373,1:4.4163470621559595,2:3.247642054709904,3:0.024073694628895293,4:-0.40068388267699656,5:0.07210357577497825,6:0.05529605184086181,7:1.944181376510876E-4,8:-0.0021484704545169566,9:0.0010787187816546572}
8 => {0:5.666776340629605,1:6.171416093835941,2:-0.3083795934221407,3:0.30978581000286615,4:0.13381512612222451,5:0.054518094586030505,6:0.06003800539358894,7:0.0021940180902364575,8:0.00758342626708023,9:8.821641518485131E-4}
9 => {0:-14.288768222002705,1:1.044071911336531,2:-0.37780588675824817,3:0.17571896141086632,4:0.07738900986483736,5:0.05338238268034717,6:0.05885952580630839,7:0.0063510900458475265,8:-0.0017179251910036297,9:-0.0031922575942936915}
... }
pcaControl:
{
0 => {0:-3.9767727562338493,1:2.657820856028969,2:2.6976389118418576,3:-0.0467132130868074,4:-0.21223261641078472,5:-0.01967520296594072,6:-0.013614646232631566,7:0.007626235012172773,8:-0.0016976480148309476,9:-8.984243517411985E-4}
1 => {0:-1.9652518688099774,1:2.0883643825167804,2:-0.8888173336333277,3:-0.3844883083393288,4:-0.11053329304156292,5:0.1945181632373766,6:-0.012165133362044441,7:0.0064076800536892,8:-0.0029285829865811582,9:0.0028140750292509546}
2 => {0:-3.250798416323264,1:2.9215182748794857,2:2.6942292608681173,3:-0.1267782206511751,4:-0.16280500063514802,5:-0.024772002455160917,6:-0.026077185639949357,7:0.003683524838459309,8:-2.5464750850487762E-6,9:-0.0010509806521691641}
3 => {0:-3.5139476068467017,1:1.5985888723435366,2:-0.6320182172197477,3:-0.17897797749391595,4:-0.14947299018693685,5:-0.05011996536234631,6:0.05820786912769826,7:0.006640658514548306,8:-0.002185364306145567,9:-4.6461487212682797E-4}
4 => {0:14.459638220249401,1:0.8022637769126226,2:3.0975603256315427,3:-0.09735162648654849,4:-0.13697348246075922,5:-0.04746341648130443,6:-0.024209058968954714,7:0.0035879082365198197,8:-4.7549255481384406E-4,9:-9.631126422772214E-4}
5 => {0:9.237510478571506,1:-8.619781509212565,2:0.3033294076398875,3:-0.21521041033420002,4:-0.06535415166203074,5:0.1684070908528499,6:-0.004189803380666121,7:-0.023056567265277755,8:-0.003970900819384748,9:0.002881511689427356}
6 => {0:-3.2868232094567675,1:2.7391629808603435,2:2.6704101643765825,3:-0.080216205261109,4:0.37215965605550666,5:-0.03594832608244449,6:0.05514749752609486,7:0.0023177835115493328,8:-5.564119508158776E-4,9:-7.247441147368215E-4}
7 => {0:-8.604380931541158,1:-4.41634706014095,2:3.247642051252035,3:-0.02407369204057187,4:0.400683833440572,5:-0.0721037259633858,6:0.05529581133111028,7:1.9477996620096728E-4,8:-0.002148150565472328,9:-0.001079009543528437}
8 => {0:-5.6667763135799,1:-6.171416083645863,2:-0.3083796330127968,3:-0.3097858053402907,4:-0.13381519042550014,5:-0.05451845887239458,6:0.06003751817687028,7:0.0021947240356788842,8:0.007584172200730077,9:-8.827758887873833E-4}
9 => {0:14.288768214037336,1:-1.0440719156853484,2:-0.377805860470935,3:-0.17571893396348365,4:-0.07738901603317172,5:-0.0533822452671452,6:0.058859755695471166,7:0.006350721587780514,8:-0.001718228620566144,9:0.0031925923265273665}
... }
[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}
05/02/2016 23:21:18 Job execution switched to status RUNNING.
05/02/2016 23:21:18 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
05/02/2016 23:21:18 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
05/02/2016 23:21:18 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
05/02/2016 23:21:19 RangePartition: LocalSample(1/1) switched to SCHEDULED
05/02/2016 23:21:19 RangePartition: LocalSample(1/1) switched to DEPLOYING
05/02/2016 23:21:19 RangePartition: LocalSample(1/1) switched to RUNNING
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x0000000764600000, 665845760, 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 665845760 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_pid23755.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 [ 9.344 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.286 s]
[INFO] Mahout Math ........................................ SUCCESS [01:07 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 9.449 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [11:15 min]
[INFO] Mahout Integration ................................. SUCCESS [ 50.759 s]
[INFO] Mahout Examples .................................... SUCCESS [ 20.793 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [03:47 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:17 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:05 min]
[INFO] Mahout Flink bindings .............................. FAILURE [01:32 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 24:40 min
[INFO] Finished at: 2016-05-02T23:21:21+00:00
[INFO] Final Memory: 70M/488M
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.scalatest:scalatest-maven-plugin:1.0:test (test) on project mahout-flink_2.10: There are test failures -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]
[ERROR] For more information about the errors and possible solutions, please read the following articles:
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
[ERROR]
[ERROR] After correcting the problems, you can resume the build with the command
[ERROR] mvn <goals> -rf :mahout-flink_2.10
Build step 'Invoke top-level Maven targets' marked build as failure
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
Compressed 173.76 MB of artifacts by 89.0% relative to #3351
Recording test results
Publishing Javadoc
Updating MAHOUT-1847
Jenkins build is back to normal : Mahout-Quality #3354
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3354/changes>
Build failed in Jenkins: Mahout-Quality #3353
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3353/changes>
Changes:
[smarthi] NoJira: Fix Javadocs Warnings
------------------------------------------
[...truncated 112258 lines...]
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELING
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELING
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELING
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELING
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELING
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(1/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(2/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(3/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(4/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(5/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(6/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(7/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(8/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(9/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(10/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(11/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(12/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(13/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(14/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(15/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(16/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(17/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(18/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(19/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(20/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(21/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(22/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(23/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(24/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(5/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(6/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(7/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(8/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(9/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(10/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(11/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(12/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(13/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(14/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(15/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(16/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(17/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(18/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(19/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(20/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(21/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(22/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(23/24) switched to CANCELED
05/03/2016 00:05:47 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(24/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(1/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(2/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(3/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(4/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(5/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(6/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(7/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(8/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(9/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(10/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(11/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(12/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(13/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(14/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(15/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(16/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(17/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(18/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(19/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(20/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(21/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(22/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(23/24) switched to CANCELED
05/03/2016 00:05:47 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@6ce20a27)(24/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
05/03/2016 00:05:47 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
05/03/2016 00:05:47 Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
05/03/2016 00:05:47 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.pollAndExecAll(ForkJoinPool.java:1253)[0m
[31m at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)[0m
[31m ...[0m
[31m Cause: java.io.IOException: Insufficient number of network buffers: required 24, but only 8 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:327)[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, 49 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 [ 5.515 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.296 s]
[INFO] Mahout Math ........................................ SUCCESS [01:12 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 7.290 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:02 min]
[INFO] Mahout Integration ................................. SUCCESS [ 48.162 s]
[INFO] Mahout Examples .................................... SUCCESS [ 24.728 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:35 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:27 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [03:18 min]
[INFO] Mahout Flink bindings .............................. FAILURE [04:49 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 30:58 min
[INFO] Finished at: 2016-05-03T00:05:48+00:00
[INFO] Final Memory: 63M/480M
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.scalatest:scalatest-maven-plugin:1.0:test (test) on project mahout-flink_2.10: There are test failures -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]
[ERROR] For more information about the errors and possible solutions, please read the following articles:
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
[ERROR]
[ERROR] After correcting the problems, you can resume the build with the command
[ERROR] mvn <goals> -rf :mahout-flink_2.10
Build step 'Invoke top-level Maven targets' marked build as failure
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
Compressed 173.76 MB of artifacts by 89.0% relative to #3351
Recording test results
Publishing Javadoc