zoukankan      html  css  js  c++  java
  • flink1.7报错:akka.pattern.AskTimeoutException: Ask timed out on

    问题描述

    flink能正常启动,但是启动任务就失败,哪怕启动examples下面的示例程序也是报错

    报错内容

    akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher#-738694886]] after [10000 ms]. Sender[null] sent message of type "org.apache.flink.runtime.rpc.messages.LocalFencedMessage".
    	at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:604)
    	at akka.actor.Scheduler$$anon$4.run(Scheduler.scala:126)
    	at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601)
    	at scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109)
    	at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599)
    	at akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:329)
    	at akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:280)
    	at akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:284)
    	at akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:236)
    	at java.lang.Thread.run(Thread.java:745)
    2020-02-28 21:54:11,924 ERROR org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler  - Could not retrieve the redirect address.
    java.util.concurrent.CompletionException: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher#-738694886]] after [10000 ms]. Sender[null] sent message of type "org.apache.flink.runtime.rpc.messages.LocalFencedMessage".
    	at java.util.concurrent.CompletableFuture.internalComplete(CompletableFuture.java:205)
    	at java.util.concurrent.CompletableFuture$ThenApply.run(CompletableFuture.java:723)
    	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:193)
    	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2361)
    	at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:772)
    	at akka.dispatch.OnComplete.internal(Future.scala:258)
    	at akka.dispatch.OnComplete.internal(Future.scala:256)
    	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:186)
    	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:183)
    	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)
    	at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:83)
    	at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)
    	at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)
    	at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:603)
    	at akka.actor.Scheduler$$anon$4.run(Scheduler.scala:126)
    	at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601)
    	at scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109)
    	at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599)
    	at akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:329)
    	at akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:280)
    	at akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:284)
    	at akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:236)
    	at java.lang.Thread.run(Thread.java:745)
    Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher#-738694886]] after [10000 ms]. Sender[null] sent message of type "org.apache.flink.runtime.rpc.messages.LocalFencedMessage".
    	at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:604)
    	... 9 more
    2020-02-28 21:54:12,904 ERROR org.apache.flink.runtime.rest.handler.cluster.ClusterOverviewHandler  - Could not retrieve the redirect address.

     

    解决:

    原因是jdk版本和flink版本有冲突

    我用的jdk版本是1.8.0_11,flink 1.7

    把jdk换成更高的版本,再重启集群即可

    我现在用的jdk版本是1.8.0_202

  • 相关阅读:
    HDU 1025 Constructing Roads In JGShining's Kingdom (DP+二分)
    HDU 1158 Employment Planning
    HDU 2059 龟兔赛跑
    Csharp 简单操作Word模板文件
    Csharp windowform datagridview Clipboard TO EXCEL OR FROM EXCEL DATA 保存datagridview所有數據
    Csharp 讀寫文件內容搜索自動彈出 AutoCompleteMode
    Csharp windowform controls clear
    CSS DIV大图片右上角叠加小图片
    Csharp DataGridView自定义添加DateTimePicker控件日期列
    Csharp 打印Word文件默認打印機或選擇打印機設置代碼
  • 原文地址:https://www.cnblogs.com/Alcesttt/p/12380795.html
Copyright © 2011-2022 走看看