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

  • 相关阅读:
    【Android-音乐类】音友 免费下载、试听、全网最全的音乐 还不快来白嫖~
    数据结构 10 基础数据结构 二叉堆 堆排序算法详解
    数据结构 9 基础数据结构 二叉堆 了解二叉堆的元素插入、删除、构建二叉堆的代码方式
    数据结构 8 基础排序算法详解、快速排序的实现、了解分治法
    Jenkins+tomcat自动发布的热部署/重启及遇到的坑解决办法
    Spring笔记(3)
    多线程高并发编程(12) -- 阻塞算法实现ArrayBlockingQueue源码分析
    多线程高并发编程(11) -- 非阻塞算法实现ConcurrentLinkedQueue源码分析
    多线程高并发编程(10) -- ConcurrentHashMap源码分析
    Spring笔记(1)
  • 原文地址:https://www.cnblogs.com/Alcesttt/p/12380795.html
Copyright © 2011-2022 走看看