diff --git a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/IMapFileStorage.java b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/IMapFileStorage.java
index edab4a2252ab..915981e476d5 100644
--- a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/IMapFileStorage.java
+++ b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/IMapFileStorage.java
@@ -124,8 +124,7 @@ public void initialize(Map<String, Object> configuration) {
                                 STORAGE_TYPE_KEY, FileConfiguration.HDFS.toString()));
         this.fileConfiguration = FileConfiguration.valueOf(storageType.toUpperCase());
         // build configuration
-        AbstractConfiguration fileConfiguration =
-                this.fileConfiguration.getConfiguration(storageType);
+        AbstractConfiguration fileConfiguration = this.fileConfiguration.getConfiguration();
 
         Configuration hadoopConf = fileConfiguration.buildConfiguration(configuration);
         this.conf = hadoopConf;
diff --git a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/config/FileConfiguration.java b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/config/FileConfiguration.java
index 22a0637ea88d..2da8a5056f8b 100644
--- a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/config/FileConfiguration.java
+++ b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/config/FileConfiguration.java
@@ -36,7 +36,7 @@ public enum FileConfiguration {
         this.configuration = configuration;
     }
 
-    public AbstractConfiguration getConfiguration(String name) {
+    public AbstractConfiguration getConfiguration() {
         return configuration;
     }
 
diff --git a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/HdfsWriter.java b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/HdfsWriter.java
index 02ab810bc658..57b329c5c97f 100644
--- a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/HdfsWriter.java
+++ b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/HdfsWriter.java
@@ -35,9 +35,9 @@
 
 public class HdfsWriter implements IFileWriter<IMapFileData> {
 
-    FSDataOutputStream out;
+    private FSDataOutputStream out;
 
-    Serializer serializer;
+    private Serializer serializer;
 
     @Override
     public String identifier() {
diff --git a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/OssWriter.java b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/OssWriter.java
index 59f4a9562450..b5d7e1614e9d 100644
--- a/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/OssWriter.java
+++ b/seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/OssWriter.java
@@ -39,17 +39,17 @@
 
 @Slf4j
 public class OssWriter implements IFileWriter<IMapFileData> {
-    FileSystem fs;
-    Path parentPath;
-    Path path;
-    Serializer serializer;
+    private FileSystem fs;
+    private Path parentPath;
+    private Path path;
+    private Serializer serializer;
 
-    ByteBuf bf = Unpooled.buffer(1024);
+    private ByteBuf bf = Unpooled.buffer(1024);
 
     // block size
-    long blockSize = 1024 * 1024;
+    private long blockSize = 1024 * 1024;
 
-    AtomicLong index = new AtomicLong(0);
+    private AtomicLong index = new AtomicLong(0);
 
     @Override
     public void initialize(FileSystem fs, Path parentPath, Serializer serializer)
@@ -114,7 +114,6 @@ public Path createNewPath() {
 
     @Override
     public void close() throws Exception {
-        // No-op
         bf.clear();
         this.bf = null;
     }