Hi, 运行的是哪个例子？从错误上看是在从MiniCluster获取结果的时候，MiniCluster被关闭了
Best, Shammon FY On Sat, Jul 22, 2023 at 3:25 PM guanyq <dlgua...@163.com> wrote: > 本地IDEA运行 MiniCluster is not yet running or has already been shut down. > 请问是什么原因，如何处理 > > > > > 15:19:27,511 INFO > org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - > Stopping resource manager service. > > 15:19:27,503 WARN > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher [] - > Failed to get job status so we assume that the job has terminated. Some > data might be lost. > > java.lang.IllegalStateException: MiniCluster is not yet running or has > already been shut down. > > at org.apache.flink.util.Preconditions.checkState(Preconditions.java:193) > ~[flink-core-1.17.1.jar:1.17.1] > > at > org.apache.flink.runtime.minicluster.MiniCluster.getDispatcherGatewayFuture(MiniCluster.java:1060) > ~[flink-runtime-1.17.1.jar:1.17.1] > > at > org.apache.flink.runtime.minicluster.MiniCluster.runDispatcherCommand(MiniCluster.java:933) > ~[flink-runtime-1.17.1.jar:1.17.1] > > at > org.apache.flink.runtime.minicluster.MiniCluster.getJobStatus(MiniCluster.java:857) > ~[flink-runtime-1.17.1.jar:1.17.1] > > at > org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobStatus(MiniClusterJobClient.java:91) > ~[flink-runtime-1.17.1.jar:1.17.1] > > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.isJobTerminated(CollectResultFetcher.java:210) > [flink-streaming-java-1.17.1.jar:1.17.1] > > at > org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:118) > [flink-streaming-java-1.17.1.jar:1.17.1] > > at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) > [flink-streaming-java-1.17.1.jar:1.17.1] > > at > org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) > [flink-streaming-java-1.17.1.jar:1.17.1] > > at > org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222) > [flink-table-planner_25e35ab8-6377-4c6a-a928-a9fe1ff9e7f4.jar:1.17.1] > > at > org.apache.flink.table.utils.print.TableauStyle.print(TableauStyle.java:120) > [flink-table-common-1.17.1.jar:1.17.1] > > at > org.apache.flink.table.api.internal.TableResultImpl.print(TableResultImpl.java:153) > [flink-table-api-java-1.17.1.jar:1.17.1]
