1. 这是个内部实现类，文档是一个问题，但最好不要直接依赖
2. ？你截图的代码片段在哪？我看是你自己代码创建使用的啊 Best, tison. 郑 洁锋 <zjfpla...@hotmail.com> 于2020年1月16日周四 下午1:18写道： > 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 > > > > > > >
