开发者社区> 问答> 正文

MiniCluster代码执行过程中报错怎么办?

MiniCluster代码执行过程中报错:

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".

SLF4J: Defaulting to no-operation (NOP) logger implementation

SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.

Exception in thread "main" java.lang.IllegalStateException: MiniCluster is not yet running.

at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195)

at org.apache.flink.runtime.minicluster.MiniCluster.getHighAvailabilityServices(MiniCluster.java:223)

at org.apache.flink.client.program.MiniClusterClient. (MiniClusterClient.java:61)

at com.dtstack.flink.sql.launcher.ClusterClientFactory.createStandaloneClient(ClusterClientFactory.java:82)

at com.dtstack.flink.sql.launcher.ClusterClientFactory.createClusterClient(ClusterClientFactory.java:69)

at com.dtstack.flink.sql.launcher.LauncherMain.main(LauncherMain.java:99)

报错段代码如下:

Configuration config = GlobalConfiguration.loadConfiguration(flinkConfDir);

MiniClusterConfiguration.Builder configBuilder = new MiniClusterConfiguration.Builder();

configBuilder.setConfiguration(config);

MiniCluster miniCluster = new MiniCluster(configBuilder.build());

MiniClusterClient clusterClient = new MiniClusterClient(config, miniCluster);

其中flinkConfDir为/opt/flink/conf

flink standalone HA集群信息如下:

[cid:_Foxmail.1@1b958fff-6637-1c63-42a4-5dff5b86583b]*来自志愿者整理的flink邮件归档

展开
收起
彗星halation 2021-12-02 17:55:26 868 0
1 条回答
写回答
取消 提交回答
  • 你 MiniCluster 要 start 啊(x*来自志愿者整理的FLINK邮件归档

    2021-12-02 18:15:42
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
《0代码搭应用》 立即下载
不止代码 立即下载
《15分钟打造你自己的小程序》 立即下载