See <https://builds.apache.org/job/Mahout-Quality/3373/changes>
Changes:
[smarthi] [maven-release-plugin] prepare release mahout-0.12.2
[smarthi] Rolling back Mahout 0.12.2 Release candidate, thanks github
connectivity
[smarthi] [maven-release-plugin] rollback the release of mahout-0.12.2
[smarthi] [maven-release-plugin] prepare release mahout-0.12.2
[smarthi] [maven-release-plugin] prepare for next development iteration
[smarthi] Rolling back Mahout 0.12.2 Release candidate, thanks github
connectivity
[smarthi] [maven-release-plugin] prepare release mahout-0.12.2
[smarthi] [maven-release-plugin] prepare for next development iteration
[smarthi] Rolling back Mahout 0.12.2 Release candidate, thanks github
connectivity
[smarthi] [maven-release-plugin] prepare release mahout-0.12.2
[smarthi] [maven-release-plugin] rollback the release of mahout-0.12.2
------------------------------------------
[...truncated 55412 lines...]
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(1/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(4/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(4/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(13/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(9/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(13/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(5/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(9/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(11/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(5/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(11/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(7/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(14/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(2/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(14/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(2/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(6/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(3/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(10/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(3/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(10/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(8/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(8/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(6/16) switched to
DEPLOYING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(7/16) switched to
DEPLOYING
06/11/2016 23:03:16 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:75))(14/16)
switched to FINISHED
06/11/2016 23:03:16 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:75))(1/16)
switched to FINISHED
06/11/2016 23:03:16 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:75))(10/16)
switched to FINISHED
06/11/2016 23:03:16 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:75))(3/16)
switched to FINISHED
06/11/2016 23:03:16 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:75))(4/16)
switched to FINISHED
Exception in thread "ForkJoinPool-898-worker-17" java.lang.OutOfMemoryError:
unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
at
scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2037)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 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:75))(9/16)
switched to FINISHED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(15/16) switched to
SCHEDULED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(15/16) switched to
DEPLOYING
Exception in thread "ForkJoinPool-898-worker-7" java.lang.OutOfMemoryError:
unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
at
scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2037)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 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:75))(15/16)
switched to FINISHED
Exception in thread "ForkJoinPool-898-worker-29" java.lang.OutOfMemoryError:
unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
at
scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2037)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Exception in thread "ForkJoinPool-898-worker-21" java.lang.OutOfMemoryError:
unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
scala.concurrent.forkjoin.ForkJoinPool.tryAddWorker(ForkJoinPool.java:1672)
at
scala.concurrent.forkjoin.ForkJoinPool.signalWork(ForkJoinPool.java:1966)
at scala.concurrent.forkjoin.ForkJoinPool.scan(ForkJoinPool.java:2037)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 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:75))(6/16)
switched to FINISHED
06/11/2016 23:03:16 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:75))(2/16)
switched to FINISHED
06/11/2016 23:03:16 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:75))(11/16)
switched to FINISHED
06/11/2016 23:03:16 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:75))(5/16)
switched to FINISHED
06/11/2016 23:03:16 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:75))(7/16)
switched to FINISHED
259395 [flink-akka.actor.default-dispatcher-8] ERROR
org.apache.flink.runtime.taskmanager.TaskManager - SubmitTask failed
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
org.apache.flink.runtime.taskmanager.Task.startTaskThread(Task.java:401)
at
org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.scala:1043)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$handleTaskMessage(TaskManager.scala:411)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$handleMessage$1.applyOrElse(TaskManager.scala:265)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
at
org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at
org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:119)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(3/16) switched to
FAILED
java.lang.Exception: Failed to deploy the task to slot SimpleSlot (5)(1) -
a2c5d8333c3e7bdd7dd75e2211837f1c @ localhost - 16 slots - URL:
akka://flink/user/taskmanager_1 - ALLOCATED/ALIVE: Response was not of type
Acknowledge
at
org.apache.flink.runtime.executiongraph.Execution$2.onComplete(Execution.java:395)
at akka.dispatch.OnComplete.internal(Future.scala:247)
at akka.dispatch.OnComplete.internal(Future.scala:244)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:174)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:171)
at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
at
scala.concurrent.impl.ExecutionContextImpl$$anon$3.exec(ExecutionContextImpl.scala:107)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 Job execution switched to status FAILING.
java.lang.Exception: Failed to deploy the task to slot SimpleSlot (5)(1) -
a2c5d8333c3e7bdd7dd75e2211837f1c @ localhost - 16 slots - URL:
akka://flink/user/taskmanager_1 - ALLOCATED/ALIVE: Response was not of type
Acknowledge
at
org.apache.flink.runtime.executiongraph.Execution$2.onComplete(Execution.java:395)
at akka.dispatch.OnComplete.internal(Future.scala:247)
at akka.dispatch.OnComplete.internal(Future.scala:244)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:174)
at akka.dispatch.japi$CallbackBridge.apply(Future.scala:171)
at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
at
scala.concurrent.impl.ExecutionContextImpl$$anon$3.exec(ExecutionContextImpl.scala:107)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 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:75))(8/16)
switched to CANCELING
06/11/2016 23:03:16 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:75))(12/16)
switched to CANCELING
06/11/2016 23:03:16 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:75))(13/16)
switched to CANCELING
06/11/2016 23:03:16 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:75))(16/16)
switched to CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(1/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(2/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(4/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(5/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(6/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(7/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(8/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(9/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(10/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(11/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(12/16) switched to
CANCELED
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(13/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(14/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(15/16) switched to
CANCELING
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(16/16) switched to
CANCELED
259400 [flink-akka.actor.default-dispatcher-8] ERROR
org.apache.flink.runtime.taskmanager.TaskManager - SubmitTask failed
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
org.apache.flink.runtime.taskmanager.Task.startTaskThread(Task.java:401)
at
org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.scala:1043)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$handleTaskMessage(TaskManager.scala:411)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$handleMessage$1.applyOrElse(TaskManager.scala:265)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
at
org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at
org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:119)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(7/16) switched to
CANCELED
259400 [flink-akka.actor.default-dispatcher-8] ERROR
org.apache.flink.runtime.taskmanager.TaskManager - SubmitTask failed
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
org.apache.flink.runtime.taskmanager.Task.startTaskThread(Task.java:401)
at
org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.scala:1043)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$handleTaskMessage(TaskManager.scala:411)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$handleMessage$1.applyOrElse(TaskManager.scala:265)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
at
org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at
org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:119)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(2/16) switched to
CANCELED
259401 [flink-akka.actor.default-dispatcher-8] ERROR
org.apache.flink.runtime.taskmanager.TaskManager - SubmitTask failed
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at
org.apache.flink.runtime.taskmanager.Task.startTaskThread(Task.java:401)
at
org.apache.flink.runtime.taskmanager.TaskManager.submitTask(TaskManager.scala:1043)
at
org.apache.flink.runtime.taskmanager.TaskManager.org$apache$flink$runtime$taskmanager$TaskManager$$handleTaskMessage(TaskManager.scala:411)
at
org.apache.flink.runtime.taskmanager.TaskManager$$anonfun$handleMessage$1.applyOrElse(TaskManager.scala:265)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:36)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
at
scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
at
org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
at
org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
at
org.apache.flink.runtime.taskmanager.TaskManager.aroundReceive(TaskManager.scala:119)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
at akka.actor.ActorCell.invoke(ActorCell.scala:487)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
at akka.dispatch.Mailbox.run(Mailbox.scala:221)
at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
at
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
at
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06/11/2016 23:03:16 DataSink
(org.apache.flink.api.java.Utils$CollectHelper@66501fcd)(15/16) switched to
CANCELED
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
