See <https://builds.apache.org/job/Mahout-Quality/3344/changes>
Changes: [smarthi] MAHOUT-1835: Remove countsPerPartition in Flink/blas/package.scala ------------------------------------------ [...truncated 108379 lines...] 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to DEPLOYING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to SCHEDULED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to DEPLOYING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to SCHEDULED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to DEPLOYING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to SCHEDULED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to DEPLOYING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/16) switched to RUNNING 04/23/2016 14:58:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED 04/23/2016 14:58:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(5/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(6/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(7/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(8/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(9/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(10/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(11/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(12/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(9/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(12/16) switched to FINISHED 04/23/2016 14:58:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(11/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(10/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(7/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(5/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(6/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/16) switched to FINISHED 04/23/2016 14:58:38 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(8/16) switched to FINISHED 04/23/2016 14:58:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@36a3f5ad)(1/1) switched to SCHEDULED 04/23/2016 14:58:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@36a3f5ad)(1/1) switched to DEPLOYING 04/23/2016 14:58:38 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED 04/23/2016 14:58:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@36a3f5ad)(1/1) switched to RUNNING 04/23/2016 14:58:38 DataSink (org.apache.flink.api.java.Utils$CollectHelper@36a3f5ad)(1/1) switched to FINISHED 04/23/2016 14:58:38 Job execution switched to status FINISHED. (100,100) 04/23/2016 14:58:39 Job execution switched to status RUNNING. 04/23/2016 14:58:39 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED 04/23/2016 14:58:39 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING 04/23/2016 14:58:39 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING 04/23/2016 14:58:39 RangePartition: LocalSample(1/1) switched to SCHEDULED 04/23/2016 14:58:39 RangePartition: LocalSample(1/1) switched to DEPLOYING 04/23/2016 14:58:39 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED 04/23/2016 14:58:39 RangePartition: PreparePartition(1/1) switched to SCHEDULED 04/23/2016 14:58:39 RangePartition: PreparePartition(1/1) switched to DEPLOYING 04/23/2016 14:58:39 RangePartition: LocalSample(1/1) switched to RUNNING 04/23/2016 14:58:39 RangePartition: PreparePartition(1/1) switched to RUNNING 04/23/2016 14:58:39 RangePartition: GlobalSample(1/1) switched to SCHEDULED 04/23/2016 14:58:39 RangePartition: GlobalSample(1/1) switched to DEPLOYING 04/23/2016 14:58:39 RangePartition: LocalSample(1/1) switched to FINISHED 04/23/2016 14:58:39 RangePartition: GlobalSample(1/1) switched to RUNNING 04/23/2016 14:58:39 RangePartition: Histogram(1/1) switched to SCHEDULED 04/23/2016 14:58:39 RangePartition: Histogram(1/1) switched to DEPLOYING 04/23/2016 14:58:39 RangePartition: GlobalSample(1/1) switched to FINISHED 04/23/2016 14:58:39 RangePartition: Histogram(1/1) switched to RUNNING 04/23/2016 14:58:39 RangePartition: Histogram(1/1) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING 04/23/2016 14:58:39 RangePartition: PreparePartition(1/1) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(15/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(15/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(11/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(12/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(1/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(12/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(13/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(11/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(14/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(13/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(1/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(9/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(14/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(8/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(9/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(4/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(8/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(4/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(16/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(10/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(16/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(7/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(10/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(5/16) switched to SCHEDULED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(7/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(5/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(3/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(3/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(6/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(6/16) switched to DEPLOYING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(2/16) switched to SCHEDULED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(2/16) switched to DEPLOYING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(11/16) switched to RUNNING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(4/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(6/16) switched to RUNNING 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(12/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(1/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(15/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(3/16) switched to RUNNING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(2/16) switched to RUNNING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(7/16) switched to RUNNING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(13/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(16/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(4/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(8/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(5/16) switched to RUNNING 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(10/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(14/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(9/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(6/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED 04/23/2016 14:58:39 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(7/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(5/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(2/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(3/16) switched to FINISHED 04/23/2016 14:58:39 DataSink (org.apache.flink.api.java.Utils$CollectHelper@6517144)(11/16) switched to FINISHED 04/23/2016 14:58:39 Job execution switched to status FINISHED. (7,100) 431310 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected. [32m- dsqDist(X)[0m [36mRun completed in 7 minutes, 23 seconds.[0m [36mTotal number of tests run: 105[0m [36mSuites: completed 11, aborted 0[0m [36mTests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0[0m [31m*** 1 TEST FAILED ***[0m [INFO] [INFO] ------------------------------------------------------------------------ [INFO] Skipping Apache Mahout [INFO] This project has been banned from the build due to previous failures. [INFO] ------------------------------------------------------------------------ [INFO] [INFO] ------------------------------------------------------------------------ [INFO] Skipping Mahout Build Tools [INFO] This project has been banned from the build due to previous failures. [INFO] ------------------------------------------------------------------------ [INFO] ------------------------------------------------------------------------ [INFO] Reactor Summary: [INFO] [INFO] Mahout Build Tools ................................. SUCCESS [ 2.678 s] [INFO] Apache Mahout ...................................... SUCCESS [ 0.933 s] [INFO] Mahout Math ........................................ SUCCESS [01:15 min] [INFO] Mahout HDFS ........................................ SUCCESS [ 4.049 s] [INFO] Mahout Map-Reduce .................................. SUCCESS [12:05 min] [INFO] Mahout Integration ................................. SUCCESS [ 42.924 s] [INFO] Mahout Examples .................................... SUCCESS [ 23.473 s] [INFO] Mahout Math Scala bindings ......................... SUCCESS [05:01 min] [INFO] Mahout H2O backend ................................. SUCCESS [03:27 min] [INFO] Mahout Spark bindings .............................. SUCCESS [02:20 min] [INFO] Mahout Flink bindings .............................. FAILURE [08:22 min] [INFO] Mahout Spark bindings shell ........................ SKIPPED [INFO] Mahout Release Package ............................. SKIPPED [INFO] ------------------------------------------------------------------------ [INFO] BUILD FAILURE [INFO] ------------------------------------------------------------------------ [INFO] Total time: 33:50 min [INFO] Finished at: 2016-04-23T14:58:39+00:00 [INFO] Final Memory: 64M/792M [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 171.04 MB of artifacts by 87.8% relative to #3340 Recording test results Publishing Javadoc Updating MAHOUT-1835
