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();