Created
February 14, 2018 21:59
-
-
Save jkff/9fb07e470f81b558e38b1bccfe2e4a99 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
| The program finished with the following exception: | |
| org.apache.flink.client.program.ProgramInvocationException: The main method caused an error. | |
| at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:545) | |
| at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:419) | |
| at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:381) | |
| at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:838) | |
| at org.apache.flink.client.CliFrontend.run(CliFrontend.java:259) | |
| at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1086) | |
| at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1133) | |
| at org.apache.flink.client.CliFrontend$2.call(CliFrontend.java:1130) | |
| at org.apache.flink.runtime.security.HadoopSecurityContext$1.run(HadoopSecurityContext.java:43) | |
| at java.security.AccessController.doPrivileged(Native Method) | |
| at javax.security.auth.Subject.doAs(Subject.java:422) | |
| at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836) | |
| at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40) | |
| at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1130) | |
| Caused by: java.lang.RuntimeException: Pipeline execution failed | |
| at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:118) | |
| at org.apache.beam.sdk.Pipeline.run(Pipeline.java:311) | |
| at org.apache.beam.sdk.Pipeline.run(Pipeline.java:297) | |
| at org.apache.beam.examples.WordCount.main(WordCount.java:187) | |
| at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) | |
| at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) | |
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
| at java.lang.reflect.Method.invoke(Method.java:498) | |
| at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528) | |
| ... 13 more | |
| Caused by: java.lang.RuntimeException: Unable to get ClusterClient status from Application Client | |
| at org.apache.flink.yarn.YarnClusterClient.getClusterStatus(YarnClusterClient.java:243) | |
| at org.apache.flink.yarn.YarnClusterClient.waitForClusterToBeReady(YarnClusterClient.java:507) | |
| at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:454) | |
| at org.apache.flink.yarn.YarnClusterClient.submitJob(YarnClusterClient.java:205) | |
| at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:442) | |
| at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:429) | |
| at org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:62) | |
| at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.executePipeline(FlinkPipelineExecutionEnvironment.java:124) | |
| at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:115) | |
| ... 21 more | |
| Caused by: org.apache.flink.util.FlinkException: Could not start the ActorSystem lazily. | |
| at org.apache.flink.client.program.ClusterClient$LazyActorSystemLoader.get(ClusterClient.java:230) | |
| at org.apache.flink.client.program.ClusterClient.getJobManagerGateway(ClusterClient.java:786) | |
| at org.apache.flink.yarn.YarnClusterClient.getClusterStatus(YarnClusterClient.java:238) | |
| ... 29 more | |
| Caused by: com.typesafe.config.ConfigException$UnresolvedSubstitution: reference.conf: 804: Could not resolve substitution to a value: ${akka.stream.materializer} | |
| at com.typesafe.config.impl.ConfigReference.resolveSubstitutions(ConfigReference.java:87) | |
| at com.typesafe.config.impl.ResolveSource.resolveCheckingReplacement(ResolveSource.java:110) | |
| at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:114) | |
| at com.typesafe.config.impl.SimpleConfigObject$1.modifyChildMayThrow(SimpleConfigObject.java:341) | |
| at com.typesafe.config.impl.SimpleConfigObject.modifyMayThrow(SimpleConfigObject.java:280) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:321) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:25) | |
| at com.typesafe.config.impl.ResolveSource.resolveCheckingReplacement(ResolveSource.java:110) | |
| at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:114) | |
| at com.typesafe.config.impl.SimpleConfigObject$1.modifyChildMayThrow(SimpleConfigObject.java:341) | |
| at com.typesafe.config.impl.SimpleConfigObject.modifyMayThrow(SimpleConfigObject.java:280) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:321) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:25) | |
| at com.typesafe.config.impl.ResolveSource.resolveCheckingReplacement(ResolveSource.java:110) | |
| at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:114) | |
| at com.typesafe.config.impl.SimpleConfigObject$1.modifyChildMayThrow(SimpleConfigObject.java:341) | |
| at com.typesafe.config.impl.SimpleConfigObject.modifyMayThrow(SimpleConfigObject.java:280) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:321) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:25) | |
| at com.typesafe.config.impl.ResolveSource.resolveCheckingReplacement(ResolveSource.java:110) | |
| at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:114) | |
| at com.typesafe.config.impl.SimpleConfigObject$1.modifyChildMayThrow(SimpleConfigObject.java:341) | |
| at com.typesafe.config.impl.SimpleConfigObject.modifyMayThrow(SimpleConfigObject.java:280) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:321) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:25) | |
| at com.typesafe.config.impl.ResolveSource.resolveCheckingReplacement(ResolveSource.java:110) | |
| at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:114) | |
| at com.typesafe.config.impl.SimpleConfigObject$1.modifyChildMayThrow(SimpleConfigObject.java:341) | |
| at com.typesafe.config.impl.SimpleConfigObject.modifyMayThrow(SimpleConfigObject.java:280) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:321) | |
| at com.typesafe.config.impl.SimpleConfigObject.resolveSubstitutions(SimpleConfigObject.java:25) | |
| at com.typesafe.config.impl.ResolveSource.resolveCheckingReplacement(ResolveSource.java:110) | |
| at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:114) | |
| at com.typesafe.config.impl.ResolveContext.resolve(ResolveContext.java:149) | |
| at com.typesafe.config.impl.SimpleConfig.resolveWith(SimpleConfig.java:70) | |
| at com.typesafe.config.impl.SimpleConfig.resolve(SimpleConfig.java:60) | |
| at com.typesafe.config.impl.SimpleConfig.resolve(SimpleConfig.java:55) | |
| at com.typesafe.config.impl.SimpleConfig.resolve(SimpleConfig.java:33) | |
| at com.typesafe.config.impl.ConfigImpl$1.call(ConfigImpl.java:372) | |
| at com.typesafe.config.impl.ConfigImpl$1.call(ConfigImpl.java:365) | |
| at com.typesafe.config.impl.ConfigImpl$LoaderCache.getOrElseUpdate(ConfigImpl.java:58) | |
| at com.typesafe.config.impl.ConfigImpl.computeCachedConfig(ConfigImpl.java:86) | |
| at com.typesafe.config.impl.ConfigImpl.defaultReference(ConfigImpl.java:365) | |
| at com.typesafe.config.ConfigFactory.defaultReference(ConfigFactory.java:423) | |
| at akka.actor.ActorSystem$Settings.<init>(ActorSystem.scala:160) | |
| at akka.actor.ActorSystemImpl.<init>(ActorSystem.scala:505) | |
| at akka.actor.ActorSystem$.apply(ActorSystem.scala:142) | |
| at akka.actor.ActorSystem$.apply(ActorSystem.scala:119) | |
| at akka.actor.ActorSystem$.create(ActorSystem.scala:67) | |
| at org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:104) | |
| at org.apache.flink.runtime.akka.AkkaUtils$.createActorSystem(AkkaUtils.scala:92) | |
| at org.apache.flink.runtime.akka.AkkaUtils.createActorSystem(AkkaUtils.scala) | |
| at org.apache.flink.client.program.ClusterClient$LazyActorSystemLoader.get(ClusterClient.java:226) | |
| ... 31 more | |
| 2018-02-14 21:50:54,252 INFO org.apache.flink.yarn.YarnClusterClient - Disconnecting YarnClusterClient from ApplicationMaster |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment