You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@mahout.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2017/02/24 14:45:25 UTC
Build failed in Jenkins: Mahout-Quality #3419
See <https://builds.apache.org/job/Mahout-Quality/3419/display/redirect?page=changes>
Changes:
[rawkintrevo] MAHOUT-1894 Add Support for Spark 2.x closes apache/mahout#271
[rawkintrevo] MAHOUT-1924 Add Unit Test for DurbinWatson Test closes apache/mahout#282
------------------------------------------
[...truncated 21.55 MB...]
02/24/2017 14:44:52 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))(9/16) switched to RUNNING
02/24/2017 14:44:52 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/16) switched to RUNNING
02/24/2017 14:44:52 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))(11/16) switched to RUNNING
02/24/2017 14:44:52 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/16) switched to RUNNING
02/24/2017 14:44:52 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))(12/16) switched to RUNNING
02/24/2017 14:44:52 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))(10/16) switched to RUNNING
02/24/2017 14:44:52 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))(13/16) switched to RUNNING
02/24/2017 14:44:52 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))(14/16) switched to RUNNING
02/24/2017 14:44:52 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))(15/16) switched to RUNNING
02/24/2017 14:44:52 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))(16/16) switched to RUNNING
02/24/2017 14:44:52 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))(8/16) switched to FINISHED
02/24/2017 14:44:52 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/16) switched to FINISHED
02/24/2017 14:44:52 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))(7/16) switched to FINISHED
02/24/2017 14:44:52 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/16) switched to FINISHED
02/24/2017 14:44:52 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/16) switched to FINISHED
02/24/2017 14:44:52 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))(13/16) switched to FINISHED
02/24/2017 14:44:52 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))(14/16) switched to FINISHED
02/24/2017 14:44:52 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
02/24/2017 14:44:52 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))(16/16) switched to FINISHED
02/24/2017 14:44:52 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))(15/16) switched to FINISHED
02/24/2017 14:44:52 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))(12/16) switched to FINISHED
02/24/2017 14:44:52 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))(9/16) switched to FINISHED
02/24/2017 14:44:52 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))(6/16) switched to FINISHED
02/24/2017 14:44:52 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/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1b6a1de0)(1/1) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1b6a1de0)(1/1) switched to DEPLOYING
02/24/2017 14:44:52 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))(5/16) switched to FINISHED
02/24/2017 14:44:52 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))(10/16) switched to FINISHED
02/24/2017 14:44:52 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))(11/16) switched to FINISHED
02/24/2017 14:44:52 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1b6a1de0)(1/1) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@1b6a1de0)(1/1) switched to FINISHED
02/24/2017 14:44:52 Job execution switched to status FINISHED.
(100,100)
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#895993936]
02/24/2017 14:44:52 Job execution switched to status RUNNING.
02/24/2017 14:44:52 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
02/24/2017 14:44:52 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
02/24/2017 14:44:52 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
02/24/2017 14:44:52 RangePartition: LocalSample(1/1) switched to SCHEDULED
02/24/2017 14:44:52 RangePartition: LocalSample(1/1) switched to DEPLOYING
02/24/2017 14:44:52 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
02/24/2017 14:44:52 RangePartition: PreparePartition(1/1) switched to SCHEDULED
02/24/2017 14:44:52 RangePartition: PreparePartition(1/1) switched to DEPLOYING
02/24/2017 14:44:52 RangePartition: LocalSample(1/1) switched to RUNNING
02/24/2017 14:44:52 RangePartition: PreparePartition(1/1) switched to RUNNING
02/24/2017 14:44:52 RangePartition: GlobalSample(1/1) switched to SCHEDULED
02/24/2017 14:44:52 RangePartition: GlobalSample(1/1) switched to DEPLOYING
02/24/2017 14:44:52 RangePartition: LocalSample(1/1) switched to FINISHED
02/24/2017 14:44:52 RangePartition: GlobalSample(1/1) switched to RUNNING
02/24/2017 14:44:52 RangePartition: Histogram(1/1) switched to SCHEDULED
02/24/2017 14:44:52 RangePartition: Histogram(1/1) switched to DEPLOYING
02/24/2017 14:44:52 RangePartition: GlobalSample(1/1) switched to FINISHED
02/24/2017 14:44:52 RangePartition: Histogram(1/1) switched to RUNNING
02/24/2017 14:44:52 RangePartition: Histogram(1/1) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED
02/24/2017 14:44:52 RangePartition: PreparePartition(1/1) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(1/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(1/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(3/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(3/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(5/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(5/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(9/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(9/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(2/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(2/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(10/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(10/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(13/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(13/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(14/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(14/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(4/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(12/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(12/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(16/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(16/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(15/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(15/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(11/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(11/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(6/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(6/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(8/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(8/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(7/16) switched to SCHEDULED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(7/16) switched to DEPLOYING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(4/16) switched to DEPLOYING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(1/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(3/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(5/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(9/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(2/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(10/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(13/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(14/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(12/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(16/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(11/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(6/16) switched to RUNNING
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED
02/24/2017 14:44:52 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(8/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(7/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(4/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(3/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(5/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(1/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(10/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(9/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(13/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(12/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(16/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(14/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(2/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(15/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(6/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(11/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(8/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(15/16) switched to RUNNING
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(7/16) switched to FINISHED
02/24/2017 14:44:52 DataSink (org.apache.flink.api.java.Utils$CollectHelper@2769a1dd)(4/16) switched to FINISHED
02/24/2017 14:44:52 Job execution switched to status FINISHED.
(7,100)
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
418215 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
[32m- dsqDist(X)[0m
[36mRun completed in 7 minutes, 10 seconds.[0m
[36mTotal number of tests run: 111[0m
[36mSuites: completed 14, aborted 0[0m
[36mTests: succeeded 110, 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.290 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.357 s]
[INFO] Mahout Math ........................................ SUCCESS [01:11 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 3.923 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:31 min]
[INFO] Mahout Integration ................................. SUCCESS [ 47.488 s]
[INFO] Mahout Examples .................................... SUCCESS [ 25.817 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:09 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:09 min]
[INFO] Mahout Flink bindings .............................. FAILURE [07:56 min]
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 30:19 min
[INFO] Finished at: 2017-02-24T14:44:52+00:00
[INFO] Final Memory: 63M/608M
[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 175.98 MB of artifacts by 91.4% relative to #3418
Recording test results
Publishing Javadoc
[JIRA] Updating issue MAHOUT-1894
[JIRA] Updating issue MAHOUT-1924
Build failed in Jenkins: Mahout-Quality #3421
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3421/display/redirect?page=changes>
Changes:
[apalumbo] MAHOUT-1912: MAHOUT-1912: CLI driver tests not working with vienniacl.
------------------------------------------
[...truncated 434.20 KB...]
[31m[0m
[31mDriver stacktrace:[0m
[31m at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1431)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1419)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1418)[0m
[31m at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)[0m
[31m at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)[0m
[31m at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1418)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)[0m
[31m at scala.Option.foreach(Option.scala:236)[0m
[31m at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:799)[0m
[31m ...[0m
[31m Cause: java.io.FileNotFoundException: /tmp/blockmgr-074cfbcd-0dda-4581-af88-284104f3529d/0e/shuffle_45_1_0.index.686b1f33-07ce-4c6a-8675-03f4bf699f82 (No such file or directory)[0m
[31m at java.io.FileOutputStream.open(Native Method)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:221)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:171)[0m
[31m at org.apache.spark.shuffle.IndexShuffleBlockResolver.writeIndexFileAndCommit(IndexShuffleBlockResolver.scala:142)[0m
[31m at org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:128)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)[0m
[31m at org.apache.spark.scheduler.Task.run(Task.scala:89)[0m
[31m at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227)[0m
[31m at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[0m
[31m ...[0m
[31m- C = cbind(A, B) with missing rows *** FAILED ***[0m
[31m org.apache.spark.SparkException: Job aborted due to stage failure: Task 2 in stage 117.0 failed 1 times, most recent failure: Lost task 2.0 in stage 117.0 (TID 285, localhost): java.io.FileNotFoundException: /tmp/blockmgr-074cfbcd-0dda-4581-af88-284104f3529d/2f/shuffle_47_2_0.index.2f3483a4-17ab-42d2-9be9-46438957695b (No such file or directory)[0m
[31m at java.io.FileOutputStream.open(Native Method)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:221)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:171)[0m
[31m at org.apache.spark.shuffle.IndexShuffleBlockResolver.writeIndexFileAndCommit(IndexShuffleBlockResolver.scala:142)[0m
[31m at org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:128)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)[0m
[31m at org.apache.spark.scheduler.Task.run(Task.scala:89)[0m
[31m at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227)[0m
[31m at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[0m
[31m at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[0m
[31m at java.lang.Thread.run(Thread.java:745)[0m
[31m[0m
[31mDriver stacktrace:[0m
[31m at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1431)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1419)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1418)[0m
[31m at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)[0m
[31m at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)[0m
[31m at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1418)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)[0m
[31m at scala.Option.foreach(Option.scala:236)[0m
[31m at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:799)[0m
[31m ...[0m
[31m Cause: java.io.FileNotFoundException: /tmp/blockmgr-074cfbcd-0dda-4581-af88-284104f3529d/2f/shuffle_47_2_0.index.2f3483a4-17ab-42d2-9be9-46438957695b (No such file or directory)[0m
[31m at java.io.FileOutputStream.open(Native Method)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:221)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:171)[0m
[31m at org.apache.spark.shuffle.IndexShuffleBlockResolver.writeIndexFileAndCommit(IndexShuffleBlockResolver.scala:142)[0m
[31m at org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:128)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)[0m
[31m at org.apache.spark.scheduler.Task.run(Task.scala:89)[0m
[31m at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227)[0m
[31m at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[0m
[31m ...[0m
collected A =
{
0 => {0:1.0,1:2.0,2:3.0}
1 => {}
2 => {}
3 => {0:3.0,1:4.0,2:5.0}
}
[31m- B = A + 1.0 missing rows *** FAILED ***[0m
[31m org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 124.0 failed 1 times, most recent failure: Lost task 0.0 in stage 124.0 (TID 327, localhost): java.io.FileNotFoundException: /tmp/blockmgr-074cfbcd-0dda-4581-af88-284104f3529d/2f/shuffle_49_0_0.index.cea4ee67-ee4a-48c8-a29e-6a841c6ed1c8 (No such file or directory)[0m
[31m at java.io.FileOutputStream.open(Native Method)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:221)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:171)[0m
[31m at org.apache.spark.shuffle.IndexShuffleBlockResolver.writeIndexFileAndCommit(IndexShuffleBlockResolver.scala:142)[0m
[31m at org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:128)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)[0m
[31m at org.apache.spark.scheduler.Task.run(Task.scala:89)[0m
[31m at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227)[0m
[31m at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[0m
[31m at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[0m
[31m at java.lang.Thread.run(Thread.java:745)[0m
[31m[0m
[31mDriver stacktrace:[0m
[31m at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1431)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1419)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1418)[0m
[31m at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)[0m
[31m at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)[0m
[31m at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1418)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)[0m
[31m at scala.Option.foreach(Option.scala:236)[0m
[31m at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:799)[0m
[31m ...[0m
[31m Cause: java.io.FileNotFoundException: /tmp/blockmgr-074cfbcd-0dda-4581-af88-284104f3529d/2f/shuffle_49_0_0.index.cea4ee67-ee4a-48c8-a29e-6a841c6ed1c8 (No such file or directory)[0m
[31m at java.io.FileOutputStream.open(Native Method)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:221)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:171)[0m
[31m at org.apache.spark.shuffle.IndexShuffleBlockResolver.writeIndexFileAndCommit(IndexShuffleBlockResolver.scala:142)[0m
[31m at org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:128)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)[0m
[31m at org.apache.spark.scheduler.Task.run(Task.scala:89)[0m
[31m at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227)[0m
[31m at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[0m
[31m ...[0m
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
in-core mul ms: 1498
[31m- A'B, bigger *** FAILED ***[0m
[31m org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 127.0 failed 1 times, most recent failure: Lost task 0.0 in stage 127.0 (TID 329, localhost): java.io.FileNotFoundException: /tmp/blockmgr-074cfbcd-0dda-4581-af88-284104f3529d/06/temp_shuffle_27b7da17-0df2-48ae-8277-43460317ed34 (No such file or directory)[0m
[31m at java.io.FileOutputStream.open(Native Method)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:221)[0m
[31m at org.apache.spark.storage.DiskBlockObjectWriter.open(DiskBlockObjectWriter.scala:88)[0m
[31m at org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:140)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)[0m
[31m at org.apache.spark.scheduler.Task.run(Task.scala:89)[0m
[31m at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227)[0m
[31m at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[0m
[31m at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[0m
[31m at java.lang.Thread.run(Thread.java:745)[0m
[31m[0m
[31mDriver stacktrace:[0m
[31m at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1431)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1419)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1418)[0m
[31m at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)[0m
[31m at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)[0m
[31m at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1418)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)[0m
[31m at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:799)[0m
[31m at scala.Option.foreach(Option.scala:236)[0m
[31m at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:799)[0m
[31m ...[0m
[31m Cause: java.io.FileNotFoundException: /tmp/blockmgr-074cfbcd-0dda-4581-af88-284104f3529d/06/temp_shuffle_27b7da17-0df2-48ae-8277-43460317ed34 (No such file or directory)[0m
[31m at java.io.FileOutputStream.open(Native Method)[0m
[31m at java.io.FileOutputStream.<init>(FileOutputStream.java:221)[0m
[31m at org.apache.spark.storage.DiskBlockObjectWriter.open(DiskBlockObjectWriter.scala:88)[0m
[31m at org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:140)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:73)[0m
[31m at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:41)[0m
[31m at org.apache.spark.scheduler.Task.run(Task.scala:89)[0m
[31m at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:227)[0m
[31m at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[0m
[31m at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[0m
[31m ...[0m
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
[32m- C = At %*% B , zippable[0m
[32mTextDelimitedReaderWriterSuite:[0m
[32m- indexedDatasetDFSRead should read sparse matrix file with null rows[0m
[32mPreprocessorSuite:[0m
OpMapBlock(org.apache.mahout.sparkbindings.drm.CheckpointedDrmSpark@70b9d2ee,<function1>,8,-1,true)
{1:3.0,2:5.0,3:6.0}
[32m- asfactor test[0m
{0:2.0,1:5.0,2:-4.0}
{0:0.8164965809277263,1:3.2659863237109037,2:8.286535263104035}
[32m- standard scaler test[0m
[32m- mean center test[0m
[32mTFIDFSparkTestSuite:[0m
[32m- TF test[0m
[32m- TFIDF test[0m
[32m- MLlib TFIDF test[0m
[36mRun completed in 1 minute, 39 seconds.[0m
[36mTotal number of tests run: 128[0m
[36mSuites: completed 18, aborted 0[0m
[36mTests: succeeded 119, failed 9, canceled 0, ignored 1, pending 0[0m
[31m*** 9 TESTS 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 [ 3.068 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.176 s]
[INFO] Mahout Math ........................................ SUCCESS [01:13 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 5.306 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:12 min]
[INFO] Mahout Integration ................................. SUCCESS [ 45.598 s]
[INFO] Mahout Examples .................................... SUCCESS [ 25.099 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:10 min]
[INFO] Mahout Spark bindings .............................. FAILURE [02:34 min]
[INFO] Mahout Flink bindings .............................. SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 22:32 min
[INFO] Finished at: 2017-02-26T00:36:46+00:00
[INFO] Final Memory: 65M/606M
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.scalatest:scalatest-maven-plugin:1.0:test (test) on project mahout-spark_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-spark_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 153.92 MB of artifacts by 89.6% relative to #3418
Recording test results
Publishing Javadoc
[JIRA] Updating issue MAHOUT-1912
Build failed in Jenkins: Mahout-Quality #3420
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/Mahout-Quality/3420/display/redirect?page=changes>
Changes:
[akm] MAHOUT-1910: Remove .zip archive from build
------------------------------------------
[...truncated 21.96 MB...]
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELING
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELING
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELING
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELING
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELING
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELING
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELING
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELING
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(1/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(2/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(3/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(4/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(5/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(6/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(7/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(8/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(9/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(10/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(11/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(12/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(13/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(14/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(15/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(16/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(17/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(18/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(19/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(20/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(21/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(22/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(23/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN Join(Join at org.apache.flink.api.scala.UnfinishedJoinOperation.createJoinFunctionAssigner(joinDataSet.scala:278)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:52))(24/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(5/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(6/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(7/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(8/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(9/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(10/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(11/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(12/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(13/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(14/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(15/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(16/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(17/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(18/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(19/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(20/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(21/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(22/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(23/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN GroupReduce (GroupReduce at org.apache.mahout.flinkbindings.blas.FlinkOpAtB$.notZippable(FlinkOpAtB.scala:69)) -> 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))(24/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(1/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(2/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(3/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(4/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(5/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(6/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(7/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(8/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(9/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(10/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(11/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(12/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(13/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(14/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(15/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(16/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(17/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(18/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(19/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(20/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(21/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(22/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(23/24) switched to CANCELED
02/24/2017 23:00:03 DataSink (org.apache.flink.api.java.io.TypeSerializerOutputFormat@5d4efbbf)(24/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
02/24/2017 23:00:03 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
02/24/2017 23:00:03 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(21/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(22/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(1/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(5/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(6/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(9/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(23/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(10/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(12/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(19/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(3/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(20/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(2/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
02/24/2017 23:00:04 Reduce(Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(16/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(24/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(14/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(7/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(8/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(11/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(18/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(15/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(17/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(13/24) switched to CANCELED
02/24/2017 23:00:04 CHAIN MapPartition (MapPartition at org.apache.mahout.flinkbindings.drm.RowsFlinkDrm.asBlockified(FlinkDrm.scala:52)) -> FlatMap (FlatMap at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:42)) -> Combine (Reduce at org.apache.mahout.flinkbindings.blas.FlinkOpAt$.sparseTrick(FlinkOpAt.scala:61))(4/24) switched to CANCELED
02/24/2017 23:00:04 Job execution switched to status FAILED.
[31m- dsqDist(X) *** FAILED ***[0m
[31m org.apache.flink.runtime.client.JobExecutionException: Job execution failed.[0m
[31m at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply$mcV$sp(JobManager.scala:805)[0m
[31m at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:751)[0m
[31m at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$8.apply(JobManager.scala:751)[0m
[31m at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)[0m
[31m at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)[0m
[31m at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)[0m
[31m at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)[0m
[31m at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)[0m
[31m at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)[0m
[31m at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)[0m
[31m ...[0m
[31m Cause: java.io.IOException: Insufficient number of network buffers: required 24, but only 12 available. The total number of network buffers is currently set to 2048. You can increase this number by setting the configuration key 'taskmanager.network.numberOfBuffers'.[0m
[31m at org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:196)[0m
[31m at org.apache.flink.runtime.io.network.NetworkEnvironment.registerTask(NetworkEnvironment.java:296)[0m
[31m at org.apache.flink.runtime.taskmanager.Task.run(Task.java:549)[0m
[31m at java.lang.Thread.run(Thread.java:745)[0m
[31m ...[0m
[36mRun completed in 3 minutes, 41 seconds.[0m
[36mTotal number of tests run: 111[0m
[36mSuites: completed 14, aborted 0[0m
[36mTests: succeeded 89, failed 22, canceled 0, ignored 1, pending 0[0m
[31m*** 22 TESTS 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.190 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.147 s]
[INFO] Mahout Math ........................................ SUCCESS [01:27 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 4.525 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:14 min]
[INFO] Mahout Integration ................................. SUCCESS [ 41.869 s]
[INFO] Mahout Examples .................................... SUCCESS [ 22.021 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [04:20 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:12 min]
[INFO] Mahout Flink bindings .............................. FAILURE [04:25 min]
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 25:52 min
[INFO] Finished at: 2017-02-24T23:00:04+00:00
[INFO] Final Memory: 68M/965M
[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 158.41 MB of artifacts by 88.6% relative to #3418
Recording test results
Publishing Javadoc
[JIRA] Updating issue MAHOUT-1910