Apache Jenkins Server
2016-04-29 22:34:02 UTC
See <https://builds.apache.org/job/Mahout-Quality/3347/changes>
Changes:
[apalumbo] MAHOUT-1838: Simple 2d plotting of a sampled DRM closes apache/mahout
------------------------------------------
[...truncated 87851 lines...]
04/29/2016 22:33:07 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/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@67fd69bf)(1/1) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@67fd69bf)(1/1) switched to FINISHED
04/29/2016 22:33:07 Job execution switched to status FINISHED.
(40,40)
04/29/2016 22:33:07 Job execution switched to status RUNNING.
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to SCHEDULED
04/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to DEPLOYING
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to SCHEDULED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to SCHEDULED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to DEPLOYING
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to SCHEDULED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to RUNNING
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to RUNNING
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to FINISHED
04/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to FINISHED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to FINISHED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to FINISHED
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(1/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (***@45a3159e)(1/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(1/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (***@45a3159e)(3/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (***@45a3159e)(3/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(3/4) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(2/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (***@45a3159e)(2/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (***@45a3159e)(4/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (***@45a3159e)(4/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (***@45a3159e)(1/4) switched to FINISHED
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(3/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (***@45a3159e)(2/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (***@45a3159e)(4/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (***@45a3159e)(2/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (***@45a3159e)(4/4) switched to FINISHED
04/29/2016 22:33:07 Job execution switched to status FINISHED.
04/29/2016 22:33:07 Job execution switched to status RUNNING.
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(1/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(1/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(1/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(2/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(2/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(1/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(2/4) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(3/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(3/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(2/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(3/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(3/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(4/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(4/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(4/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(4/4) switched to FINISHED
04/29/2016 22:33:07 Job execution switched to status FINISHED.
04/29/2016 22:33:07 Job execution switched to status RUNNING.
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
04/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
04/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@3a687daf)(1/1) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@3a687daf)(1/1) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@3a687daf)(1/1) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@3a687daf)(1/1) switched to FINISHED
04/29/2016 22:33:07 Job execution switched to status FINISHED.
(10,500)
pca:
{
0 => {0:1.7816869476014652,1:1.3451729011111981,2:0.558855117476603,3:0.4011699584423243,4:0.10698370503797276,5:-0.18617304491173164,6:0.010463387259494998,7:0.004258574199839061,8:-6.54609495603731E-4,9:-3.900102472457472E-4}
1 => {0:1.1544722178865707,1:2.161304920879497,2:1.0997130934561168,3:0.17107621041336424,4:0.10158521298090481,5:0.028484729943775475,6:0.020349348619703705,7:0.006001332797913958,8:-0.0013401914323885294,9:-4.566144017002148E-4}
2 => {0:2.6662783664810954,1:2.4502330612646834,2:0.6399113083059575,3:0.28664381325761207,4:0.10956240402888949,5:0.03953205109237298,6:0.01002304972261898,7:0.00484892299126534,8:-0.0026520704948935804,9:-9.017684208251612E-4}
3 => {0:2.755604223909896,1:2.658820624282611,2:0.6827450841623344,3:0.19642161187712445,4:0.16109942088685947,5:0.015971116215194734,6:0.016022906140754727,7:0.0047454831874864396,8:-0.0019457175380042755,9:-6.027189089773281E-4}
4 => {0:-14.912309674357228,1:0.3275136819517519,2:0.7016201941833893,3:0.36591852536847885,4:0.0892248288627562,5:-0.18271537192182788,6:0.0055419262856074925,7:0.0075220055569203016,8:0.010253453108466936,9:-0.0014138794425063717}
5 => {0:-14.36696362140451,1:1.0772556587761413,2:-2.7249498345103533,3:-1.076381481262328,4:-0.4084695592906003,5:0.044725635056259906,6:0.01611696783633468,7:0.006590091397334821,8:-0.002129771589883034,9:-7.696913562057545E-4}
6 => {0:2.741343668104479,1:2.3967076781181786,2:0.9593004888175339,3:0.32873608846167085,4:-0.42632362330775686,5:0.02740134050979198,6:0.012370296149898766,7:0.0033084005150073553,8:-0.0014260141189209766,9:-0.001327904323877042}
7 => {0:2.472150291498864,1:1.9031340456188326,2:0.7424493131686203,3:0.21887139583790188,4:0.08732593069742241,5:0.0427236511164542,6:-0.060424315585860096,7:0.007169730405893507,8:-0.002747370308237456,9:-0.0011076836873486545}
8 => {0:1.656339923257641,1:1.668731049383505,2:0.8978102135663696,3:0.3664160097668585,4:0.12884110849870742,5:0.023241036953681116,6:0.009426137343337769,7:0.006014273493251437,8:-0.0024347958612810305,9:-0.0011169252756534239}
9 => {0:5.967403116462152,1:-5.241186054588428,2:-3.0463053222408494,3:0.13714043337596052,4:0.14663696787806613,5:0.018235140564396665,6:0.01731076716969202,7:0.00948203013490813,8:0.007573212817656264,9:0.003228271293277352}
... }
pcaControl:
{
0 => {0:-1.781686946123938,1:1.3451729010205828,2:-0.5588551167017591,3:0.4011699610107793,4:0.10698370523059254,5:-0.18617304371618906,6:-0.01046338586589941,7:-0.004258572846157989,8:6.546067274434896E-4,9:3.9001700100116843E-4}
1 => {0:-1.154472221711959,1:2.161304921938093,2:-1.0997130841845308,3:0.1710762384402199,4:0.10158522862436108,5:0.02848474715358524,6:-0.020349333515637395,7:-0.006001322930605977,8:0.0013401941855177954,9:4.5664225491257943E-4}
2 => {0:-2.6662783674915533,1:2.4502330616914825,2:-0.6399113061191263,3:0.28664381335632844,4:0.10956240863139939,5:0.039532051510350955,6:-0.010023048241172349,7:-0.004848922932011094,8:0.002652077132776839,9:9.017580492217967E-4}
3 => {0:-2.7556042266547545,1:2.658820629340614,2:-0.6827450741952306,3:0.19642163884563457,4:0.1610994254851564,5:0.01597112232033237,6:-0.016022886833169322,7:-0.004745467518017239,8:0.0019457218081979102,9:6.02748920867883E-4}
4 => {0:14.912309678661586,1:0.327513685276011,2:-0.7016201975863119,3:0.36591851766035366,4:0.08922481786731234,5:-0.1827153813097995,6:-0.005541929540576737,7:-0.007522005412983008,8:-0.0102534575549424,9:0.001413878804479069}
5 => {0:14.366963621041613,1:1.077255658437839,2:2.7249498358380717,3:-1.0763814782982841,4:-0.4084695569999717,5:0.04472563719429491,6:-0.01611696584698191,7:-0.006590090477172091,8:0.002129771928234864,9:7.696950030369802E-4}
6 => {0:-2.7413436679982164,1:2.396707675838144,2:-0.9593004910071444,3:0.3287360894649531,4:-0.4263236203146207,5:0.027401346500816107,6:-0.012370300138760008,7:-0.003308403929803605,8:0.0014260069927127294,9:0.0013279127447271312}
7 => {0:-2.4721502926484433,1:1.9031340457956964,2:-0.7424493141913913,3:0.21887139227187724,4:0.08732592831327693,5:0.042723648265497835,6:0.06042431454359323,7:-0.00716973113443063,8:0.002747371782398714,9:0.0011076786077657403}
8 => {0:-1.656339927515574,1:1.6687310503502137,2:-0.8978102065531673,3:0.3664160282072632,4:0.12884112122548086,5:0.023241048432359045,6:-0.00942612694474336,7:-0.0060142670698473,8:0.0024348020869661173,9:0.0011169368679210118}
9 => {0:-5.9674031122362825,1:-5.241186057082707,2:3.046305309924219,3:0.13714040032876562,4:0.14663695184222036,5:0.018235124446240297,6:-0.0173107877617487,7:-0.009482043592958494,8:-0.007573220108689888,9:-0.0032283039255871886}
... }
[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/29/2016 22:33:11 Job execution switched to status RUNNING.
04/29/2016 22:33:11 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/29/2016 22:33:11 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/29/2016 22:33:11 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/29/2016 22:33:13 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/29/2016 22:33:13 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/29/2016 22:33:13 RangePartition: LocalSample(1/1) switched to RUNNING
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x000000076f500000, 414187520, 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 414187520 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_pid9262.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.315 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.229 s]
[INFO] Mahout Math ........................................ SUCCESS [01:17 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 8.555 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:09 min]
[INFO] Mahout Integration ................................. SUCCESS [ 54.899 s]
[INFO] Mahout Examples .................................... SUCCESS [ 22.345 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:19 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:24 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:24 min]
[INFO] Mahout Flink bindings .............................. FAILURE [01:45 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 26:54 min
[INFO] Finished at: 2016-04-29T22:33:14+00:00
[INFO] Final Memory: 70M/438M
[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.73 MB of artifacts by 85.5% relative to #3346
Recording test results
Publishing Javadoc
Updating MAHOUT-1838
Changes:
[apalumbo] MAHOUT-1838: Simple 2d plotting of a sampled DRM closes apache/mahout
------------------------------------------
[...truncated 87851 lines...]
04/29/2016 22:33:07 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/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@67fd69bf)(1/1) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@67fd69bf)(1/1) switched to FINISHED
04/29/2016 22:33:07 Job execution switched to status FINISHED.
(40,40)
04/29/2016 22:33:07 Job execution switched to status RUNNING.
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to SCHEDULED
04/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to DEPLOYING
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to SCHEDULED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to SCHEDULED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to DEPLOYING
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to SCHEDULED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to RUNNING
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to RUNNING
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(1/4) switched to FINISHED
04/29/2016 22:33:07 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/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(3/4) switched to FINISHED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(2/4) switched to FINISHED
04/29/2016 22:33:07 MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52))(4/4) switched to FINISHED
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(1/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (***@45a3159e)(1/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(1/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (***@45a3159e)(3/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (***@45a3159e)(3/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(3/4) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(2/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (***@45a3159e)(2/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (***@45a3159e)(4/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (***@45a3159e)(4/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (***@45a3159e)(1/4) switched to FINISHED
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (***@45a3159e)(3/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (***@45a3159e)(2/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (***@45a3159e)(4/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (***@45a3159e)(2/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (***@45a3159e)(4/4) switched to FINISHED
04/29/2016 22:33:07 Job execution switched to status FINISHED.
04/29/2016 22:33:07 Job execution switched to status RUNNING.
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(1/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(1/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(1/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(2/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(2/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(1/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(2/4) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(3/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(3/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(2/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(3/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(3/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(4/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(4/4) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(4/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@192c357a)(4/4) switched to FINISHED
04/29/2016 22:33:07 Job execution switched to status FINISHED.
04/29/2016 22:33:07 Job execution switched to status RUNNING.
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
04/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
04/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
04/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 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/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@3a687daf)(1/1) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@3a687daf)(1/1) switched to DEPLOYING
04/29/2016 22:33:07 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/29/2016 22:33:07 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@3a687daf)(1/1) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$***@3a687daf)(1/1) switched to FINISHED
04/29/2016 22:33:07 Job execution switched to status FINISHED.
(10,500)
pca:
{
0 => {0:1.7816869476014652,1:1.3451729011111981,2:0.558855117476603,3:0.4011699584423243,4:0.10698370503797276,5:-0.18617304491173164,6:0.010463387259494998,7:0.004258574199839061,8:-6.54609495603731E-4,9:-3.900102472457472E-4}
1 => {0:1.1544722178865707,1:2.161304920879497,2:1.0997130934561168,3:0.17107621041336424,4:0.10158521298090481,5:0.028484729943775475,6:0.020349348619703705,7:0.006001332797913958,8:-0.0013401914323885294,9:-4.566144017002148E-4}
2 => {0:2.6662783664810954,1:2.4502330612646834,2:0.6399113083059575,3:0.28664381325761207,4:0.10956240402888949,5:0.03953205109237298,6:0.01002304972261898,7:0.00484892299126534,8:-0.0026520704948935804,9:-9.017684208251612E-4}
3 => {0:2.755604223909896,1:2.658820624282611,2:0.6827450841623344,3:0.19642161187712445,4:0.16109942088685947,5:0.015971116215194734,6:0.016022906140754727,7:0.0047454831874864396,8:-0.0019457175380042755,9:-6.027189089773281E-4}
4 => {0:-14.912309674357228,1:0.3275136819517519,2:0.7016201941833893,3:0.36591852536847885,4:0.0892248288627562,5:-0.18271537192182788,6:0.0055419262856074925,7:0.0075220055569203016,8:0.010253453108466936,9:-0.0014138794425063717}
5 => {0:-14.36696362140451,1:1.0772556587761413,2:-2.7249498345103533,3:-1.076381481262328,4:-0.4084695592906003,5:0.044725635056259906,6:0.01611696783633468,7:0.006590091397334821,8:-0.002129771589883034,9:-7.696913562057545E-4}
6 => {0:2.741343668104479,1:2.3967076781181786,2:0.9593004888175339,3:0.32873608846167085,4:-0.42632362330775686,5:0.02740134050979198,6:0.012370296149898766,7:0.0033084005150073553,8:-0.0014260141189209766,9:-0.001327904323877042}
7 => {0:2.472150291498864,1:1.9031340456188326,2:0.7424493131686203,3:0.21887139583790188,4:0.08732593069742241,5:0.0427236511164542,6:-0.060424315585860096,7:0.007169730405893507,8:-0.002747370308237456,9:-0.0011076836873486545}
8 => {0:1.656339923257641,1:1.668731049383505,2:0.8978102135663696,3:0.3664160097668585,4:0.12884110849870742,5:0.023241036953681116,6:0.009426137343337769,7:0.006014273493251437,8:-0.0024347958612810305,9:-0.0011169252756534239}
9 => {0:5.967403116462152,1:-5.241186054588428,2:-3.0463053222408494,3:0.13714043337596052,4:0.14663696787806613,5:0.018235140564396665,6:0.01731076716969202,7:0.00948203013490813,8:0.007573212817656264,9:0.003228271293277352}
... }
pcaControl:
{
0 => {0:-1.781686946123938,1:1.3451729010205828,2:-0.5588551167017591,3:0.4011699610107793,4:0.10698370523059254,5:-0.18617304371618906,6:-0.01046338586589941,7:-0.004258572846157989,8:6.546067274434896E-4,9:3.9001700100116843E-4}
1 => {0:-1.154472221711959,1:2.161304921938093,2:-1.0997130841845308,3:0.1710762384402199,4:0.10158522862436108,5:0.02848474715358524,6:-0.020349333515637395,7:-0.006001322930605977,8:0.0013401941855177954,9:4.5664225491257943E-4}
2 => {0:-2.6662783674915533,1:2.4502330616914825,2:-0.6399113061191263,3:0.28664381335632844,4:0.10956240863139939,5:0.039532051510350955,6:-0.010023048241172349,7:-0.004848922932011094,8:0.002652077132776839,9:9.017580492217967E-4}
3 => {0:-2.7556042266547545,1:2.658820629340614,2:-0.6827450741952306,3:0.19642163884563457,4:0.1610994254851564,5:0.01597112232033237,6:-0.016022886833169322,7:-0.004745467518017239,8:0.0019457218081979102,9:6.02748920867883E-4}
4 => {0:14.912309678661586,1:0.327513685276011,2:-0.7016201975863119,3:0.36591851766035366,4:0.08922481786731234,5:-0.1827153813097995,6:-0.005541929540576737,7:-0.007522005412983008,8:-0.0102534575549424,9:0.001413878804479069}
5 => {0:14.366963621041613,1:1.077255658437839,2:2.7249498358380717,3:-1.0763814782982841,4:-0.4084695569999717,5:0.04472563719429491,6:-0.01611696584698191,7:-0.006590090477172091,8:0.002129771928234864,9:7.696950030369802E-4}
6 => {0:-2.7413436679982164,1:2.396707675838144,2:-0.9593004910071444,3:0.3287360894649531,4:-0.4263236203146207,5:0.027401346500816107,6:-0.012370300138760008,7:-0.003308403929803605,8:0.0014260069927127294,9:0.0013279127447271312}
7 => {0:-2.4721502926484433,1:1.9031340457956964,2:-0.7424493141913913,3:0.21887139227187724,4:0.08732592831327693,5:0.042723648265497835,6:0.06042431454359323,7:-0.00716973113443063,8:0.002747371782398714,9:0.0011076786077657403}
8 => {0:-1.656339927515574,1:1.6687310503502137,2:-0.8978102065531673,3:0.3664160282072632,4:0.12884112122548086,5:0.023241048432359045,6:-0.00942612694474336,7:-0.0060142670698473,8:0.0024348020869661173,9:0.0011169368679210118}
9 => {0:-5.9674031122362825,1:-5.241186057082707,2:3.046305309924219,3:0.13714040032876562,4:0.14663695184222036,5:0.018235124446240297,6:-0.0173107877617487,7:-0.009482043592958494,8:-0.007573220108689888,9:-0.0032283039255871886}
... }
[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/29/2016 22:33:11 Job execution switched to status RUNNING.
04/29/2016 22:33:11 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
04/29/2016 22:33:11 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
04/29/2016 22:33:11 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
04/29/2016 22:33:13 RangePartition: LocalSample(1/1) switched to SCHEDULED
04/29/2016 22:33:13 RangePartition: LocalSample(1/1) switched to DEPLOYING
04/29/2016 22:33:13 RangePartition: LocalSample(1/1) switched to RUNNING
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x000000076f500000, 414187520, 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 414187520 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_pid9262.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.315 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.229 s]
[INFO] Mahout Math ........................................ SUCCESS [01:17 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 8.555 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:09 min]
[INFO] Mahout Integration ................................. SUCCESS [ 54.899 s]
[INFO] Mahout Examples .................................... SUCCESS [ 22.345 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:19 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:24 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:24 min]
[INFO] Mahout Flink bindings .............................. FAILURE [01:45 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 26:54 min
[INFO] Finished at: 2016-04-29T22:33:14+00:00
[INFO] Final Memory: 70M/438M
[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.73 MB of artifacts by 85.5% relative to #3346
Recording test results
Publishing Javadoc
Updating MAHOUT-1838