; Sink: Print to Std. Out (2/4)#0
> (2500c455c9c458780199da504300da05_90bea66de1c231edf33913ecd54406c1_1_0)
> switched from INITIALIZING to FAILED with failure cause:
> java.lang.Exception: Exception while creating StreamOperatorStateContext.
> at
> org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:294)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:266)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restoreStateAndGates(StreamTask.java:799)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$restoreInternal$3(StreamTask.java:753)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:753)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:712)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
> ~[flink-runtime-1.19.0.jar:1.19.0]
> at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
> [flink-runtime-1.19.0.jar:1.19.0]
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:751)
> [flink-runtime-1.19.0.jar:1.19.0]
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
> [flink-runtime-1.19.0.jar:1.19.0]
> at java.lang.Thread.run(Thread.java:745) [?:1.8.0_60]
> Caused by: org.apache.flink.util.FlinkException: Could not restore keyed
> state backend for WindowOperator_90bea66de1c231edf33913ecd54406c1_(2/4) from
> any of the 1 provided restore options.
> at
> org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:165)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.keyedStatedBackend(StreamTaskStateInitializerImpl.java:399)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> at
> org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:180)
> ~[flink-streaming-java-1.19.0.jar:1.19.0]
> ... 12 more
>
>
>
> From: Yanfei Lei
> Date: 2024-05-07 10:07
> To: user-zh
> Subject: Re: java.io.IOException: Could not load the native RocksDB library
> 请问是什么开发环境呢？ windows吗？
> 可以分享一下更详细的报错吗？比如.dll 找不到
>
> ha.fen...@aisino.com 于2024年5月7日周二 09:34写道：
> >
> > Configuration config = new Configuration();
> > config.set(StateBackendOptions.STATE_BACKEND, "rocksdb");
> > config.set(CheckpointingOptions.CHECKPOINT_STORAGE, "filesystem");
> > config.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, "file:\\d:\\cdc");
> >
> > 开发环境Flink1.17包中运行没有问题
> > 开发环境Flink1.19包中运行提示
> >
> > java.io.IOException: Could not load the native RocksDB library
>
>
>
> --
> Best,
> Yanfei
--
Best,
Yanfei
