开发者社区 问答 正文

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 895 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • 你 MiniCluster 要 start 啊(x*来自志愿者整理的FLINK邮件归档

    2021-12-02 18:15:42 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
问答地址:
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等