我一直在尝试为在ide中本地运行的flink应用程序配置flinkui。所以我建立了相关的依赖关系和执行环境。但是FlinkUI仍然不起作用。原因可能是什么?
由http://localhost:8081有消息
{"errors":["Not found."]}
执行环境设置:
val conf = new Configuration()
conf.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf)
build.sbt中的依赖项设置:
"org.apache.flink" %% "flink-runtime-web" % "1.9.1"
暂无答案!
目前还没有任何答案,快来回答吧!