See <https://builds.apache.org/job/Mahout-Quality/3396/changes>
Changes: [smarthi] No Jira: Update DOAP to the most recent release ------------------------------------------ [...truncated 79914 lines...] 10/10/2016 16:30:30 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED 10/10/2016 16:30:30 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED 10/10/2016 16:30:30 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING 10/10/2016 16:30:30 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING 10/10/2016 16:30:30 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING 10/10/2016 16:30:30 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING 10/10/2016 16:30:30 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING 10/10/2016 16:30:30 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING 10/10/2016 16:30:30 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 10/10/2016 16:30:30 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 10/10/2016 16:30:30 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 10/10/2016 16:30:31 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 10/10/2016 16:30:31 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 10/10/2016 16:30:31 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 10/10/2016 16:30:32 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 10/10/2016 16:30:32 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 10/10/2016 16:30:32 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 10/10/2016 16:30:33 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 10/10/2016 16:30:33 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 10/10/2016 16:30:33 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 10/10/2016 16:30:34 RangePartition: PreparePartition(1/1) switched to FINISHED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to SCHEDULED 10/10/2016 16:30:34 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to DEPLOYING 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to RUNNING 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 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 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@4daa0cc3)(1/1) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@4daa0cc3)(1/1) switched to DEPLOYING 10/10/2016 16:30:34 Reduce (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtA$.slim(FlinkOpAtA.scala:118))(1/1) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@4daa0cc3)(1/1) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@4daa0cc3)(1/1) switched to FINISHED 10/10/2016 16:30:34 Job execution switched to status FINISHED. Connected to JobManager at Actor[akka://flink/user/jobmanager_1#949166162] 10/10/2016 16:30:34 Job execution switched to status RUNNING. 10/10/2016 16:30:34 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED 10/10/2016 16:30:34 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING 10/10/2016 16:30:34 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING 10/10/2016 16:30:34 RangePartition: LocalSample(1/1) switched to SCHEDULED 10/10/2016 16:30:34 RangePartition: LocalSample(1/1) switched to DEPLOYING 10/10/2016 16:30:34 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED 10/10/2016 16:30:34 RangePartition: PreparePartition(1/1) switched to SCHEDULED 10/10/2016 16:30:34 RangePartition: PreparePartition(1/1) switched to DEPLOYING 10/10/2016 16:30:34 RangePartition: LocalSample(1/1) switched to RUNNING 10/10/2016 16:30:34 RangePartition: PreparePartition(1/1) switched to RUNNING 10/10/2016 16:30:34 RangePartition: GlobalSample(1/1) switched to SCHEDULED 10/10/2016 16:30:34 RangePartition: GlobalSample(1/1) switched to DEPLOYING 10/10/2016 16:30:34 RangePartition: LocalSample(1/1) switched to FINISHED 10/10/2016 16:30:34 RangePartition: GlobalSample(1/1) switched to RUNNING 10/10/2016 16:30:34 RangePartition: Histogram(1/1) switched to SCHEDULED 10/10/2016 16:30:34 RangePartition: Histogram(1/1) switched to DEPLOYING 10/10/2016 16:30:34 RangePartition: GlobalSample(1/1) switched to FINISHED 10/10/2016 16:30:34 RangePartition: Histogram(1/1) switched to RUNNING 10/10/2016 16:30:34 RangePartition: Histogram(1/1) switched to FINISHED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(1/4) switched to SCHEDULED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(2/4) switched to SCHEDULED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(1/4) switched to DEPLOYING 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(2/4) switched to DEPLOYING 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(3/4) switched to SCHEDULED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(4/4) switched to SCHEDULED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(3/4) switched to DEPLOYING 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(4/4) switched to DEPLOYING 10/10/2016 16:30:34 RangePartition: PreparePartition(1/1) switched to FINISHED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(1/4) switched to RUNNING 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(2/4) switched to RUNNING 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(3/4) switched to RUNNING 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(4/4) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(3/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(3/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(2/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(2/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(4/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(4/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(1/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(1/4) switched to DEPLOYING 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(2/4) switched to FINISHED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(3/4) switched to FINISHED 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(1/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(3/4) switched to RUNNING 10/10/2016 16:30:34 CHAIN RangePartition: Partition -> Partition(4/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(2/4) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(4/4) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(1/4) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(3/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(2/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(4/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@4fb104a9)(1/4) switched to FINISHED 10/10/2016 16:30:34 Job execution switched to status FINISHED. Connected to JobManager at Actor[akka://flink/user/jobmanager_1#1564885588] 10/10/2016 16:30:34 Job execution switched to status RUNNING. 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to RUNNING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to RUNNING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to RUNNING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to RUNNING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(3/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(3/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(3/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(4/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(4/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(1/4) switched to FINISHED 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(2/4) switched to FINISHED 10/10/2016 16:30:34 DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat)(4/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(1/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(2/4) switched to SCHEDULED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(1/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(2/4) switched to DEPLOYING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(4/4) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(1/4) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(3/4) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(2/4) switched to RUNNING 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(2/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(3/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(4/4) switched to FINISHED 10/10/2016 16:30:34 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1c1fa982)(1/4) switched to FINISHED 10/10/2016 16:30:34 Job execution switched to status FINISHED. Connected to JobManager at Actor[akka://flink/user/jobmanager_1#-1253674828] 10/10/2016 16:30:35 Job execution switched to status RUNNING. 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED 10/10/2016 16:30:35 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING 10/10/2016 16:30:35 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 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 10/10/2016 16:30:35 DataSink (org.apache.flink.api.java.Utils$CollectHelper@d956124)(1/1) switched to SCHEDULED 10/10/2016 16:30:35 DataSink (org.apache.flink.api.java.Utils$CollectHelper@d956124)(1/1) switched to DEPLOYING 10/10/2016 16:30:35 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 10/10/2016 16:30:35 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED 10/10/2016 16:30:35 DataSink (org.apache.flink.api.java.Utils$CollectHelper@d956124)(1/1) switched to RUNNING 10/10/2016 16:30:35 DataSink (org.apache.flink.api.java.Utils$CollectHelper@d956124)(1/1) switched to FINISHED 10/10/2016 16:30:35 Job execution switched to status FINISHED. (20,20) Connected to JobManager at Actor[akka://flink/user/jobmanager_1#-111254381] 10/10/2016 16:30:38 Job execution switched to status RUNNING. 10/10/2016 16:30:38 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED 10/10/2016 16:30:38 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING 10/10/2016 16:30:38 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to SCHEDULED 10/10/2016 16:30:38 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to DEPLOYING 10/10/2016 16:30:38 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING 10/10/2016 16:30:38 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to RUNNING 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 DataSource (at org.apache.mahout.flinkbindings.blas.FlinkOpTimesRightMatrix$.drmTimesInCore(FlinkOpTimesRightMatrix.scala:50) (org.apache.flink.api.java.io.Collec)(1/1) switched to FINISHED 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 10/10/2016 16:30:38 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 Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000007da800000, 587202560, 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 587202560 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_pid22136.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 [ 3.039 s] [INFO] Apache Mahout ...................................... SUCCESS [ 0.201 s] [INFO] Mahout Math ........................................ SUCCESS [01:23 min] [INFO] Mahout HDFS ........................................ SUCCESS [ 12.928 s] [INFO] Mahout Map-Reduce .................................. SUCCESS [12:58 min] [INFO] Mahout Integration ................................. SUCCESS [01:00 min] [INFO] Mahout Examples .................................... SUCCESS [ 25.006 s] [INFO] Mahout Math Scala bindings ......................... SUCCESS [04:33 min] [INFO] Mahout Spark bindings .............................. SUCCESS [02:37 min] [INFO] Mahout Flink bindings .............................. FAILURE [02:40 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: 25:58 min [INFO] Finished at: 2016-10-10T16:30:40+00:00 [INFO] Final Memory: 67M/416M [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.97 MB of artifacts by 86.8% relative to #3394 Recording test results Publishing Javadoc
