diff --git a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesRuntimeFunctions.java b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesRuntimeFunctions.java index 82b4bdd976d85..7a4c84770d269 100644 --- a/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesRuntimeFunctions.java +++ b/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesRuntimeFunctions.java @@ -95,7 +95,13 @@ static List getRawResults(String tableName) { } static List getWatermarks(String tableName) { - return watermarkHistory.getOrDefault(tableName, new ArrayList<>()); + synchronized (TestValuesTableFactory.class) { + if (watermarkHistory.containsKey(tableName)) { + return new ArrayList<>(watermarkHistory.get(tableName)); + } else { + return Collections.emptyList(); + } + } } static List getResults(String tableName) { @@ -122,6 +128,7 @@ static void clearResults() { globalRawResult.clear(); globalUpsertResult.clear(); globalRetractResult.clear(); + watermarkHistory.clear(); } }