diff --git a/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java b/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
index 52cdaf78bf92..36f173bb6956 100644
--- a/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
+++ b/seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-13/src/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();
-}
+}
\ No newline at end of file