This is an automated email from the ASF dual-hosted git repository.
RocMarshal pushed a commit to branch release-2.3
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-2.3 by this push:
new 7b4dbcfd683 [hotfix][tests] Reenable
`PeriodicMaterializationManagerTest.testInitialDelay` (#28431)
7b4dbcfd683 is described below
commit 7b4dbcfd68329f398165ec5d61dec2889847db87
Author: Yuepeng Pan <[email protected]>
AuthorDate: Sun Jun 14 09:27:50 2026 +0800
[hotfix][tests] Reenable
`PeriodicMaterializationManagerTest.testInitialDelay` (#28431)
(cherry picked from commit 9ea2216ef0fe834139e0157d852b15bb952d8d2d)
Co-authored-by: Sergey Nuyanzin <[email protected]>
---
.../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();