Apache Jenkins Server
2017-02-26 06:41:47 UTC
See <https://builds.apache.org/job/Mahout-Quality/3423/display/redirect?page=changes>
Changes:
[akm] Adding signing key to KEYS
------------------------------------------
[...truncated 22.54 MB...]
02/26/2017 06:41:22 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
02/26/2017 06:41:22 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
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to RUNNING
02/26/2017 06:41:22 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
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(12/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(11/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(10/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(9/16) switched to RUNNING
02/26/2017 06:41:22 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
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(7/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(5/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(9/16) switched to FINISHED
02/26/2017 06:41:22 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(8/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(10/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(12/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(11/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(6/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@23cf4320)(1/1) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@23cf4320)(1/1) switched to DEPLOYING
02/26/2017 06:41:22 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@23cf4320)(1/1) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@23cf4320)(1/1) switched to FINISHED
02/26/2017 06:41:22 Job execution switched to status FINISHED.
(100,100)
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#-906345210]
02/26/2017 06:41:22 Job execution switched to status RUNNING.
02/26/2017 06:41:22 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
02/26/2017 06:41:22 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
02/26/2017 06:41:22 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: LocalSample(1/1) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: LocalSample(1/1) switched to DEPLOYING
02/26/2017 06:41:22 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
02/26/2017 06:41:22 RangePartition: PreparePartition(1/1) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: PreparePartition(1/1) switched to DEPLOYING
02/26/2017 06:41:22 RangePartition: LocalSample(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: PreparePartition(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: GlobalSample(1/1) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: GlobalSample(1/1) switched to DEPLOYING
02/26/2017 06:41:22 RangePartition: LocalSample(1/1) switched to FINISHED
02/26/2017 06:41:22 RangePartition: GlobalSample(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: Histogram(1/1) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: Histogram(1/1) switched to DEPLOYING
02/26/2017 06:41:22 RangePartition: GlobalSample(1/1) switched to FINISHED
02/26/2017 06:41:22 RangePartition: Histogram(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: Histogram(1/1) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: PreparePartition(1/1) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(3/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(2/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(3/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(2/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(6/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(8/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(11/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(8/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(6/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(11/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(12/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(12/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(13/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(13/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(15/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(15/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(1/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(1/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(16/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(16/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(14/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(14/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(10/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(10/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(9/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(9/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(7/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(5/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(5/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(7/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(4/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(4/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(3/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(2/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(8/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(6/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(11/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(12/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(13/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(15/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(1/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(16/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(14/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(10/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(9/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(5/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(7/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(4/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(3/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(2/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(8/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(6/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(11/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(12/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(13/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(1/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(15/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(16/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(5/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(7/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(10/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(14/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(9/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(4/16) switched to FINISHED
02/26/2017 06:41:22 Job execution switched to status FINISHED.
(7,100)
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
519405 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
[32m- dsqDist(X)[0m
[36mRun completed in 8 minutes, 52 seconds.[0m
[36mTotal number of tests run: 111[0m
[36mSuites: completed 14, aborted 0[0m
[36mTests: succeeded 110, failed 1, canceled 0, ignored 1, pending 0[0m
[31m*** 1 TEST FAILED ***[0m
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Apache Mahout
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Mahout Build Tools
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO]
[INFO] Mahout Build Tools ................................. SUCCESS [ 3.106 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 2.813 s]
[INFO] Mahout Math ........................................ SUCCESS [01:10 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 5.186 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:13 min]
[INFO] Mahout Integration ................................. SUCCESS [ 49.874 s]
[INFO] Mahout Examples .................................... SUCCESS [ 25.034 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:13 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:50 min]
[INFO] Mahout Flink bindings .............................. FAILURE [09:40 min]
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 32:37 min
[INFO] Finished at: 2017-02-26T06:41:22+00:00
[INFO] Final Memory: 60M/561M
[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 176.06 MB of artifacts by 91.2% relative to #3418
Recording test results
Publishing Javadoc
Changes:
[akm] Adding signing key to KEYS
------------------------------------------
[...truncated 22.54 MB...]
02/26/2017 06:41:22 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
02/26/2017 06:41:22 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
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to RUNNING
02/26/2017 06:41:22 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
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(12/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(11/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(10/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(9/16) switched to RUNNING
02/26/2017 06:41:22 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
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(7/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(3/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(5/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(4/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(14/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(9/16) switched to FINISHED
02/26/2017 06:41:22 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to RUNNING
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(8/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(15/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(10/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(13/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(12/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(11/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(6/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(16/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@23cf4320)(1/1) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@23cf4320)(1/1) switched to DEPLOYING
02/26/2017 06:41:22 Reduce (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(1/1) switched to FINISHED
02/26/2017 06:41:22 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:395) (org.apache.flink.api.java.io.TypeSerializerInputFormat) -> Map (Map at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:79)) -> Combine (Reduce at org.apache.mahout.flinkbindings.drm.CheckpointedFlinkDrm.dim$lzycompute(CheckpointedFlinkDrm.scala:83))(2/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@23cf4320)(1/1) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@23cf4320)(1/1) switched to FINISHED
02/26/2017 06:41:22 Job execution switched to status FINISHED.
(100,100)
Connected to JobManager at Actor[akka://flink/user/jobmanager_1#-906345210]
02/26/2017 06:41:22 Job execution switched to status RUNNING.
02/26/2017 06:41:22 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED
02/26/2017 06:41:22 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING
02/26/2017 06:41:22 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: LocalSample(1/1) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: LocalSample(1/1) switched to DEPLOYING
02/26/2017 06:41:22 DataSource (at org.apache.mahout.flinkbindings.FlinkEngine$.parallelize(FlinkEngine.scala:273) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to FINISHED
02/26/2017 06:41:22 RangePartition: PreparePartition(1/1) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: PreparePartition(1/1) switched to DEPLOYING
02/26/2017 06:41:22 RangePartition: LocalSample(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: PreparePartition(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: GlobalSample(1/1) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: GlobalSample(1/1) switched to DEPLOYING
02/26/2017 06:41:22 RangePartition: LocalSample(1/1) switched to FINISHED
02/26/2017 06:41:22 RangePartition: GlobalSample(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: Histogram(1/1) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: Histogram(1/1) switched to DEPLOYING
02/26/2017 06:41:22 RangePartition: GlobalSample(1/1) switched to FINISHED
02/26/2017 06:41:22 RangePartition: Histogram(1/1) switched to RUNNING
02/26/2017 06:41:22 RangePartition: Histogram(1/1) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(1/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(2/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(3/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(4/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(2/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(5/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(6/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(7/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(3/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(6/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(8/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(9/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(8/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(11/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(10/16) switched to SCHEDULED
02/26/2017 06:41:22 RangePartition: PreparePartition(1/1) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(12/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(11/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(13/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(14/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(12/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(16/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(15/16) switched to SCHEDULED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(13/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(1/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(15/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(16/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(14/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(10/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(9/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(7/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(5/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(4/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(3/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(2/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(3/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(2/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(6/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(8/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(11/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(8/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(6/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(11/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(12/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(12/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(13/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(13/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(15/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(15/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(1/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(1/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(16/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(16/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(14/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(14/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(10/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(10/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(2/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(3/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(6/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(8/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(11/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(12/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(9/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(9/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(7/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(5/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(5/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(7/16) switched to DEPLOYING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(4/16) switched to SCHEDULED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(4/16) switched to DEPLOYING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(13/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(1/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(15/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(10/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(7/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(9/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(16/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(14/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(5/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(4/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(3/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(2/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(6/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(3/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(2/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(12/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(11/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(8/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(8/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(6/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(11/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(12/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(13/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(13/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(15/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(1/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(1/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(16/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(16/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(14/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(14/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(10/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(10/16) switched to RUNNING
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(9/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(9/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(5/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(5/16) switched to FINISHED
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(15/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(7/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(7/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(4/16) switched to RUNNING
02/26/2017 06:41:22 CHAIN RangePartition: Partition -> Partition(4/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(3/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(2/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(8/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(6/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(11/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(12/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(13/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(1/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(15/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(16/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(5/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(7/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(10/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(14/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(9/16) switched to FINISHED
02/26/2017 06:41:22 DataSink (org.apache.flink.api.java.Utils$***@791be4a4)(4/16) switched to FINISHED
02/26/2017 06:41:22 Job execution switched to status FINISHED.
(7,100)
[INFO] Creating org.apache.mahout.viennacl.opencl.GPUMMul solver
[WARN] Unable to create class GPUMMul: attempting OpenMP version
[INFO] Creating org.apache.mahout.viennacl.openmp.OMPMMul solver
org.apache.mahout.viennacl.openmp.OMPMMul$
[INFO] Unable to create class OMPMMul: falling back to java version
519405 [ScalaTest-main-running-DrmLikeOpsSuite] DEBUG org.apache.mahout.math.scalabindings.MMul$ - AAt computation detected.
[32m- dsqDist(X)[0m
[36mRun completed in 8 minutes, 52 seconds.[0m
[36mTotal number of tests run: 111[0m
[36mSuites: completed 14, aborted 0[0m
[36mTests: succeeded 110, failed 1, canceled 0, ignored 1, pending 0[0m
[31m*** 1 TEST FAILED ***[0m
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Apache Mahout
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Skipping Mahout Build Tools
[INFO] This project has been banned from the build due to previous failures.
[INFO] ------------------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] Reactor Summary:
[INFO]
[INFO] Mahout Build Tools ................................. SUCCESS [ 3.106 s]
[INFO] Apache Mahout ...................................... SUCCESS [ 2.813 s]
[INFO] Mahout Math ........................................ SUCCESS [01:10 min]
[INFO] Mahout HDFS ........................................ SUCCESS [ 5.186 s]
[INFO] Mahout Map-Reduce .................................. SUCCESS [12:13 min]
[INFO] Mahout Integration ................................. SUCCESS [ 49.874 s]
[INFO] Mahout Examples .................................... SUCCESS [ 25.034 s]
[INFO] Mahout Math Scala bindings ......................... SUCCESS [05:13 min]
[INFO] Mahout Spark bindings .............................. SUCCESS [02:50 min]
[INFO] Mahout Flink bindings .............................. FAILURE [09:40 min]
[INFO] Mahout Release Package ............................. SKIPPED
[INFO] Mahout H2O backend ................................. SKIPPED
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 32:37 min
[INFO] Finished at: 2017-02-26T06:41:22+00:00
[INFO] Final Memory: 60M/561M
[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 176.06 MB of artifacts by 91.2% relative to #3418
Recording test results
Publishing Javadoc