我正在尝试使用Linux和Windows上的Flinklocal来完成我的学士论文。我找到了用于本地设置的以下步骤:-bash: bin/start-local.sh: No such file or directory/flink-1.1.2/flink-dist/src/main/flink-bin
使用flink 0.10.1在本地,由于以下错误,我无法与作业管理器连接:
Association with remote system [akka.tcp://flink@127.0.0.1:49789Reason is: [scala.Option; local class incompatible: stream classdesc serialVersionUID = -2062608324514658839, local class serialVersionUID = -1144987520
, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@flink-jobmanager@flink-taskmanager-54d85f57c7-nl9cf:~$ ping flink-jobmanager
PING flink-jobmanager.dabai-fat.svc.cluster.local(10.254.58.171) 56(84
我正在从IDE运行flink。在queryable中存储数据是可行的,但是当我查询它时,它会抛出一个异常。异常
Failure(akka.actor.ActorNotFound: Actor not found for: ActorSelection[Anchor(akka.tcp://flink@127.0.0.1默认情况下,flink在localhost上运行:6123连接有问题吗?是否需要在单独的组群中提交职务?