我的Flink作业运行了几天,没有任何问题,但是过了几天,就会关闭tm并重新启动整个作业。在日志中我发现,org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend -删除现有的实例基目录/tmp/flink-io-4b455efa-bcde(StreamTask.java:279)
at org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.j
我的Flink作业从一个kafka主题中读取数据,并将数据存储在RocksDB状态后端中,以便使用可查询状态。我能够在本地机器上运行作业并查询状态。at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.Exception: Could not load the native RocksDB/librocksdbjni-linux64.so: /data/hadoop/tmp/rocksdb-lib-32