Created
February 26, 2018 05:49
-
-
Save casidiablo/6bc718270ab9cedfd825c075f68a86d0 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Logged in as: dr.who | |
Application | |
About | |
Jobs | |
Tools | |
Log Type: jobmanager.err | |
Log Upload Time: Mon Feb 26 01:33:44 +0000 2018 | |
Log Length: 5691 | |
Showing 4096 bytes of 5691 total. Click here for the full log. | |
xyDesc(ObjectInputStream.java:1847) | |
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1744) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2032) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566) | |
at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1965) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1560) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2277) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2201) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2059) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566) | |
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2277) | |
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2201) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2059) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566) | |
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:426) | |
at akka.serialization.JavaSerializer$$anonfun$1.apply(Serializer.scala:136) | |
at scala.util.DynamicVariable.withValue(DynamicVariable.scala:58) | |
at akka.serialization.JavaSerializer.fromBinary(Serializer.scala:136) | |
at akka.serialization.Serialization$$anonfun$deserialize$1.apply(Serialization.scala:104) | |
at scala.util.Try$.apply(Try.scala:192) | |
at akka.serialization.Serialization.deserialize(Serialization.scala:98) | |
at akka.remote.MessageSerializer$.deserialize(MessageSerializer.scala:23) | |
at akka.remote.DefaultMessageDispatcher.payload$lzycompute$1(Endpoint.scala:58) | |
Uncaught error from thread [flink-akka.remote.default-remote-dispatcher-6] shutting down JVM since 'akka.jvm-exit-on-fatal-error' is enabled for ActorSystem[flink] | |
java.lang.OutOfMemoryError: GC overhead limit exceeded | |
at java.util.Arrays.copyOfRange(Arrays.java:3664) | |
at java.lang.String.<init>(String.java:207) | |
at java.lang.StringBuilder.toString(StringBuilder.java:407) | |
at java.io.ObjectInputStream$BlockDataInputStream.readUTFBody(ObjectInputStream.java:3420) | |
at java.io.ObjectInputStream$BlockDataInputStream.readUTF(ObjectInputStream.java:3215) | |
at java.io.ObjectInputStream.readUTF(ObjectInputStream.java:1128) | |
at java.io.ObjectStreamClass.readNonProxy(ObjectStreamClass.java:756) | |
at java.io.ObjectInputStream.readClassDescriptor(ObjectInputStream.java:886) | |
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1847) | |
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1744) | |
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2032) | |
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1566) | |
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:426) | |
at akka.serialization.JavaSerializer$$anonfun$1.apply(Serializer.scala:136) | |
at scala.util.DynamicVariable.withValue(DynamicVariable.scala:58) | |
at akka.serialization.JavaSerializer.fromBinary(Serializer.scala:136) | |
at akka.serialization.Serialization$$anonfun$deserialize$1.apply(Serialization.scala:104) | |
at scala.util.Try$.apply(Try.scala:192) | |
at akka.serialization.Serialization.deserialize(Serialization.scala:98) | |
at akka.remote.MessageSerializer$.deserialize(MessageSerializer.scala:23) | |
at akka.remote.DefaultMessageDispatcher.payload$lzycompute$1(Endpoint.scala:58) | |
at akka.remote.DefaultMessageDispatcher.payload$1(Endpoint.scala:58) | |
at akka.remote.DefaultMessageDispatcher.dispatch(Endpoint.scala:76) | |
at akka.remote.EndpointReader$$anonfun$receive$2.applyOrElse(Endpoint.scala:967) | |
at akka.actor.Actor$class.aroundReceive(Actor.scala:467) | |
at akka.remote.EndpointActor.aroundReceive(Endpoint.scala:437) | |
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) | |
at akka.actor.ActorCell.invoke(ActorCell.scala:487) | |
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) | |
at akka.dispatch.Mailbox.run(Mailbox.scala:220) | |
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) | |
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
Log Type: jobmanager.log | |
Log Upload Time: Mon Feb 26 01:33:44 +0000 2018 | |
Log Length: 206190349 | |
Showing 4096 bytes of 206190349 total. Click here for the full log. | |
11) | |
at java.util.concurrent.FutureTask.run(FutureTask.java:266) | |
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) | |
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) | |
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
at java.lang.Thread.run(Thread.java:748) | |
Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@ip-10-0-42-138:35775/user/taskmanager#-1975886233]] after [10000 ms] | |
at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:334) | |
at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117) | |
at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:599) | |
at scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109) | |
at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:597) | |
at akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(Scheduler.scala:474) | |
at akka.actor.LightArrayRevolverScheduler$$anon$8.executeBucket$1(Scheduler.scala:425) | |
at akka.actor.LightArrayRevolverScheduler$$anon$8.nextTick(Scheduler.scala:429) | |
at akka.actor.LightArrayRevolverScheduler$$anon$8.run(Scheduler.scala:381) | |
... 1 more | |
2018-02-26 01:33:41,284 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: titan-enriched (14/15) (5c3ebd0bf9b39fca490d3affb30d006b) switched from DEPLOYING to FAILED. | |
java.lang.Exception: Cannot deploy task Source: titan-enriched (14/15) (5c3ebd0bf9b39fca490d3affb30d006b) - TaskManager (container_1519541017643_0003_01_000013 @ ip-10-0-42-223.ec2.internal (dataPort=43051)) not responding after a timeout of 10000 ms | |
at org.apache.flink.runtime.executiongraph.Execution$2.apply(Execution.java:437) | |
at org.apache.flink.runtime.executiongraph.Execution$2.apply(Execution.java:429) | |
at org.apache.flink.runtime.concurrent.impl.FlinkFuture$3.recover(FlinkFuture.java:201) | |
at akka.dispatch.Recover.internal(Future.scala:268) | |
at akka.dispatch.japi$RecoverBridge.apply(Future.scala:184) | |
at akka.dispatch.japi$RecoverBridge.apply(Future.scala:182) | |
at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:216) | |
at scala.util.Try$.apply(Try.scala:192) | |
at scala.util.Failure.recover(Try.scala:216) | |
at scala.concurrent.Future$$anonfun$recover$1.apply(Future.scala:324) | |
at scala.concurrent.Future$$anonfun$recover$1.apply(Future.scala:324) | |
at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) | |
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) | |
at java.util.concurrent.FutureTask.run(FutureTask.java:266) | |
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) | |
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) | |
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
at java.lang.Thread.run(Thread.java:748) | |
Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@ip-10-0-42-223:45621/user/taskmanager#-561296728]] after [10000 ms] | |
at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:334) | |
at akka.actor.Scheduler$$anon$7.run(Scheduler.scala:117) | |
at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:599) | |
at scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109) | |
at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:597) | |
at akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(Scheduler.scala:474) | |
at akka.actor.LightArrayRevolverScheduler$$anon$8.executeBucket$1(Scheduler.scala:425) | |
at akka.actor.LightArrayRevolverScheduler$$anon$8.nextTick(Scheduler.scala:429) | |
at akka.actor.LightArrayRevolverScheduler$$anon$8.run(Scheduler.scala:381) | |
... 1 more | |
Log Type: jobmanager.out | |
Log Upload Time: Mon Feb 26 01:33:44 +0000 2018 | |
Log Length: 0 | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment