Apache Jenkins Server
2016-09-13 19:50:51 UTC
See <https://builds.apache.org/job/Mahout-Quality/3392/changes>
Changes:
[apalumbo] move Hadoop1HDFSUtils into a new h2o package to not coflict with spark
------------------------------------------
[...truncated 89816 lines...]
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
09/13/2016 19:49:23 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to SCHEDULED
09/13/2016 19:49:23 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to DEPLOYING
09/13/2016 19:49:23 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to RUNNING
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to SCHEDULED
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to DEPLOYING
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to RUNNING
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to SCHEDULED
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to DEPLOYING
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to RUNNING
09/13/2016 19:49:25 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to SCHEDULED
09/13/2016 19:49:25 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to DEPLOYING
09/13/2016 19:49:25 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to RUNNING
09/13/2016 19:49:26 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to SCHEDULED
09/13/2016 19:49:26 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to FINISHED
09/13/2016 19:49:26 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to RUNNING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (org.apache.flink.api.java.Utils$***@772cd8a3)(1/1) switched to SCHEDULED
09/13/2016 19:49:26 DataSink (org.apache.flink.api.java.Utils$***@772cd8a3)(1/1) switched to DEPLOYING
09/13/2016 19:49:26 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to FINISHED
09/13/2016 19:49:26 DataSink (org.apache.flink.api.java.Utils$***@772cd8a3)(1/1) switched to RUNNING
09/13/2016 19:49:26 DataSink (org.apache.flink.api.java.Utils$***@772cd8a3)(1/1) switched to FINISHED
09/13/2016 19:49:26 Job execution switched to status FINISHED.
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#584595676]
09/13/2016 19:49:26 Job execution switched to status RUNNING.
09/13/2016 19:49:26 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
09/13/2016 19:49:26 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
09/13/2016 19:49:26 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: LocalSample(1/1) switched to SCHEDULED
09/13/2016 19:49:26 RangePartition: LocalSample(1/1) switched to DEPLOYING
09/13/2016 19:49:26 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to SCHEDULED
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to DEPLOYING
09/13/2016 19:49:26 RangePartition: LocalSample(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: GlobalSample(1/1) switched to SCHEDULED
09/13/2016 19:49:26 RangePartition: GlobalSample(1/1) switched to DEPLOYING
09/13/2016 19:49:26 RangePartition: LocalSample(1/1) switched to FINISHED
09/13/2016 19:49:26 RangePartition: GlobalSample(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: Histogram(1/1) switched to SCHEDULED
09/13/2016 19:49:26 RangePartition: Histogram(1/1) switched to DEPLOYING
09/13/2016 19:49:26 RangePartition: GlobalSample(1/1) switched to FINISHED
09/13/2016 19:49:26 RangePartition: Histogram(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: Histogram(1/1) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
09/13/2016 19:49:26 DataSink (***@7d21df71)(2/4) switched to SCHEDULED
09/13/2016 19:49:26 DataSink (***@7d21df71)(2/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(1/4) switched to SCHEDULED
09/13/2016 19:49:26 DataSink (***@7d21df71)(1/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(4/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(4/4) switched to DEPLOYING
09/13/2016 19:49:26 DataSink (***@7d21df71)(3/4) switched to SCHEDULED
09/13/2016 19:49:26 DataSink (***@7d21df71)(3/4) switched to DEPLOYING
09/13/2016 19:49:26 DataSink (***@7d21df71)(1/4) switched to RUNNING
09/13/2016 19:49:26 DataSink (***@7d21df71)(2/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(3/4) switched to RUNNING
09/13/2016 19:49:26 DataSink (***@7d21df71)(4/4) switched to RUNNING
09/13/2016 19:49:26 DataSink (***@7d21df71)(3/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(1/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(2/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(4/4) switched to FINISHED
09/13/2016 19:49:26 Job execution switched to status FINISHED.
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#-839158076]
09/13/2016 19:49:27 Job execution switched to status RUNNING.
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to RUNNING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to RUNNING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to RUNNING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(2/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(2/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(1/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(1/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(4/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(4/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to FINISHED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to FINISHED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(4/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(1/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(2/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(2/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(1/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(3/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(3/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(3/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(4/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(3/4) switched to FINISHED
09/13/2016 19:49:27 Job execution switched to status FINISHED.
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#236930863]
09/13/2016 19:49:27 Job execution switched to status RUNNING.
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
09/13/2016 19:49:27 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@3d67d65e)(1/1) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@3d67d65e)(1/1) switched to DEPLOYING
09/13/2016 19:49:27 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@3d67d65e)(1/1) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@3d67d65e)(1/1) switched to FINISHED
09/13/2016 19:49:27 Job execution switched to status FINISHED.
(20,20)
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#1871433580]
09/13/2016 19:49:30 Job execution switched to status RUNNING.
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to SCHEDULED
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to DEPLOYING
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to RUNNING
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to FINISHED
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000007d7480000, 454557696, 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 454557696 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_pid20566.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 [ 6.921 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.225 s]
[INFO] Mahout Math ........................................ SUCCESS [01:18 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 8.810 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:12 min]
[INFO] Mahout Integration ................................. SUCCESS [ 55.552 s]
[INFO] Mahout Examples .................................... SUCCESS [ 23.971 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:18 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:17 min]
[INFO] Mahout Flink bindings .............................. FAILURE [02:24 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 24:10 min
[INFO] Finished at: 2016-09-13T19:49:31+00:00
[INFO] Final Memory: 67M/423M
[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 157.95 MB of artifacts by 89.4% relative to #3391
Recording test results
Publishing Javadoc
Changes:
[apalumbo] move Hadoop1HDFSUtils into a new h2o package to not coflict with spark
------------------------------------------
[...truncated 89816 lines...]
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
09/13/2016 19:49:23 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
09/13/2016 19:49:23 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to SCHEDULED
09/13/2016 19:49:23 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to DEPLOYING
09/13/2016 19:49:23 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to RUNNING
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to SCHEDULED
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to DEPLOYING
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to RUNNING
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to SCHEDULED
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to DEPLOYING
09/13/2016 19:49:24 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to RUNNING
09/13/2016 19:49:25 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to SCHEDULED
09/13/2016 19:49:25 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to DEPLOYING
09/13/2016 19:49:25 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(2/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(1/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to RUNNING
09/13/2016 19:49:26 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to SCHEDULED
09/13/2016 19:49:26 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(2/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/4) switched to FINISHED
09/13/2016 19:49:26 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to RUNNING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(3/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> Map (Map at org.apache.mahout.flinkbindings.blas.FlinkOpMapBlock$.apply(FlinkOpMapBlock.scala:37)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.drm.BlockifiedFlinkDrm.asRowWise(FlinkDrm.scala:93))(4/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(3/4) switched to FINISHED
09/13/2016 19:49:26 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:71)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(4/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (org.apache.flink.api.java.Utils$***@772cd8a3)(1/1) switched to SCHEDULED
09/13/2016 19:49:26 DataSink (org.apache.flink.api.java.Utils$***@772cd8a3)(1/1) switched to DEPLOYING
09/13/2016 19:49:26 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to FINISHED
09/13/2016 19:49:26 DataSink (org.apache.flink.api.java.Utils$***@772cd8a3)(1/1) switched to RUNNING
09/13/2016 19:49:26 DataSink (org.apache.flink.api.java.Utils$***@772cd8a3)(1/1) switched to FINISHED
09/13/2016 19:49:26 Job execution switched to status FINISHED.
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#584595676]
09/13/2016 19:49:26 Job execution switched to status RUNNING.
09/13/2016 19:49:26 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
09/13/2016 19:49:26 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
09/13/2016 19:49:26 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: LocalSample(1/1) switched to SCHEDULED
09/13/2016 19:49:26 RangePartition: LocalSample(1/1) switched to DEPLOYING
09/13/2016 19:49:26 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to SCHEDULED
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to DEPLOYING
09/13/2016 19:49:26 RangePartition: LocalSample(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: GlobalSample(1/1) switched to SCHEDULED
09/13/2016 19:49:26 RangePartition: GlobalSample(1/1) switched to DEPLOYING
09/13/2016 19:49:26 RangePartition: LocalSample(1/1) switched to FINISHED
09/13/2016 19:49:26 RangePartition: GlobalSample(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: Histogram(1/1) switched to SCHEDULED
09/13/2016 19:49:26 RangePartition: Histogram(1/1) switched to DEPLOYING
09/13/2016 19:49:26 RangePartition: GlobalSample(1/1) switched to FINISHED
09/13/2016 19:49:26 RangePartition: Histogram(1/1) switched to RUNNING
09/13/2016 19:49:26 RangePartition: Histogram(1/1) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING
09/13/2016 19:49:26 RangePartition: PreparePartition(1/1) switched to FINISHED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING
09/13/2016 19:49:26 DataSink (***@7d21df71)(2/4) switched to SCHEDULED
09/13/2016 19:49:26 DataSink (***@7d21df71)(2/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(1/4) switched to SCHEDULED
09/13/2016 19:49:26 DataSink (***@7d21df71)(1/4) switched to DEPLOYING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(4/4) switched to SCHEDULED
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(4/4) switched to DEPLOYING
09/13/2016 19:49:26 DataSink (***@7d21df71)(3/4) switched to SCHEDULED
09/13/2016 19:49:26 DataSink (***@7d21df71)(3/4) switched to DEPLOYING
09/13/2016 19:49:26 DataSink (***@7d21df71)(1/4) switched to RUNNING
09/13/2016 19:49:26 DataSink (***@7d21df71)(2/4) switched to RUNNING
09/13/2016 19:49:26 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(3/4) switched to RUNNING
09/13/2016 19:49:26 DataSink (***@7d21df71)(4/4) switched to RUNNING
09/13/2016 19:49:26 DataSink (***@7d21df71)(3/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(1/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(2/4) switched to FINISHED
09/13/2016 19:49:26 DataSink (***@7d21df71)(4/4) switched to FINISHED
09/13/2016 19:49:26 Job execution switched to status FINISHED.
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#-839158076]
09/13/2016 19:49:27 Job execution switched to status RUNNING.
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to RUNNING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to RUNNING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to RUNNING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(2/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(2/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(1/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(1/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(4/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(4/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to FINISHED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to FINISHED
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(4/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(1/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(2/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(2/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(1/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(3/4) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(3/4) switched to DEPLOYING
09/13/2016 19:49:27 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(3/4) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(4/4) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@39fb6520)(3/4) switched to FINISHED
09/13/2016 19:49:27 Job execution switched to status FINISHED.
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#236930863]
09/13/2016 19:49:27 Job execution switched to status RUNNING.
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
09/13/2016 19:49:27 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
09/13/2016 19:49:27 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (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
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@3d67d65e)(1/1) switched to SCHEDULED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@3d67d65e)(1/1) switched to DEPLOYING
09/13/2016 19:49:27 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@3d67d65e)(1/1) switched to RUNNING
09/13/2016 19:49:27 DataSink (org.apache.flink.api.java.Utils$***@3d67d65e)(1/1) switched to FINISHED
09/13/2016 19:49:27 Job execution switched to status FINISHED.
(20,20)
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#1871433580]
09/13/2016 19:49:30 Job execution switched to status RUNNING.
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to SCHEDULED
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to DEPLOYING
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to RUNNING
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to FINISHED
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
09/13/2016 19:49:30 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
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000007d7480000, 454557696, 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 454557696 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_pid20566.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 [ 6.921 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.225 s]
[INFO] Mahout Math ........................................ SUCCESS [01:18 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 8.810 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:12 min]
[INFO] Mahout Integration ................................. SUCCESS [ 55.552 s]
[INFO] Mahout Examples .................................... SUCCESS [ 23.971 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:18 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:17 min]
[INFO] Mahout Flink bindings .............................. FAILURE [02:24 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 24:10 min
[INFO] Finished at: 2016-09-13T19:49:31+00:00
[INFO] Final Memory: 67M/423M
[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 157.95 MB of artifacts by 89.4% relative to #3391
Recording test results
Publishing Javadoc