From 3222c3cf336a52130fd3e647bfcb799520b5d0f4 Mon Sep 17 00:00:00 2001 From: Zakelly Date: Mon, 30 Sep 2024 11:30:35 +0800 Subject: [PATCH] [hotfix] Compile error of ForStStateExecutor --- .../org/apache/flink/state/forst/ForStStateExecutorTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateExecutorTest.java b/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateExecutorTest.java index 3a0d236f6aec8..d715cae5a7f8e 100644 --- a/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateExecutorTest.java +++ b/flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStStateExecutorTest.java @@ -234,7 +234,7 @@ void testExecuteMapStateRequest() throws Exception { @SuppressWarnings("unchecked") public void testExecuteAggregatingStateRequest() throws Exception { ForStStateExecutor forStStateExecutor = - new ForStStateExecutor(false, 4, 1, db, new WriteOptions()); + new ForStStateExecutor(false, false, 4, 1, db, new WriteOptions()); ForStAggregatingState state = buildForStSumAggregateState("agg-state-1");