make formatters private

apache · Dec 18, 2023 · c6ed800 · c6ed800
1 parent 351f55d
commit c6ed800
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/...-sort/sort-core/src/main/java/org/apache/inlong/sort/function/RoundTimestampFunction.java b/...-sort/sort-core/src/main/java/org/apache/inlong/sort/function/RoundTimestampFunction.java
@@ -17,6 +17,7 @@
 
 package org.apache.inlong.sort.function;
 
+import org.apache.flink.table.functions.FunctionContext;
 import org.apache.flink.table.functions.ScalarFunction;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -37,7 +38,12 @@ public class RoundTimestampFunction extends ScalarFunction {
 
     public static final Logger LOG = LoggerFactory.getLogger(RoundTimestampFunction.class);
     public static final ZoneId DEFAULT_ZONE = ZoneId.systemDefault();
-    private static final Map<String, DateTimeFormatter> formatters = new HashMap<>();
+    private transient Map<String, DateTimeFormatter> formatters;
+
+    public void open(FunctionContext context) throws Exception {
+        super.open(context);
+        formatters = new HashMap<>();
+    }
 
     /**
      * Round timestamp and output formatted timestamp.