fixed

apache · May 5, 2023 · fb5e6be · fb5e6be
1 parent 08b5196
commit fb5e6be
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 13 deletions.
diff --git a/...age-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/IMapFileStorage.java b/...age-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/...src/main/java/org/apache/seatunnel/engine/imap/storage/file/config/FileConfiguration.java b/...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/...le/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/HdfsWriter.java b/...le/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/...ile/src/main/java/org/apache/seatunnel/engine/imap/storage/file/wal/writer/OssWriter.java b/...ile/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;
     }