liuyufei9527 commented on a change in pull request #14341:
URL: https://github.com/apache/flink/pull/14341#discussion_r539302090
##########
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java
##########
@@ -143,6 +144,11 @@ public ColumnFamilyOptions getColumnOptions() {
"We currently only support
BlockBasedTableConfig When bounding total memory.");
blockBasedTableConfig = (BlockBasedTableConfig)
tableFormatConfig;
}
+ if (rocksResources.isUsingPartitionedIndex()) {
Review comment:
We couldn't know the filter config(bits, useBlockBasedMode) if it's
already created. Should we overwrite with a default full bloom filter? It might
have not expected behavior.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
