Build failed in Jenkins: Mahout-Quality #3402

[Apache Jenkins Server]

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

Changes:

[smarthi] NoJira: Bump up Flink and Slf4j versions

------------------------------------------
[...truncated 100176 lines...]
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 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
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3e88f3ad)(1/1) switched to SCHEDULED
12/26/2016 07:34:45 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
12/26/2016 07:34:45 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
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3e88f3ad)(1/1) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3e88f3ad)(1/1) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3e88f3ad)(1/1) switched to FINISHED
12/26/2016 07:34:45 Job execution switched to status FINISHED.
(100,100)
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#326204016]
12/26/2016 07:34:45 Job execution switched to status RUNNING.
12/26/2016 07:34:45 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
12/26/2016 07:34:45 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
12/26/2016 07:34:45 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
12/26/2016 07:34:45 RangePartition: LocalSample(1/1) switched to SCHEDULED
12/26/2016 07:34:45 RangePartition: LocalSample(1/1) switched to DEPLOYING
12/26/2016 07:34:45 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
12/26/2016 07:34:45 RangePartition: PreparePartition(1/1) switched to SCHEDULED
12/26/2016 07:34:45 RangePartition: PreparePartition(1/1) switched to DEPLOYING
12/26/2016 07:34:45 RangePartition: LocalSample(1/1) switched to RUNNING
12/26/2016 07:34:45 RangePartition: PreparePartition(1/1) switched to RUNNING
12/26/2016 07:34:45 RangePartition: GlobalSample(1/1) switched to SCHEDULED
12/26/2016 07:34:45 RangePartition: GlobalSample(1/1) switched to DEPLOYING
12/26/2016 07:34:45 RangePartition: LocalSample(1/1) switched to FINISHED
12/26/2016 07:34:45 RangePartition: GlobalSample(1/1) switched to RUNNING
12/26/2016 07:34:45 RangePartition: Histogram(1/1) switched to SCHEDULED
12/26/2016 07:34:45 RangePartition: Histogram(1/1) switched to DEPLOYING
12/26/2016 07:34:45 RangePartition: GlobalSample(1/1) switched to FINISHED
12/26/2016 07:34:45 RangePartition: Histogram(1/1) switched to RUNNING
12/26/2016 07:34:45 RangePartition: Histogram(1/1) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED
12/26/2016 07:34:45 RangePartition: PreparePartition(1/1) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(1/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(1/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(3/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(3/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(5/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(2/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(5/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(2/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(7/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(7/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(4/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(4/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(12/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(12/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(14/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(14/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(10/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(10/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(11/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(11/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(8/16) switched to SCHEDULED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(8/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(9/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(9/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(6/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(6/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(16/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(16/16) switched to DEPLOYING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(15/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(15/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(13/16) switched to SCHEDULED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(13/16) switched to DEPLOYING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(1/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(3/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(5/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(2/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(4/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(12/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(7/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(14/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(10/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(8/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(6/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(16/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(9/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(15/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(11/16) switched to RUNNING
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED
12/26/2016 07:34:45 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(1/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(13/16) switched to RUNNING
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(4/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(3/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(2/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(5/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(12/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(10/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(14/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(7/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(16/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(6/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(15/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(13/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(9/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(8/16) switched to FINISHED
12/26/2016 07:34:45 DataSink (org.apache.flink.api.java.Utils$***@3881f786)(11/16) switched to FINISHED
12/26/2016 07:34:45 Job execution switched to status FINISHED.
(7,100)
379024 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
- dsqDist(X)
Run completed in 6 minutes, 35 seconds.
Total number of tests run: 105
Suites: completed 11, aborted 0
Tests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0
*** 1 TEST FAILED ***
[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.475 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.285 s]
[INFO] Mahout Math ........................................ SUCCESS [01:16 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 4.785 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:50 min]
[INFO] Mahout Integration ................................. SUCCESS [ 50.162 s]
[INFO] Mahout Examples .................................... SUCCESS [ 26.673 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:23 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:17 min]
[INFO] Mahout Flink bindings .............................. FAILURE [07:34 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 30:49 min
[INFO] Finished at: 2016-12-26T07:34:46+00:00
[INFO] Final Memory: 63M/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 157.98 MB of artifacts by 87.5% relative to #3401
Recording test results
Publishing Javadoc

[Apache Jenkins Server]

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

Changes:

[smarthi] MAHOUT-1875: Use faster shallowCopy for dense matices in blockify

------------------------------------------
[...truncated 96274 lines...]
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to SCHEDULED
12/27/2016 18:25:53 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 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
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@19d81570)(1/1) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@19d81570)(1/1) switched to DEPLOYING
12/27/2016 18:25:53 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
12/27/2016 18:25:53 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@19d81570)(1/1) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@19d81570)(1/1) switched to FINISHED
12/27/2016 18:25:53 Job execution switched to status FINISHED.
(100,100)
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#1275005312]
12/27/2016 18:25:53 Job execution switched to status RUNNING.
12/27/2016 18:25:53 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
12/27/2016 18:25:53 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
12/27/2016 18:25:53 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
12/27/2016 18:25:53 RangePartition: LocalSample(1/1) switched to SCHEDULED
12/27/2016 18:25:53 RangePartition: LocalSample(1/1) switched to DEPLOYING
12/27/2016 18:25:53 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
12/27/2016 18:25:53 RangePartition: PreparePartition(1/1) switched to SCHEDULED
12/27/2016 18:25:53 RangePartition: PreparePartition(1/1) switched to DEPLOYING
12/27/2016 18:25:53 RangePartition: LocalSample(1/1) switched to RUNNING
12/27/2016 18:25:53 RangePartition: PreparePartition(1/1) switched to RUNNING
12/27/2016 18:25:53 RangePartition: GlobalSample(1/1) switched to SCHEDULED
12/27/2016 18:25:53 RangePartition: GlobalSample(1/1) switched to DEPLOYING
12/27/2016 18:25:53 RangePartition: LocalSample(1/1) switched to FINISHED
12/27/2016 18:25:53 RangePartition: GlobalSample(1/1) switched to RUNNING
12/27/2016 18:25:53 RangePartition: Histogram(1/1) switched to SCHEDULED
12/27/2016 18:25:53 RangePartition: Histogram(1/1) switched to DEPLOYING
12/27/2016 18:25:53 RangePartition: GlobalSample(1/1) switched to FINISHED
12/27/2016 18:25:53 RangePartition: Histogram(1/1) switched to RUNNING
12/27/2016 18:25:53 RangePartition: Histogram(1/1) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED
12/27/2016 18:25:53 RangePartition: PreparePartition(1/1) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(1/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(1/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(4/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(4/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(2/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(2/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(6/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(3/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(6/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(3/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(10/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(10/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(12/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(13/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(12/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(13/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(16/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(16/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(5/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(5/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(14/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(14/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(15/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(15/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(9/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(9/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(11/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(8/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(7/16) switched to SCHEDULED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(11/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(8/16) switched to DEPLOYING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(7/16) switched to DEPLOYING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(1/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(4/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(6/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(2/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(3/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(10/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(12/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(13/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(16/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(5/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(14/16) switched to RUNNING
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED
12/27/2016 18:25:53 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(15/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(9/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(11/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(8/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(1/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(6/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(7/16) switched to RUNNING
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(10/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(4/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(13/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(5/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(3/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(16/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(15/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(14/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(8/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(11/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(2/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(9/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(12/16) switched to FINISHED
12/27/2016 18:25:53 DataSink (org.apache.flink.api.java.Utils$***@65fdb558)(7/16) switched to FINISHED
12/27/2016 18:25:53 Job execution switched to status FINISHED.
(7,100)
526475 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
- dsqDist(X)
Run completed in 9 minutes, 1 second.
Total number of tests run: 105
Suites: completed 11, aborted 0
Tests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0
*** 1 TEST FAILED ***
[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.296 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.217 s]
[INFO] Mahout Math ........................................ SUCCESS [01:12 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 3.787 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:18 min]
[INFO] Mahout Integration ................................. SUCCESS [ 44.030 s]
[INFO] Mahout Examples .................................... SUCCESS [ 24.890 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:05 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:19 min]
[INFO] Mahout Flink bindings .............................. FAILURE [09:56 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 32:08 min
[INFO] Finished at: 2016-12-27T18:25:54+00:00
[INFO] Final Memory: 59M/550M
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.scalatest:scalatest-maven-plugin:1.0:test (test) on project mahout-flink_2.10: There are test failures -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]
[ERROR] For more information about the errors and possible solutions, please read the following articles:
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
[ERROR]
[ERROR] After correcting the problems, you can resume the build with the command
[ERROR] mvn <goals> -rf :mahout-flink_2.10
Build step 'Invoke top-level Maven targets' marked build as failure
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
Compressed 157.98 MB of artifacts by 87.5% relative to #3401
Recording test results
Publishing Javadoc
Updating MAHOUT-1875

[Apache Jenkins Server]

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

Changes:

[smarthi] MAHOUT-1901: Remove h2o from Binary Release Build, this closes

------------------------------------------
[...truncated 90756 lines...]
01/07/2017 16:23:48 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to DEPLOYING
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 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
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@79c5750b)(1/1) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@79c5750b)(1/1) switched to DEPLOYING
01/07/2017 16:23:48 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@79c5750b)(1/1) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@79c5750b)(1/1) switched to FINISHED
01/07/2017 16:23:48 Job execution switched to status FINISHED.
(100,100)
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#668803618]
01/07/2017 16:23:48 Job execution switched to status RUNNING.
01/07/2017 16:23:48 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
01/07/2017 16:23:48 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
01/07/2017 16:23:48 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
01/07/2017 16:23:48 RangePartition: LocalSample(1/1) switched to SCHEDULED
01/07/2017 16:23:48 RangePartition: LocalSample(1/1) switched to DEPLOYING
01/07/2017 16:23:48 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
01/07/2017 16:23:48 RangePartition: PreparePartition(1/1) switched to SCHEDULED
01/07/2017 16:23:48 RangePartition: PreparePartition(1/1) switched to DEPLOYING
01/07/2017 16:23:48 RangePartition: LocalSample(1/1) switched to RUNNING
01/07/2017 16:23:48 RangePartition: PreparePartition(1/1) switched to RUNNING
01/07/2017 16:23:48 RangePartition: GlobalSample(1/1) switched to SCHEDULED
01/07/2017 16:23:48 RangePartition: GlobalSample(1/1) switched to DEPLOYING
01/07/2017 16:23:48 RangePartition: LocalSample(1/1) switched to FINISHED
01/07/2017 16:23:48 RangePartition: GlobalSample(1/1) switched to RUNNING
01/07/2017 16:23:48 RangePartition: Histogram(1/1) switched to SCHEDULED
01/07/2017 16:23:48 RangePartition: Histogram(1/1) switched to DEPLOYING
01/07/2017 16:23:48 RangePartition: GlobalSample(1/1) switched to FINISHED
01/07/2017 16:23:48 RangePartition: Histogram(1/1) switched to RUNNING
01/07/2017 16:23:48 RangePartition: Histogram(1/1) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING
01/07/2017 16:23:48 RangePartition: PreparePartition(1/1) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(2/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(5/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(2/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(5/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(1/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(1/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(8/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(8/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(4/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(4/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(7/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(7/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(11/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(11/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(12/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(12/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(16/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(16/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(3/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(3/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(15/16) switched to SCHEDULED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(15/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(13/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(14/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(14/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(13/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(9/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(9/16) switched to DEPLOYING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(6/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(6/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(10/16) switched to SCHEDULED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(10/16) switched to DEPLOYING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(2/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(5/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(1/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(8/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(4/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(7/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(11/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(12/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(16/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(15/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(3/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(14/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(13/16) switched to RUNNING
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(9/16) switched to RUNNING
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(8/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(15/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(11/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(10/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(14/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(13/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(9/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(6/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(3/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(12/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(5/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(16/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(4/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(7/16) switched to FINISHED
01/07/2017 16:23:48 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(2/16) switched to FINISHED
01/07/2017 16:23:48 DataSink (org.apache.flink.api.java.Utils$***@6cae5b79)(1/16) switched to FINISHED
01/07/2017 16:23:48 Job execution switched to status FINISHED.
(7,100)
373179 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
- dsqDist(X)
Run completed in 6 minutes, 28 seconds.
Total number of tests run: 105
Suites: completed 11, aborted 0
Tests: succeeded 104, failed 1, canceled 0, ignored 1, pending 0
*** 1 TEST FAILED ***
[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.649 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 0.257 s]
[INFO] Mahout Math ........................................ SUCCESS [01:15 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 4.360 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:23 min]
[INFO] Mahout Integration ................................. SUCCESS [ 44.207 s]
[INFO] Mahout Examples .................................... SUCCESS [ 25.448 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:09 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:19 min]
[INFO] Mahout Flink bindings .............................. FAILURE [07:26 min]
[INFO] Mahout Spark bindings shell ........................ SKIPPED
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 29:53 min
[INFO] Finished at: 2017-01-07T16:23:49+00:00
[INFO] Final Memory: 65M/563M
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.scalatest:scalatest-maven-plugin:1.0:test (test) on project mahout-flink_2.10: There are test failures -> [Help 1]
[ERROR]
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR]
[ERROR] For more information about the errors and possible solutions, please read the following articles:
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoFailureException
[ERROR]
[ERROR] After correcting the problems, you can resume the build with the command
[ERROR] mvn <goals> -rf :mahout-flink_2.10
Build step 'Invoke top-level Maven targets' marked build as failure
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
Compressed 157.98 MB of artifacts by 87.5% relative to #3401
Recording test results
Publishing Javadoc
Updating MAHOUT-1901

[Apache Jenkins Server]

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