MiniCluster有没有相关文档，官方文档里面看到部署模式里面没有相关的内容？ 我是通过bin/start-cluster.sh启动的flink standalone集群
________________________________ zjfpla...@hotmail.com 发件人： tison<mailto:wander4...@gmail.com> 发送时间： 2020-01-16 12:39 收件人： user-zh<mailto:user-zh@flink.apache.org> 主题： Re: MiniCluster问题 你 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 > > >
