See <https://builds.apache.org/job/Mahout-Quality/3368/changes>
Changes:
[smarthi] Rolling back 0.12.2 Release candidate 2
------------------------------------------
[...truncated 136038 lines...]
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
281226 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(3/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(3/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281233 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(8/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(8/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281246 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(6/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(6/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281246 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(7/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(7/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281248 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(11/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(11/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281248 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(1/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(1/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281250 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(14/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(14/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281248 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(4/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(4/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281248 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(5/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(5/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281251 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(13/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(13/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281250 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(2/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(2/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281249 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(15/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(15/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281249 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(10/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(10/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281249 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(9/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(9/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
281248 [CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(12/16)] ERROR org.apache.flink.runtime.operators.BatchTask - Error in task
code: CHAIN DataSource (at
org.apache.flink.api.scala.ExecutionEnvironment.createInput(ExecutionEnvironment.scala:396)
(org.apache.flink.api.scala.hadoop.mapred.HadoopInputFo) -> Map (Map at
org.apache.mahout.flinkbindings.FlinkEngine$.drmDfsRead(FlinkEngine.scala:93))
(12/16)
java.lang.RuntimeException: Requesting the next InputSplit failed.
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:91)
at
org.apache.flink.runtime.operators.DataSourceTask$1.hasNext(DataSourceTask.java:342)
at
org.apache.flink.runtime.operators.DataSourceTask.invoke(DataSourceTask.java:137)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.util.concurrent.TimeoutException: Futures timed out after
[10000 milliseconds]
at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
at
scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
at
scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
at scala.concurrent.Await$.result(package.scala:107)
at scala.concurrent.Await.result(package.scala)
at
org.apache.flink.runtime.taskmanager.TaskInputSplitProvider.getNextInputSplit(TaskInputSplitProvider.java:71)
... 4 more
Build timed out (after 223 minutes). Marking the build as failed.
Build was aborted
[PMD] Skipping publisher since build result is FAILURE
[TASKS] Skipping publisher since build result is FAILURE
Archiving artifacts
Compressed 171.05 MB of artifacts by 86.9% relative to #3363
Recording test results
Publishing Javadoc
