This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 9ea2216ef0f [hotfix][tests] Reenable 
`PeriodicMaterializationManagerTest.testInitialDelay`
9ea2216ef0f is described below

commit 9ea2216ef0fe834139e0157d852b15bb952d8d2d
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Sat Jun 13 18:41:37 2026 +0200

    [hotfix][tests] Reenable 
`PeriodicMaterializationManagerTest.testInitialDelay`
---
 .../apache/flink/state/common/PeriodicMaterializationManagerTest.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/flink-state-backends/flink-statebackend-common/src/test/java/org/apache/flink/state/common/PeriodicMaterializationManagerTest.java
 
b/flink-state-backends/flink-statebackend-common/src/test/java/org/apache/flink/state/common/PeriodicMaterializationManagerTest.java
index 0f06aa217f8..a9b0b5bd956 100644
--- 
a/flink-state-backends/flink-statebackend-common/src/test/java/org/apache/flink/state/common/PeriodicMaterializationManagerTest.java
+++ 
b/flink-state-backends/flink-statebackend-common/src/test/java/org/apache/flink/state/common/PeriodicMaterializationManagerTest.java
@@ -22,6 +22,8 @@ import org.apache.flink.runtime.mailbox.SyncMailboxExecutor;
 import org.apache.flink.runtime.metrics.groups.UnregisteredMetricGroups;
 import 
org.apache.flink.state.common.PeriodicMaterializationManager.MaterializationTarget;
 
+import org.junit.jupiter.api.Test;
+
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
 import static 
org.apache.flink.shaded.guava33.com.google.common.collect.Iterators.getOnlyElement;
 import static 
org.apache.flink.util.concurrent.Executors.newDirectExecutorService;
@@ -30,6 +32,7 @@ import static org.assertj.core.api.Assertions.assertThat;
 /** {@link PeriodicMaterializationManager} test. */
 class PeriodicMaterializationManagerTest {
 
+    @Test
     void testInitialDelay() {
         ManuallyTriggeredScheduledExecutorService scheduledExecutorService =
                 new ManuallyTriggeredScheduledExecutorService();

Reply via email to