This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit deeb42ec897560413ca92ce8b4d09c57fe06882f Author: Stefan Richter <[email protected]> AuthorDate: Fri Mar 8 10:38:31 2024 +0100 [FLINK-35580] Improve logging and problem analysis in RockDBHandle. --- .../apache/flink/contrib/streaming/state/restore/RocksDBHandle.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBHandle.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBHandle.java index 16edc072102..acb34928bca 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBHandle.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBHandle.java @@ -209,7 +209,9 @@ class RocksDBHandle implements AutoCloseable { RegisteredStateMetaInfoBase stateMetaInfo = stateMetaInfoKey.getRegisteredStateMetaInfoBase(); - Preconditions.checkState(!kvStateInformation.containsKey(stateMetaInfo.getName())); + Preconditions.checkState( + !kvStateInformation.containsKey(stateMetaInfo.getName()), + "Error: stateMetaInfo.name is not unique:" + stateMetaInfo.getName()); RocksDbKvStateInfo stateInfo = RocksDBOperationUtils.createStateInfo(
