This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit a31ad06ddc11729fd5383ae2e1b29aee33d7277c Author: Piotr Nowojski <[email protected]> AuthorDate: Thu May 15 16:29:50 2025 +0200 [hotfix] Log State Backend build exception ASAP --- .../org/apache/flink/state/rocksdb/RocksDBKeyedStateBackendBuilder.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBKeyedStateBackendBuilder.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBKeyedStateBackendBuilder.java index 414e6027efc..163d6891ea8 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBKeyedStateBackendBuilder.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBKeyedStateBackendBuilder.java @@ -440,6 +440,8 @@ public class RocksDBKeyedStateBackendBuilder<K> extends AbstractKeyedStateBacken nativeMetricMonitor, manualCompactionManager); } catch (Throwable e) { + // log ASAP because close can block or fail too + logger.warn("Failed to build RocksDB state backend", e); // Do clean up List<ColumnFamilyOptions> columnFamilyOptions = new ArrayList<>(kvStateInformation.values().size());
