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