flink认证报错了

源码节点 发布于 2020/07/09 16:52
阅读 167
收藏 0

flink.runtime.executiongraph.ExecutionGraph        - async wait operator -> Filter (1/2) (0a39cbf9cd7f69b8a68c031474c877e8) switched from CANCELING to CANCELED.
2020-07-09 16:54:14,065 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job job (7cf0cd15da61dd21cb193e5d9afd701f) switched from state FAILING to FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:110)
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:76)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:192)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:186)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:180)
    at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:484)
    at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:380)
    at sun.reflect.GeneratedMethodAccessor16.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:279)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:194)
    at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
    at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
    at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
    at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
    at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
    at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
    at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
    at akka.actor.ActorCell.invoke(ActorCell.scala:561)
    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
    at akka.dispatch.Mailbox.run(Mailbox.scala:225)
    at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
    at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.IllegalArgumentException: Can't get Kerberos realm
    at org.apache.hadoop.security.HadoopKerberosName.setConfiguration(HadoopKerberosName.java:65)
    at org.apache.hadoop.security.UserGroupInformation.initialize(UserGroupInformation.java:276)
    at org.apache.hadoop.security.UserGroupInformation.setConfiguration(UserGroupInformation.java:312)
    at com.rongan.realtime.util.HbaseMutilUtil.loginKerberos(HbaseMutilUtil.java:305)
    at com.rongan.realtime.DimHbaseAsyncFunction2.open(DimHbaseAsyncFunction2.scala:63)
    at org.apache.flink.streaming.api.scala.async.ScalaRichAsyncFunctionWrapper.open(ScalaRichAsyncFunctionWrapper.scala:44)
    at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
    at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
    at org.apache.flink.streaming.api.operators.async.AsyncWaitOperator.open(AsyncWaitOperator.java:151)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.initializeStateAndOpen(StreamTask.java:1007)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:454)
    at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:449)
    at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:461)
    at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707)
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:532)
    at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.reflect.InvocationTargetException
    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.hadoop.security.authentication.util.KerberosUtil.getDefaultRealm(KerberosUtil.java:84)
    at org.apache.hadoop.security.HadoopKerberosName.setConfiguration(HadoopKerberosName.java:63)
    ... 16 more
Caused by: KrbException: Cannot locate default realm
    at sun.security.krb5.Config.getDefaultRealm(Config.java:1029)
    ... 22 more
2020-07-09 16:54:14,066 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Stopping checkpoint coordinator for job 7cf0cd15da61dd21cb193e5d9afd701f.
2020-07-09 16:54:14,067 INFO  org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore  - Shutting down
2020-07-09 16:54:14,073 INFO  org.apache.flink.runtime.dispatcher.MiniDispatcher            - Job 7cf0cd15da61dd21cb193e5d9afd701f reached globally terminal state FAILED.
2020-07-09 16:54:14,074 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Stopping the JobMaster for job job(7cf0cd15da61dd21cb193e5d9afd701f).
2020-07-09 16:54:14,076 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Shutting YarnJobClusterEntrypoint down with application status FAILED. Diagnostics null.
2020-07-09 16:54:14,076 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - Shutting down rest endpoint.
2020-07-09 16:54:14,076 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Suspending SlotPool.
2020-07-09 16:54:14,076 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Close ResourceManager connection c5e12a239e25c2b82d20a8983eb956bd: JobManager is shutting down..
2020-07-09 16:54:14,076 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Stopping SlotPool.
2020-07-09 16:54:14,077 INFO  org.apache.flink.yarn.YarnResourceManager                     - Disconnect job manager 00000000000000000000000000000000@akka.tcp://flink@slave4:44402/user/jobmanager_0 for job 7cf0cd15da61dd21cb193e5d9afd701f from the resource manager.
2020-07-09 16:54:14,079 INFO  org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl       - JobManagerRunner already shutdown.
2020-07-09 16:54:14,103 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - Removing cache directory /tmp/flink-web-f0333d43-c5eb-46a5-bef1-eab3f6d61661/flink-web-ui
2020-07-09 16:54:14,104 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - http://slave4:37625 lost leadership
2020-07-09 16:54:14,104 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - Shut down complete.
2020-07-09 16:54:14,105 INFO  org.apache.flink.yarn.YarnResourceManager                     - Shut down cluster because application is in FAILED, diagnostics null.
2020-07-09 16:54:14,106 INFO  org.apache.flink.yarn.YarnResourceManager                     - Unregister application from the YARN Resource Manager with final status FAILED.
2020-07-09 16:54:14,110 INFO  org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl         - Waiting for application to be successfully unregistered.
2020-07-09 16:54:14,260 INFO  org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent  - Closing components.
2020-07-09 16:54:14,261 INFO  org.apache.flink.runtime.dispatcher.runner.JobDispatcherLeaderProcess  - Stopping JobDispatcherLeaderProcess.
2020-07-09 16:54:14,261 INFO  org.apache.flink.runtime.dispatcher.MiniDispatcher            - Stopping dispatcher akka.tcp://flink@slave4:44402/user/dispatcher.
2020-07-09 16:54:14,261 INFO  org.apache.flink.runtime.dispatcher.MiniDispatcher            - Stopping all currently running jobs of dispatcher akka.tcp://flink@slave4:44402/user/dispatcher.
2020-07-09 16:54:14,261 INFO  org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl  - Interrupted while waiting for queue
java.lang.InterruptedException
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
    at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
    at org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl$CallbackHandlerThread.run(AMRMClientAsyncImpl.java:287)
2020-07-09 16:54:14,262 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - Opening proxy : slave4:8041
2020-07-09 16:54:14,262 INFO  org.apache.flink.runtime.rest.handler.legacy.backpressure.BackP

加载中
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部