01/12/2016 18:55:32	Job execution switched to status RUNNING.
01/12/2016 18:55:32	CHAIN DataSource (at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:282) (org.apache.flink.api.scala.operators.ScalaCsvInputFormat)) -> Filter (Filter at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:282))(1/1) switched to SCHEDULED 
01/12/2016 18:55:32	CHAIN DataSource (at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:282) (org.apache.flink.api.scala.operators.ScalaCsvInputFormat)) -> Filter (Filter at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:282))(1/1) switched to DEPLOYING 
01/12/2016 18:55:32	CHAIN DataSource (at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:282) (org.apache.flink.api.scala.operators.ScalaCsvInputFormat)) -> Filter (Filter at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:282))(1/1) switched to RUNNING 
01/12/2016 18:55:32	Sort-Partition(1/1) switched to SCHEDULED 
01/12/2016 18:55:32	Sort-Partition(1/1) switched to DEPLOYING 
01/12/2016 18:55:32	Sort-Partition(1/1) switched to RUNNING 
01/12/2016 18:56:58	CHAIN DataSource (at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:282) (org.apache.flink.api.scala.operators.ScalaCsvInputFormat)) -> Filter (Filter at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:282))(1/1) switched to FINISHED 
01/12/2016 18:57:32	CHAIN GroupReduce (GroupReduce at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:283)) -> FlatMap (FlatMap at collect(DataSet.scala:542))(1/1) switched to SCHEDULED 
01/12/2016 18:57:32	CHAIN GroupReduce (GroupReduce at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:283)) -> FlatMap (FlatMap at collect(DataSet.scala:542))(1/1) switched to DEPLOYING 
01/12/2016 18:57:32	CHAIN GroupReduce (GroupReduce at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:283)) -> FlatMap (FlatMap at collect(DataSet.scala:542))(1/1) switched to RUNNING 
01/12/2016 18:58:38	Sort-Partition(1/1) switched to FINISHED 
01/12/2016 18:58:40	DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75c7ff93)(1/1) switched to SCHEDULED 
01/12/2016 18:58:40	DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75c7ff93)(1/1) switched to DEPLOYING 
01/12/2016 18:58:41	DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75c7ff93)(1/1) switched to RUNNING 
01/12/2016 18:58:41	DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@75c7ff93)(1/1) switched to FINISHED 
01/12/2016 18:58:44	CHAIN GroupReduce (GroupReduce at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:283)) -> FlatMap (FlatMap at collect(DataSet.scala:542))(1/1) switched to FINISHED 
01/12/2016 18:58:44	Job execution switched to status FINISHED.
01/12/2016 19:04:55	Job execution switched to status RUNNING.
01/12/2016 19:04:55	DataSource (at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:290) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to SCHEDULED 
01/12/2016 19:04:55	DataSource (at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:290) (org.apache.flink.api.java.io.CollectionInputFormat))(1/1) switched to DEPLOYING 
Exception in thread "main" org.apache.flink.runtime.client.JobTimeoutException: Timeout while waiting for JobManager answer. Job time exceeded 21474835 seconds
	at org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:137)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:411)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:397)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:389)
	at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:190)
	at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:87)
	at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:804)
	at org.apache.flink.api.scala.ExecutionEnvironment.execute(ExecutionEnvironment.scala:613)
	at org.apache.flink.api.scala.DataSet.collect(DataSet.scala:545)
	at hu.mta.sztaki.dms.Utils$.processDataSetWithoutTimeRandomSequence(Utils.scala:292)
	at hu.mta.sztaki.dms.EuclideanItemRecommenderTrainer$.main(EuclideanItemRecommenderTrainer.scala:181)
	at hu.mta.sztaki.dms.EuclideanItemRecommenderTrainer.main(EuclideanItemRecommenderTrainer.scala)
Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/$a#1408607275]] after [21474835000 ms]
	at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:333)
	at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117)
	at akka.actor.LightArrayRevolverScheduler$TaskHolder.run(Scheduler.scala:476)
	at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:282)
	at akka.actor.LightArrayRevolverScheduler$$anonfun$close$1.apply(Scheduler.scala:281)
	at scala.collection.Iterator$class.foreach(Iterator.scala:742)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1194)
	at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
	at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
	at akka.actor.LightArrayRevolverScheduler.close(Scheduler.scala:280)
	at akka.actor.ActorSystemImpl.stopScheduler(ActorSystem.scala:688)
	at akka.actor.ActorSystemImpl$$anonfun$liftedTree2$1$1.apply$mcV$sp(ActorSystem.scala:617)
	at akka.actor.ActorSystemImpl$$anonfun$liftedTree2$1$1.apply(ActorSystem.scala:617)
	at akka.actor.ActorSystemImpl$$anonfun$liftedTree2$1$1.apply(ActorSystem.scala:617)
	at akka.actor.ActorSystemImpl$$anon$3.run(ActorSystem.scala:641)
	at akka.actor.ActorSystemImpl$TerminationCallbacks$$anonfun$run$1.runNext$1(ActorSystem.scala:808)
	at akka.actor.ActorSystemImpl$TerminationCallbacks$$anonfun$run$1.apply$mcV$sp(ActorSystem.scala:811)
	at akka.actor.ActorSystemImpl$TerminationCallbacks$$anonfun$run$1.apply(ActorSystem.scala:804)
	at akka.actor.ActorSystemImpl$TerminationCallbacks$$anonfun$run$1.apply(ActorSystem.scala:804)
	at akka.util.ReentrantGuard.withGuard(LockUtil.scala:15)
	at akka.actor.ActorSystemImpl$TerminationCallbacks.run(ActorSystem.scala:804)
	at akka.actor.ActorSystemImpl$$anonfun$terminationCallbacks$1.apply(ActorSystem.scala:638)
	at akka.actor.ActorSystemImpl$$anonfun$terminationCallbacks$1.apply(ActorSystem.scala:638)
	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)
	at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67)
	at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82)
	at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59)
	at akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59)
	at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)
	at akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58)
	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
	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)