我正在设置一个使用ZooKeeper和3个TaskManagers的JobManager HA集群。我在kubernetes中这样做，并且需要JM通过全主机名(hostname -f而不是hostname)来寻址to，因为它们是在有状态集中。- Association with remote system [akka.tcp://flink-metrics@flink-taskmanager-Reason: [Association failed with [akka
浏览 141提问于2019-04-13得票数 0
我们使用的是1.14.3版本的flink，当我们试图运行作业经理时，我们得到的是异常。我尝试在flink- with . file文件中输入akka.remote.netty.tcp.hostname = "127.0.0.1“，甚至用主机名更新IP。但帮不上忙。[flink-akka.actor.default-dispatcher-5]
ERROR akka.remote.transport.netty.NettyTransport -
浏览 28提问于2022-02-02得票数 0
我试图创建简单的多节点flink集群(1主1从)。当我使用“.bin/ start -cluster.sh”启动集群时，作业管理器和任务管理器都会启动，但是任务管理器无法在作业管理器注册。有关环境的详细情况：
任务管理器主
浏览 1提问于2019-06-25得票数 2
回答已采纳
我是apache-flink的新手，我需要处理一些来自akka本地分车的数据，这些数据正在流到'ws://localhost:9000/ws‘例：如何将套接字指定为
浏览 0提问于2019-04-19得票数 0
回答已采纳
我们正在尝试做的事情，：我们正在评估Flink，以便使用执行批处理。BATCH模式的具体说明：
at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
at org.apache.flink.runtime.rpc.<e
浏览 39提问于2021-07-13得票数 1
回答已采纳
我在玩Akka遥控器。一个使用Akka 2.5.23的简单示例运行良好。at akka.serialization.Serialization.serializationInformation(Serialization.scala:166)
at akka.serialization.Serialization.akkaakka.remote.EndpointReader$$anonfun$receive$2.applyOrElse(Endpoint.scal
浏览 112提问于2019-06-30得票数 1
at org.apache.flink.streaming.api.graph.StreamConfig.getOutEdgesInOrder(StreamConfig.java:470) ~[flink-distat org.apache.flink.runtime.taskmanager.Task.loadAndInstantiateInvokable(Task.java:1373) [flink-dist__2.12-1.12.0.jar:1.12.0]
at org.<e
浏览 348提问于2020-12-30得票数 0
我已经对它进行了修改，只需从一个主题读取数据并写入另一个主题。我使用了以下属性： properties.put("topic", "test");at org.apache.flink.runtime.rpc.akka.AkkaRpcAc
浏览 25提问于2021-08-19得票数 0
回答已采纳
我试图运行一个简单的flink流作业的AWS EMR。就目前而言，目的很简单：scalaVersion := "2.11.8" "org.apache.flink"org.apache.flink"
浏览 5提问于2020-10-21得票数 0
回答已采纳
我试图在kubernetes环境中运行Flink作业集群(1.8.1)。我使用用Job创建了停靠映像。
按照创建作业、职务管理器和任务管理器。问题是任务管理器无法连接到职务经理并继续崩溃。recipient [Actor[akka.tcp://flink@flink-job-cluster:6123/]] arriving at [akka.tcp://flink@flink-job-cluster:6
浏览 0提问于2019-07-16得票数 0
当我尝试将数据写入另一个主题时，我能够读取数据并对其进行处理。它会给出错误 如果我尝试按原样写入数据，而不对其进行任何处理。卡夫卡制片人SimpleStringSchema接受了它。使用Json，然后以字符串格式将其写入另一个主题。(AkkaRpcActor.java:305) at org.apache
浏览 241提问于2021-09-13得票数 0
回答已采纳
$Record cannot be cast to java.lang.String at org.apache.flink.runtim
浏览 233提问于2021-05-04得票数 0
回答已采纳
1回答
我正在尝试对我的flink应用程序进行集成测试。473) at org.apache.flink.runtime.taskmanager.Task.run473)
at org.apache.flink.streaming.runtime.tasks.StreamT
浏览 0提问于2018-10-16得票数 0
我按照的指示设置会话模式flink集群，如“启动Kubernetes集群(会话模式)”一节中使用以下命令：$ kubectl$17(TaskExecutor.java:1434) ~[flink-dist_2.12-1.14.3.jar:1.14.3]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda:68) ~[flink</e
浏览 15提问于2022-02-28得票数 0
我在本地运行了，以便使用kinesis进行一些开发。该服务通过localhost:4568公开，我可以使用aws cli与其进行交互。DelegatingMethodAccessorImpl.java:43) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:28
浏览 0提问于2020-06-17得票数 0
//repo.maven.apache.org/maven2/org/apache/flink/flink-csv/${FLINK_VERSION}/flink-csv-${FLINK_VERSION}/ https://repo.maven.apache.org/maven2/org/apach
浏览 670提问于2021-02-01得票数 0
回答已采纳
我正在尝试设置由2个主节点和1个工作节点组成的Apache Flink独立集群。使用Flink 1.6和Zookeeper。要启动和停止cluster，我使用了Flink的1.6文档中描述的过程，即，要启动cluster，我运行start-zookeeper-quorum.sh，然后运行start-cluster.sh，然后运行:158)
at org.apache.flink.runtime.rpc.akka.Fen
浏览 24提问于2018-09-07得票数 0
使用以下命令启动单个实例(只有一台计算机)：
import org.apache.flink.api.scala当我尝试使用“->”从Intellij Flink Server远程连接时，它总是因为某种原因而失败。:199)
at org.apache.flink</
浏览 3提问于2020-08-05得票数 0
回答已采纳
1回答
我正在使用Flink 1.11使用，但在启动应用程序时出现了以下错误： at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at org.apache.flink.runtime.rpc.akka.Akk
浏览 4提问于2021-12-28得票数 0
1回答
我正试图在使用几天前的1.0.0-rc3的按作业纱线会话的上下文中工作JobManager HA，并且遇到了与多个网络接口的任务管理器有关的问题。[Anchor(akka.tcp://flink@10.127.68.136:34811/), at akka.actor.ActorSelection，从现在开始使用eth1 (10.120.193.110)：
2016-03-02 18:01:23,65
浏览 1提问于2016-03-31得票数 3
回答已采纳
云服务器
ICP备案
云直播
对象存储
腾讯会议
腾讯云开发者
