search

DTStack / flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法
Apache License 2.0
2.02k stars 924 forks source link

Windows系统下standalone模式下运行报错MiniCluster is not yet running. #190

Open qiuqingyu opened 5 years ago

qiuqingyu commented 5 years ago

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.(MiniClusterClient.java:61) at com.dtstack.flink.sql.launcher.ClusterClientFactory.createStandaloneClient(ClusterClientFactory.java:79) at com.dtstack.flink.sql.launcher.ClusterClientFactory.createClusterClient(ClusterClientFactory.java:66) at com.dtstack.flink.sql.launcher.LauncherMain.main(LauncherMain.java:98)

liubin2048 commented 4 years ago

这个代码默认连接的是flink的HA standalone集群，你是单master节点就会出这样的错误

oliveryunchang commented 4 years ago

这个问题解决了吗？

oliveryunchang commented 4 years ago

本地单master怎样提交基于flinkStreamSQL的任务？

oliveryunchang commented 4 years ago

这个HA standalone集群怎么搭建的？我这边使用K8S已经搭建了两个JobManager，但是还是提示"MiniCluster is not yet running"