You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2026/06/13 16:41:44 UTC
(flink) branch master updated: [hotfix][tests] Reenable `PeriodicMaterializationManagerTest.testInitialDelay`
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 <sn...@gmail.com>
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();