You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@mahout.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2016/08/12 17:53:38 UTC

Build failed in Jenkins: Mahout-Quality #3385

See <https://builds.apache.org/job/Mahout-Quality/3385/changes>

Changes:

[smarthi] added maven code coverage plugin, this closes apache/mahout#250

------------------------------------------
[...truncated 124739 lines...]
08/12/2016 17:53:07	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING 
08/12/2016 17:53:07	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 RUNNING 
08/12/2016 17:53:07	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 RUNNING 
08/12/2016 17:53:07	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 RUNNING 
08/12/2016 17:53:07	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 RUNNING 
08/12/2016 17:53:07	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 RUNNING 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 RUNNING 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	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 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@54a0176b)(1/1) switched to SCHEDULED 
08/12/2016 17:53:07	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@54a0176b)(1/1) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@54a0176b)(1/1) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@54a0176b)(1/1) switched to FINISHED 
08/12/2016 17:53:07	Job execution switched to status FINISHED.
(100,100)
08/12/2016 17:53:07	Job execution switched to status RUNNING.
08/12/2016 17:53:07	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED 
08/12/2016 17:53:07	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING 
08/12/2016 17:53:07	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING 
08/12/2016 17:53:07	RangePartition: LocalSample(1/1) switched to SCHEDULED 
08/12/2016 17:53:07	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED 
08/12/2016 17:53:07	RangePartition: LocalSample(1/1) switched to DEPLOYING 
08/12/2016 17:53:07	RangePartition: PreparePartition(1/1) switched to SCHEDULED 
08/12/2016 17:53:07	RangePartition: PreparePartition(1/1) switched to DEPLOYING 
08/12/2016 17:53:07	RangePartition: LocalSample(1/1) switched to RUNNING 
08/12/2016 17:53:07	RangePartition: PreparePartition(1/1) switched to RUNNING 
08/12/2016 17:53:07	RangePartition: GlobalSample(1/1) switched to SCHEDULED 
08/12/2016 17:53:07	RangePartition: GlobalSample(1/1) switched to DEPLOYING 
08/12/2016 17:53:07	RangePartition: LocalSample(1/1) switched to FINISHED 
08/12/2016 17:53:07	RangePartition: GlobalSample(1/1) switched to RUNNING 
08/12/2016 17:53:07	RangePartition: Histogram(1/1) switched to SCHEDULED 
08/12/2016 17:53:07	RangePartition: Histogram(1/1) switched to DEPLOYING 
08/12/2016 17:53:07	RangePartition: GlobalSample(1/1) switched to FINISHED 
08/12/2016 17:53:07	RangePartition: Histogram(1/1) switched to RUNNING 
08/12/2016 17:53:07	RangePartition: Histogram(1/1) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED 
08/12/2016 17:53:07	RangePartition: PreparePartition(1/1) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(10/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(8/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(11/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(10/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(11/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(8/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(7/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(1/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(7/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(1/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(4/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(4/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(2/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(2/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(13/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(13/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(14/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(14/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(12/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(12/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(9/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(9/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(15/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(16/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(15/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(16/16) switched to DEPLOYING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(5/16) switched to SCHEDULED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(5/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(6/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(6/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(3/16) switched to SCHEDULED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(3/16) switched to DEPLOYING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(10/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(11/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(8/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(7/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(1/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(4/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(2/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(14/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(13/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(9/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(15/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(16/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(5/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(3/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(6/16) switched to RUNNING 
08/12/2016 17:53:07	CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(12/16) switched to RUNNING 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(8/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(14/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(3/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(6/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(10/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(11/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(16/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(12/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(9/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(5/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(2/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(13/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(4/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(7/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(1/16) switched to FINISHED 
08/12/2016 17:53:07	DataSink (org.apache.flink.api.java.Utils$CollectHelper@3eaebfc9)(15/16) switched to FINISHED 
08/12/2016 17:53:07	Job execution switched to status FINISHED.
(7,100)
585075 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$  - AAt computation detected.
[32m- dsqDist(X)[0m
[36mRun completed in 9 minutes, 58 seconds.[0m
[36mTotal number of tests run: 105[0m
[36mSuites: completed 11, aborted 0[0m
[36mTests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0[0m
[31m*** 1 TEST FAILED ***[0m
[INFO]                                                                         
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Apache Mahout
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO]                                                                         
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Mahout Build Tools
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO] 
[INFO] Mahout Build Tools ................................. SUCCESS [  5.145 s]
[INFO] Apache Mahout ...................................... SUCCESS [  0.379 s]
[INFO] Mahout Math ........................................ SUCCESS [01:17 min]
[INFO] Mahout HDFS ........................................ SUCCESS [  9.709 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:41 min]
[INFO] Mahout Integration ................................. SUCCESS [01:10 min]
[INFO] Mahout Examples .................................... SUCCESS [ 31.328 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:17 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:35 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:25 min]
[INFO] Mahout Flink bindings .............................. FAILURE [11:03 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 38:21 min
[INFO] Finished at: 2016-08-12T17:53:07+00:00
[INFO] Final Memory: 65M/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.34 MB of artifacts by 89.7% relative to #3384
Recording test results
Publishing Javadoc

Jenkins build is back to normal : Mahout-Quality #3388

Posted by Apache Jenkins Server <je...@builds.apache.org>.

See <https://builds.apache.org/job/Mahout-Quality/3388/changes>

Build failed in Jenkins: Mahout-Quality #3387

Posted by Apache Jenkins Server <je...@builds.apache.org>.

See <https://builds.apache.org/job/Mahout-Quality/3387/changes>

Changes:

[apalumbo] MAHOUT-1837: fix bug in drm.blockify(): use SparseRowMatrix by default

------------------------------------------
[...truncated 89264 lines...]
08/27/2016 16:58:00	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 RUNNING 
08/27/2016 16:58:00	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 RUNNING 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 RUNNING 
08/27/2016 16:58:00	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 RUNNING 
08/27/2016 16:58:00	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 RUNNING 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 RUNNING 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	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 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@27c11600)(1/1) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@27c11600)(1/1) switched to DEPLOYING 
08/27/2016 16:58:00	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@27c11600)(1/1) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@27c11600)(1/1) switched to FINISHED 
08/27/2016 16:58:00	Job execution switched to status FINISHED.
(100,100)
08/27/2016 16:58:00	Job execution switched to status RUNNING.
08/27/2016 16:58:00	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED 
08/27/2016 16:58:00	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING 
08/27/2016 16:58:00	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING 
08/27/2016 16:58:00	RangePartition: LocalSample(1/1) switched to SCHEDULED 
08/27/2016 16:58:00	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED 
08/27/2016 16:58:00	RangePartition: LocalSample(1/1) switched to DEPLOYING 
08/27/2016 16:58:00	RangePartition: PreparePartition(1/1) switched to SCHEDULED 
08/27/2016 16:58:00	RangePartition: PreparePartition(1/1) switched to DEPLOYING 
08/27/2016 16:58:00	RangePartition: LocalSample(1/1) switched to RUNNING 
08/27/2016 16:58:00	RangePartition: PreparePartition(1/1) switched to RUNNING 
08/27/2016 16:58:00	RangePartition: GlobalSample(1/1) switched to SCHEDULED 
08/27/2016 16:58:00	RangePartition: GlobalSample(1/1) switched to DEPLOYING 
08/27/2016 16:58:00	RangePartition: LocalSample(1/1) switched to FINISHED 
08/27/2016 16:58:00	RangePartition: GlobalSample(1/1) switched to RUNNING 
08/27/2016 16:58:00	RangePartition: Histogram(1/1) switched to SCHEDULED 
08/27/2016 16:58:00	RangePartition: Histogram(1/1) switched to DEPLOYING 
08/27/2016 16:58:00	RangePartition: GlobalSample(1/1) switched to FINISHED 
08/27/2016 16:58:00	RangePartition: Histogram(1/1) switched to RUNNING 
08/27/2016 16:58:00	RangePartition: Histogram(1/1) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED 
08/27/2016 16:58:00	RangePartition: PreparePartition(1/1) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(1/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(1/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(3/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(3/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(2/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(2/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(4/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(4/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(10/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(10/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(9/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(9/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(16/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(16/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(5/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(5/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(14/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(13/16) switched to SCHEDULED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(14/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(13/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(7/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(11/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(7/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(11/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(8/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(8/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(15/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(15/16) switched to DEPLOYING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(12/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(12/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(6/16) switched to SCHEDULED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(6/16) switched to DEPLOYING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(1/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(3/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(2/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(4/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(10/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(9/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(16/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(5/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(13/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(15/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(14/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(7/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(11/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(8/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(12/16) switched to RUNNING 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(6/16) switched to RUNNING 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED 
08/27/2016 16:58:00	CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(7/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(1/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(10/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(6/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(14/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(3/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(4/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(13/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(12/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(9/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(16/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(2/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(11/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(5/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(15/16) switched to FINISHED 
08/27/2016 16:58:00	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2848089b)(8/16) switched to FINISHED 
08/27/2016 16:58:00	Job execution switched to status FINISHED.
(7,100)
384327 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$  - AAt computation detected.
[32m- dsqDist(X)[0m
[36mRun completed in 6 minutes, 39 seconds.[0m
[36mTotal number of tests run: 105[0m
[36mSuites: completed 11, aborted 0[0m
[36mTests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0[0m
[31m*** 1 TEST FAILED ***[0m
[INFO]                                                                         
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Apache Mahout
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO]                                                                         
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Mahout Build Tools
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO] 
[INFO] Mahout Build Tools ................................. SUCCESS [  2.676 s]
[INFO] Apache Mahout ...................................... SUCCESS [  1.075 s]
[INFO] Mahout Math ........................................ SUCCESS [01:16 min]
[INFO] Mahout HDFS ........................................ SUCCESS [  4.609 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:31 min]
[INFO] Mahout Integration ................................. SUCCESS [ 45.393 s]
[INFO] Mahout Examples .................................... SUCCESS [ 26.058 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:14 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:29 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:16 min]
[INFO] Mahout Flink bindings .............................. FAILURE [07:29 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 33:41 min
[INFO] Finished at: 2016-08-27T16:58:01+00:00
[INFO] Final Memory: 65M/610M
[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.41 MB of artifacts by 89.7% relative to #3384
Recording test results
Publishing Javadoc
Updating MAHOUT-1837

Build failed in Jenkins: Mahout-Quality #3386

Posted by Apache Jenkins Server <je...@builds.apache.org>.

See <https://builds.apache.org/job/Mahout-Quality/3386/changes>

Changes:

[smarthi] Add Codecoverage maven plugin

------------------------------------------
[...truncated 125740 lines...]
08/12/2016 19:21: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 DEPLOYING 
08/12/2016 19:21: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 RUNNING 
08/12/2016 19:21: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 RUNNING 
08/12/2016 19:21: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 
08/12/2016 19:21: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 RUNNING 
08/12/2016 19:21: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 RUNNING 
08/12/2016 19:21: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 RUNNING 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 RUNNING 
08/12/2016 19:21: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 
08/12/2016 19:21:52	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED 
08/12/2016 19:21:52	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21:52	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21: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 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2007e457)(1/1) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2007e457)(1/1) switched to DEPLOYING 
08/12/2016 19:21: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 
08/12/2016 19:21:52	Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2007e457)(1/1) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@2007e457)(1/1) switched to FINISHED 
08/12/2016 19:21:52	Job execution switched to status FINISHED.
(100,100)
08/12/2016 19:21:52	Job execution switched to status RUNNING.
08/12/2016 19:21:52	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED 
08/12/2016 19:21:52	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING 
08/12/2016 19:21:52	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING 
08/12/2016 19:21:52	DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED 
08/12/2016 19:21:52	RangePartition: LocalSample(1/1) switched to SCHEDULED 
08/12/2016 19:21:52	RangePartition: LocalSample(1/1) switched to DEPLOYING 
08/12/2016 19:21:52	RangePartition: PreparePartition(1/1) switched to SCHEDULED 
08/12/2016 19:21:52	RangePartition: PreparePartition(1/1) switched to DEPLOYING 
08/12/2016 19:21:52	RangePartition: LocalSample(1/1) switched to RUNNING 
08/12/2016 19:21:52	RangePartition: PreparePartition(1/1) switched to RUNNING 
08/12/2016 19:21:52	RangePartition: LocalSample(1/1) switched to FINISHED 
08/12/2016 19:21:52	RangePartition: GlobalSample(1/1) switched to SCHEDULED 
08/12/2016 19:21:52	RangePartition: GlobalSample(1/1) switched to DEPLOYING 
08/12/2016 19:21:52	RangePartition: GlobalSample(1/1) switched to RUNNING 
08/12/2016 19:21:52	RangePartition: Histogram(1/1) switched to SCHEDULED 
08/12/2016 19:21:52	RangePartition: Histogram(1/1) switched to DEPLOYING 
08/12/2016 19:21:52	RangePartition: GlobalSample(1/1) switched to FINISHED 
08/12/2016 19:21:52	RangePartition: Histogram(1/1) switched to RUNNING 
08/12/2016 19:21:52	RangePartition: Histogram(1/1) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED 
08/12/2016 19:21:52	RangePartition: PreparePartition(1/1) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(1/16) switched to SCHEDULED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(1/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(7/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(6/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(7/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(9/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(16/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(6/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(2/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(9/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(14/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(12/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(16/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(10/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(2/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(13/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(14/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(11/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(12/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(11/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(15/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(3/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(13/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(15/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(10/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(3/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(8/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(8/16) switched to DEPLOYING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(5/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(5/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(1/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(4/16) switched to SCHEDULED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(4/16) switched to DEPLOYING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(7/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(6/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(9/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(16/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(2/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(3/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(8/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(5/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(4/16) switched to RUNNING 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED 
08/12/2016 19:21:52	CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(14/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(1/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(2/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(7/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(8/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(4/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(5/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(14/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(10/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(13/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(12/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(15/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(11/16) switched to RUNNING 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(11/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(10/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(6/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(16/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(3/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(9/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(13/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(12/16) switched to FINISHED 
08/12/2016 19:21:52	DataSink (org.apache.flink.api.java.Utils$CollectHelper@6bb23484)(15/16) switched to FINISHED 
08/12/2016 19:21:52	Job execution switched to status FINISHED.
(7,100)
558573 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$  - AAt computation detected.
[32m- dsqDist(X)[0m
[36mRun completed in 9 minutes, 31 seconds.[0m
[36mTotal number of tests run: 105[0m
[36mSuites: completed 11, aborted 0[0m
[36mTests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0[0m
[31m*** 1 TEST FAILED ***[0m
[INFO]                                                                         
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Apache Mahout
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO]                                                                         
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Mahout Build Tools
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO] 
[INFO] Mahout Build Tools ................................. SUCCESS [  2.493 s]
[INFO] Apache Mahout ...................................... SUCCESS [  0.193 s]
[INFO] Mahout Math ........................................ SUCCESS [01:20 min]
[INFO] Mahout HDFS ........................................ SUCCESS [  7.882 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:45 min]
[INFO] Mahout Integration ................................. SUCCESS [ 55.576 s]
[INFO] Mahout Examples .................................... SUCCESS [ 26.095 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:18 min]
[INFO] Mahout H2O backend ................................. SUCCESS [03:31 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:22 min]
[INFO] Mahout Flink bindings .............................. FAILURE [10:28 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 37:23 min
[INFO] Finished at: 2016-08-12T19:21:52+00:00
[INFO] Final Memory: 64M/612M
[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.34 MB of artifacts by 91.4% relative to #3384
Recording test results
Publishing Javadoc