-
0 votesanswersviews
如何正确设置Rocks DB上的TTL？
我正在尝试使用带有TTL的Rocks DB . 我初始化岩石db的方式如下： options.setCreateIfMissing(true).setWriteBufferSize(8 * SizeUnit.KB) .setMaxWriteBufferNumber(3) .setCompressionType(CompressionType.LZ4_COMPRESSION).setKeepLogF... -
0 votesanswersviews
由于字节顺序不匹配，无法使用Flink RocksDB状态后端
我的Flink Job从kafka主题读取并将数据存储在RocksDB状态后端中，以便利用可查询状态 . 我能够运行该作业并在本地计算机中查询状态 . 但是在集群上部署时，我收到以下错误： Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.fli...