You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@mahout.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2016/04/30 00:34:02 UTC
Build failed in Jenkins: Mahout-Quality #3347
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$CollectHelper@67fd69bf)(1/1) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@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 (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(1/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@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 (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(1/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(3/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@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 (org.apache.flink.api.java.io.TypeSerializerOutputFormat@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 (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(2/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(2/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(4/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(4/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@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 (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(3/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(2/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(4/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@45a3159e)(2/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@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$CollectHelper@192c357a)(1/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@192c357a)(1/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@192c357a)(1/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@192c357a)(2/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@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$CollectHelper@192c357a)(1/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@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$CollectHelper@192c357a)(3/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@192c357a)(3/4) switched to DEPLOYING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@192c357a)(2/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@192c357a)(3/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@192c357a)(3/4) switched to FINISHED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@192c357a)(4/4) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@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$CollectHelper@192c357a)(4/4) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@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$CollectHelper@3a687daf)(1/1) switched to SCHEDULED
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@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$CollectHelper@3a687daf)(1/1) switched to RUNNING
04/29/2016 22:33:07 DataSink (org.apache.flink.api.java.Utils$CollectHelper@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
Jenkins build is back to normal : Mahout-Quality #3349
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3349/changes>
Build failed in Jenkins: Mahout-Quality #3348
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3348/changes>
Changes:
[smarthi] MAHOUT-1841: Matrices.symmetricUniformView(...) returning values in the
------------------------------------------
[...truncated 3212 lines...]
1 => {0:25.0,1:39.0}
}
{
0 => {0:11.0,1:17.0}
1 => {0:25.0,1:39.0}
}
Q=
{
0 => {0:0.40273861426601687,1:-0.9153150324187648}
1 => {0:0.9153150324227656,1:0.40273861426427493}
}
[32m- C = A %*% B mapBlock {}[0m
[32m- C = A %*% B incompatible B keys[0m
[32m- Spark-specific C = At %*% B , join[0m
[32m- C = At %*% B , join, String-keyed[0m
[32m- C = At %*% B , zippable, String-keyed[0m
[32m- C = A %*% B.t[0m
{
0 => {0:26.0,1:35.0,2:46.0,3:51.0}
1 => {0:50.0,1:69.0,2:92.0,3:105.0}
2 => {0:62.0,1:86.0,2:115.0,3:132.0}
3 => {0:74.0,1:103.0,2:138.0,3:159.0}
}
[32m- C = A %*% inCoreB[0m
{
0 => {0:26.0,1:35.0,2:46.0,3:51.0}
1 => {0:50.0,1:69.0,2:92.0,3:105.0}
2 => {0:62.0,1:86.0,2:115.0,3:132.0}
3 => {0:74.0,1:103.0,2:138.0,3:159.0}
}
[32m- C = inCoreA %*%: B[0m
58977 [ScalaTest-main-running-RLikeDrmOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
[32m- C = A.t %*% A[0m
[32m- C = A.t %*% A fat non-graph[0m
162595 [ScalaTest-main-running-RLikeDrmOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
[32m- C = A.t %*% A non-int key[0m
[32m- C = A + B[0m
A=
{
0 => {0:1.0,1:2.0,2:3.0}
1 => {0:3.0,1:4.0,2:5.0}
2 => {0:5.0,1:6.0,2:7.0}
}
B=
{
0 => {0:0.9853454767970793,1:0.523158918707643,2:0.7686363963425746}
1 => {0:0.7566230885246726,1:0.3760312521689527,2:0.25076380173255}
2 => {0:0.18446250691787902,1:0.5058988187226822,2:0.3310050825958947}
}
C=
{
0 => {0:1.9853454767970793,1:2.523158918707643,2:3.7686363963425746}
1 => {0:3.7566230885246727,1:4.376031252168953,2:5.25076380173255}
2 => {0:5.184462506917879,1:6.505898818722682,2:7.331005082595895}
}
[32m- C = A + B, identically partitioned[0m
[32m- C = A + B side test 1[0m
[32m- C = A + B side test 2[0m
[32m- C = A + B side test 3[0m
[32m- Ax[0m
[32m- A'x[0m
[32m- colSums, colMeans[0m
[32m- rowSums, rowMeans[0m
[32m- A.diagv[0m
[32m- numNonZeroElementsPerColumn[0m
[32m- C = A cbind B, cogroup[0m
[32m- C = A cbind B, zip[0m
[32m- B = 1 cbind A[0m
[32m- B = A cbind 1[0m
[32m- B = A + 1.0[0m
[32m- C = A rbind B[0m
[32m- C = A rbind B, with empty[0m
[32m- scalarOps[0m
optimized:OpAewUnaryFunc(org.apache.mahout.h2obindings.drm.CheckpointedDrmH2O@370ff791,<function1>,false)
[32m- A * A -> sqr(A) rewrite [0m
optimizer rewritten:OpAewUnaryFuncFusion(org.apache.mahout.h2obindings.drm.CheckpointedDrmH2O@ce6c64f,List(OpAewUnaryFunc(OpAewUnaryFunc(OpAewUnaryFunc(org.apache.mahout.h2obindings.drm.CheckpointedDrmH2O@ce6c64f,<function1>,false),<function1>,false),<function1>,true), OpAewUnaryFunc(OpAewUnaryFunc(org.apache.mahout.h2obindings.drm.CheckpointedDrmH2O@ce6c64f,<function1>,false),<function1>,false), OpAewUnaryFunc(org.apache.mahout.h2obindings.drm.CheckpointedDrmH2O@ce6c64f,<function1>,false)))
[32m- B = 1 + 2 * (A * A) ew unary function fusion[0m
[32m- functional apply()[0m
[32mDrmLikeOpsSuite:[0m
{
0 => {0:2.0,1:3.0,2:4.0}
1 => {0:3.0,1:4.0,2:5.0}
2 => {0:4.0,1:5.0,2:6.0}
3 => {0:5.0,1:6.0,2:7.0}
}
[32m- mapBlock[0m
[32m- mapBlock implicit keying[0m
[32m- allReduceBlock[0m
{
0 => {0:2.0,1:3.0}
1 => {0:3.0,1:4.0}
2 => {0:4.0,1:5.0}
3 => {0:5.0,1:6.0}
}
[32m- col range[0m
{
0 => {0:2.0,1:3.0,2:4.0}
1 => {0:3.0,1:4.0,2:5.0}
}
[32m- row range[0m
{
0 => {0:3.0,1:4.0}
1 => {0:4.0,1:5.0}
}
[32m- col, row range[0m
[32m- dsqDist(X,Y)[0m
226107 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
[32m- dsqDist(X)[0m
[32mAtSuite:[0m
{
0 => {0:1.0,1:2.0,2:3.0}
1 => {0:2.0,1:3.0,2:4.0}
2 => {0:3.0,1:4.0,2:5.0}
}
[32m- At[0m
[32mClassifierStatsH2OTestSuite:[0m
[32m- testFullRunningAverageAndStdDev[0m
[32m- testBigFullRunningAverageAndStdDev[0m
[32m- testStddevFullRunningAverageAndStdDev[0m
[32m- testFullRunningAverage[0m
[32m- testFullRunningAveragCopyConstructor[0m
[32m- testInvertedRunningAverage[0m
[32m- testInvertedRunningAverageAndStdDev[0m
[32m- testBuild[0m
[32m- GetMatrix[0m
[32m- testPrecisionRecallAndF1ScoreAsScikitLearn[0m
[32mAewBSuite:[0m
[32m- A * B Hadamard[0m
[32m- A + B Elementwise[0m
[32m- A - B Elementwise[0m
[32m- A / B Elementwise[0m
[32mNBH2OTestSuite:[0m
[32m- Simple Standard NB Model[0m
[32m- NB Aggregator[0m
[32m- Model DFS Serialization[0m
[32m- train and test a model[0m
TFIDF matrix
{
0 => {0:0.8507302182814089,1:0.8162266640434258,2:0.32850304500842264,3:0.06852174754693185,4:0.6089922100906467,5:0.47299954209911754,6:0.33829266287203197,7:0.20377529397787336,8:0.9022123704174732,9:0.17636281176456498,10:0.4661829066011731,11:0.7783988866502161,12:0.30500040488502705,13:0.17928292181794725,14:0.36542691848062997,15:0.882254603932934,16:0.8887844549713073,17:0.8134382691523407,18:0.7339751015873561,19:0.21497897985116293 ... }
1 => {0:0.9790528764555192,1:0.39986010535516586,2:0.08705835939267886,3:0.6198923301970254,4:0.6603973417083813,5:0.6557608750982553,6:0.6304986955986625,7:0.021822157447133783,8:0.493067663444509,9:0.6349017281834919,10:0.6608667898628399,11:0.5341072845444107,12:0.11836184269288558,13:0.5598426346093659,14:0.6065707224689623,15:0.3132013783906795,16:0.20760890698306894,17:0.22685501718257145,18:0.9768971988949653,19:0.12030512356051443 ... }
2 => {0:0.4409029532274484,1:0.7126933998766671,2:0.08830651883480517,3:0.9836922914120694,4:0.8147991877860192,5:0.9637626092779221,6:0.6562955422663692,7:0.270485632228403,8:0.9480444572500816,9:0.7352253313372139,10:0.7725018453364743,11:0.21356192209543412,12:0.3878677758826206,13:0.03291522680495329,14:0.9920692301668461,15:0.7492082330578532,16:0.9363143653412787,17:0.7834213512859992,18:0.35442335384918733,19:0.9262549155149999 ... }
3 => {0:0.8315588105745518,1:0.3873932896516372,2:0.825226217216761,3:0.1372662347971157,4:0.2769521834422016,5:0.008700149103209154,6:0.2834224173816073,7:0.11671181651191648,8:0.987734140082854,9:0.021823520439176847,10:0.056034542102896046,11:0.12068677573921321,12:0.4852706816636544,13:0.16116575808320854,14:0.5557288522928112,15:0.22903519745118556,16:0.2887215905435109,17:0.5940820521412096,18:0.6122066172493819,19:0.7437388783154334 ... }
4 => {0:0.5189313784204878,1:0.44757550280881025,2:0.028080662762998476,3:0.3910491584217025,4:0.2707999667148042,5:0.5299674672701041,6:0.057880283461186566,7:0.3156044301058978,8:0.40310975400388593,9:0.8163155682265194,10:0.746460282647356,11:0.8366375298145626,12:0.38967553640668373,13:0.6049465237732463,14:0.7617697465470061,15:0.9810653402971572,16:0.4377361025668834,17:0.8608929733503776,18:0.45539187780139406,19:0.3125296584118819 ... }
5 => {0:0.23313174113544088,1:0.2954050134961161,2:0.5606036029787539,3:0.13364542055659528,4:0.8823120329339047,5:0.8027047262173239,6:0.8133984392213951,7:0.3165247922758436,8:0.828407605457065,9:0.29488931330501367,10:0.3006316897576098,11:0.7934761471876535,12:0.8076655066458152,13:0.5150576470138923,14:0.13551332684818945,15:0.6091779080610398,16:0.40342943955263544,17:0.9087956230676538,18:0.6908382669626307,19:0.02918233231704931 ... }
6 => {0:0.23691330693442497,1:0.3160943498624943,2:0.9307664428911595,3:0.4172064951041291,4:0.6571392141032505,5:0.24420397531329419,6:0.950302668448519,7:0.3828362293356651,8:0.5330251600873261,9:0.9208835865169951,10:0.7627679196893393,11:0.6489950247789021,12:0.6812730956322666,13:0.6568514160116712,14:0.3195565628783393,15:0.18372002593427084,16:0.21124435521562585,17:0.3509281962223606,18:0.4314104260991564,19:0.20052122442227222 ... }
7 => {0:0.1852971335986197,1:0.1793133630244606,2:0.4493711661519407,3:0.5890901912397832,4:0.5338823259500403,5:0.22798862095777395,6:0.16314445114479464,7:0.9814995255985685,8:0.3329520367910288,9:0.00421285425543283,10:0.7188590952579077,11:0.3035597708647675,12:0.3837964859823591,13:0.08745303043974262,14:0.9292900296381184,15:0.43931115108049595,16:0.8263215914738486,17:0.9727270485875785,18:0.18905235067727927,19:0.2619541655945521 ... }
8 => {0:0.5007509921451473,1:0.13088766209559644,2:0.192694610678114,3:0.7733767836300116,4:0.07796746748771866,5:0.753548456202387,6:0.41817891825840936,7:0.1894263924834157,8:0.08250962347819424,9:0.33729475596926084,10:0.005196037471752568,11:0.542126539479446,12:0.17094491652565835,13:0.9941308836100584,14:0.4576672519662146,15:0.2908082010546223,16:0.7105598845170121,17:0.1531340181914138,18:0.5477420757316044,19:0.2936461122674974 ... }
9 => {0:0.17709130240687881,1:0.880764552985152,2:0.63712758787694,3:0.9495694176000596,4:0.9417251834057264,5:0.5632406703499729,6:0.21461934822221929,7:0.5682578002932495,8:0.6177839851581074,9:0.8616534238046288,10:0.9687548383407668,11:0.7746835137126495,12:0.9579791420656746,13:0.5909620104452651,14:0.20660388670531094,15:0.18390434426734387,16:0.6982024076397368,17:0.22864762420118157,18:0.9734283173775786,19:0.91228015813139 ... }
... }
Aggregated by key
{
0 => {0:2.5482288490089173,1:2.423477578686994,2:1.5683512801754997,3:2.6338464761148446,4:2.4296980461824393,5:2.964482050162825,6:2.420950075306516,7:1.3621279781312547,8:2.868901365236961,9:2.9860820538145547,10:2.753108991746095,11:3.019719902818561,12:1.9347617293322563,13:2.4681269720178767,14:2.8964897100390363,15:3.087056404276838,16:3.1846391626121076,17:2.9618148082024924,18:2.522942835068698,19:1.9479308904678145 ... }
1 => {0:2.4061318641710105,1:2.1427363245125317,2:2.5593869336170747,3:2.429463594390579,4:3.295269067440254,5:2.2583950417265353,6:2.1050833515686787,7:2.0048160921267115,8:3.2599454309335636,9:1.817480839987744,10:2.70514695532202,11:2.5265134920486947,12:2.7530736590503886,13:1.9144810805914745,14:2.433706817953392,15:1.7746299792507445,16:2.4242839361928006,17:2.931107365180195,18:3.442422751161836,19:2.0674606579189394 ... }
}
Map(Cat1 -> 0, Cat2 -> 1)
=======================================================
Summary
-------------------------------------------------------
Correctly Classified Instances: 10 100%
Incorrectly Classified Instances: 0 0%
Total Classified Instances: 10
=======================================================
Confusion Matrix
-------------------------------------------------------
a b <--Classified as
5 0 | 5 a = Cat1
0 5 | 5 b = Cat2
=======================================================
Statistics
-------------------------------------------------------
Kappa: 0.7447
Accuracy: 100%
Reliability: 66.6667%
Reliability (std dev): 0.5774
Weighted precision: 1
Weighted recall: 1
Weighted F1 score: 1
[32m- train and test a model with the confusion matrix[0m
[32mDrmLikeSuite:[0m
{
0 => {0:1.0,1:2.0,2:3.0}
1 => {0:3.0,1:4.0,2:5.0}
}
{
0 => {0:1.0,1:2.0,2:3.0}
1 => {0:3.0,1:4.0,2:5.0}
}
[32m- DRM DFS i/o (local)[0m
[32m- DRM parallelizeEmpty[0m
[36mRun completed in 4 minutes, 47 seconds.[0m
[36mTotal number of tests run: 73[0m
[36mSuites: completed 11, aborted 0[0m
[36mTests: succeeded 72, failed 1, canceled 0, ignored 0, pending 0[0m
[31m*** 1 TEST FAILED ***[0m
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Apache Mahout
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Mahout Build Tools
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO]
[INFO] Mahout Build Tools ................................. SUCCESS [ 14.220 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 2.189 s]
[INFO] Mahout Math ........................................ SUCCESS [04:39 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 23.073 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [36:42 min]
[INFO] Mahout Integration ................................. SUCCESS [03:05 min]
[INFO] Mahout Examples .................................... SUCCESS [01:17 min]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [17:16 min]
[INFO] Mahout H2O backend ................................. FAILURE [06:15 min]
[INFO] Mahout Spark bindings .............................. SKIPPED
[INFO] Mahout Flink bindings .............................. SKIPPED
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 01:10 h
[INFO] Finished at: 2016-05-01T06:25:10+00:00
[INFO] Final Memory: 57M/798M
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.scalatest:scalatest-maven-plugin:1.0:test (test) on project mahout-h2o_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-h2o_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 154.76 MB of artifacts by 86.1% relative to #3346
Recording test results
Publishing Javadoc
Updating MAHOUT-1841