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.<init>(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] ________________________________ [email protected]
