本地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]

回复