revert

apache · Jan 31, 2023 · 9fb766c · 9fb766c
1 parent 4e175b0
commit 9fb766c
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/.../main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java b/.../main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
@@ -152,10 +152,8 @@ public void initializeState(FunctionInitializationContext initializeContext) thr
                     getStateName(),
                     Types.MAP(
                         BasicTypeInfo.INT_TYPE_INFO,
-                        Types.LIST(PrimitiveArrayTypeInfo.BYTE_PRIMITIVE_ARRAY_TYPE_INFO)
-                    )
-                )
-            );
+                        Types.LIST(PrimitiveArrayTypeInfo.BYTE_PRIMITIVE_ARRAY_TYPE_INFO))
+                ));
         if (initializeContext.isRestored()) {
             // populate actual holder for restored state
             sourceState.get().forEach(map -> restoredState.putAll(map));
@@ -166,4 +164,4 @@ public void initializeState(FunctionInitializationContext initializeContext) thr
     }
 
     protected abstract String getStateName();
-}
+}