Caused by: java.lang.Exception: Exception while creating StreamOperatorStateContext.

at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:256)

at org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:256)

at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106)

at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:734)

at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)

at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:709)

at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675)

at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952)

at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921)

at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745)

at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)

at java.base/java.lang.Thread.run(Thread.java:834)

Caused by: org.apache.flink.util.FlinkException: Could not restore keyed state backend for StreamMap_e4cb5bc1ac70d352198b4a1200f6b296_(4/12) from any of the 1 provided restore options.

at org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:160)

at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.keyedStatedBackend(StreamTaskStateInitializerImpl.java:353)

at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:165)

... 11 more

Caused by: java.io.IOException: Could not load the native RocksDB library

at org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.ensureRocksDBIsLoaded(EmbeddedRocksDBStateBackend.java:977)

at org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.createKeyedStateBackend(EmbeddedRocksDBStateBackend.java:448)

at org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.createKeyedStateBackend(EmbeddedRocksDBStateBackend.java:99)

at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.lambda$keyedStatedBackend$1(StreamTaskStateInitializerImpl.java:336)

at org.apache.flink.streaming.api.operators.BackendRestorerProcedure.attemptCreateAndRestore(BackendRestorerProcedure.java:168)

at org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:135)

... 13 more

Caused by: java.lang.UnsatisfiedLinkError: C:\Users\...\AppData\Local\Temp\minicluster_8800a67d6f12e85c690a30d4b08db590\tm_0\tmp\rocksdb-lib-072fe938ffd58de9d936923ddbb55280\librocksdbjni-win64.dll: Can't find dependent libraries

at java.base/java.lang.ClassLoader$NativeLibrary.load0(Native Method)

at java.base/java.lang.ClassLoader$NativeLibrary.load(ClassLoader.java:2432)

at java.base/java.lang.ClassLoader$NativeLibrary.loadLibrary(ClassLoader.java:2489)

at java.base/java.lang.ClassLoader.loadLibrary0(ClassLoader.java:2689)

at java.base/java.lang.ClassLoader.loadLibrary(ClassLoader.java:2619)

at java.base/java.lang.Runtime.load0(Runtime.java:765)

at java.base/java.lang.System.load(System.java:1835)

at org.rocksdb.NativeLibraryLoader.loadLibraryFromJar(NativeLibraryLoader.java:102)

at org.rocksdb.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:82)

at org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.ensureRocksDBIsLoaded(EmbeddedRocksDBStateBackend.java:951)

<dependency>

<groupId>com.ververica</groupId>

<artifactId>frocksdbjni</artifactId>

<version>6.20.3-ververica-2.0</version>

</dependency>