-
Notifications
You must be signed in to change notification settings - Fork 60
Description
Hi,
I have a flink job, H3Core.newInstance() is initialized in the open method , when restore from flink state , it throws an exception like this
java.lang.UnsatisfiedLinkError: Can't load library: /tmp/libh3-java6591047064313530667.so
at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1820)
at java.lang.Runtime.load0(Runtime.java:810)
at java.lang.System.load(System.java:1086)
at com.uber.h3core.H3CoreLoader.loadNatives(H3CoreLoader.java:125)
at com.uber.h3core.H3CoreLoader.loadNatives(H3CoreLoader.java:89)
at com.uber.h3core.H3Core.newInstance(H3Core.java:73)
at com.sankuai.meituan.banma.rtdw.flink.business.function.BusinessWorkStatusH3ClearRiderRichSinkFunction.open(BusinessWorkStatusH3ClearRiderRichSinkFunction.java:60)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
at org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46)
at org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:466)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:547)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:537)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:577)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:767)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:578)
at java.lang.Thread.run(Thread.java:748)