Zakelly commented on code in PR #27194:
URL: https://github.com/apache/flink/pull/27194#discussion_r2497026371
##########
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:
I'm not sure whether the changelog can perform right when delegating the
RocksDB with heap-based timers. If it cannot, we can fail against the
combination.
--
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]
