This is an automated email from the ASF dual-hosted git repository.
hangxiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new aa0c1b5e71d [FLINK-33946] [rocksdb] set setAvoidFlushDuringShutdown to
true for avoiding Flush when Cancel Task (#24069)
aa0c1b5e71d is described below
commit aa0c1b5e71da6b5cb5d4f3797a9fbea401f38672
Author: 马越 <[email protected]>
AuthorDate: Thu Jan 11 14:22:31 2024 +0800
[FLINK-33946] [rocksdb] set setAvoidFlushDuringShutdown to true for
avoiding Flush when Cancel Task (#24069)
---
.../apache/flink/contrib/streaming/state/RocksDBResourceContainer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
index 74cfdb0d24c..673f2c805a7 100644
---
a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
+++
b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
@@ -141,7 +141,7 @@ public final class RocksDBResourceContainer implements
AutoCloseable {
}
// add necessary default options
- opt = opt.setCreateIfMissing(true);
+ opt = opt.setCreateIfMissing(true).setAvoidFlushDuringShutdown(true);
// if sharedResources is non-null, use the write buffer manager from
it.
if (sharedResources != null) {
