跟集群无关 Best, tison.
tison <[email protected]> 于2020年1月16日周四 下午1:30写道： > 1. 这是个内部实现类，文档是一个问题，但最好不要直接依赖 > > 2. ？你截图的代码片段在哪？我看是你自己代码创建使用的啊 > > Best, > tison. > > > 郑 洁锋 <[email protected]> 于2020年1月16日周四 下午1:18写道： > >> MiniCluster有没有相关文档，官方文档里面看到部署模式里面没有相关的内容？ >> 我是通过bin/start-cluster.sh启动的flink standalone集群 >> >> >> ________________________________ >> [email protected] >> >> 发件人： tison<mailto:[email protected]> >> 发送时间： 2020-01-16 12:39 >> 收件人： user-zh<mailto:[email protected]> >> 主题： Re: MiniCluster问题 >> 你 MiniCluster 要 start 啊（x >> >> Best, >> tison. >> >> >> 郑 洁锋 <[email protected]> 于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集群信息如下： >> > ------------------------------ >> > [email protected] >> > >> > >> > >> >
