你 MiniCluster 要 start 啊(x Best, tison.
郑 洁锋 <zjfpla...@hotmail.com> 于2020年1月16日周四 上午11:38写道: > 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集群信息如下: > ------------------------------ > zjfpla...@hotmail.com > > >