davidradl commented on code in PR #27194:
URL: https://github.com/apache/flink/pull/27194#discussion_r2494008445
##########
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateEmbeddedRocksDBStateBackendTest.java:
##########
@@ -49,6 +50,15 @@ public class ChangelogDelegateEmbeddedRocksDBStateBackendTest
@TempDir private Path temp;
+ @BeforeEach
+ public void setup() throws IOException {
+ assumeFalse(
+ useHeapTimer,
+ "The combination RocksDB state backend with heap-based timers
currently "
Review Comment:
The code looks fine. I am curious can we validate that RocksDB state
backend with heap-based timers are not being used in the code - so we cannot
get into this unsupported setup and fail early?
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
