1311: fixed tests

Author: emmanouil-vega

fluss-filesystems/fluss-fs-abfs/src/test/java/org/apache/fluss/fs/abfs/AbfsFileSystemBehaviorITCase.java

@@ -42,46 +42,33 @@ class AbfsFileSystemBehaviorITCase extends FileSystemBehaviorTestSuite {
     public static final String ABFS_FS_PATH = "abfs://[email protected]/test";
 
     private static MockAuthServer mockGSServer;
-    private static FileSystem fileSystem;
 
     @BeforeAll
-    static void setup() throws IOException {
+    static void setup() {
         mockGSServer = MockAuthServer.create();
-        fileSystem = createFileSystem();
+        final Configuration configuration = new Configuration();
+        configuration.setString(CONFIG_PREFIX + ".oauth2.client.id", CLIENT_ID);
+        configuration.setString(CONFIG_PREFIX + ".oauth2.client.secret", CLIENT_SECRET);
+        configuration.setString(CONFIG_PREFIX + ".oauth2.client.endpoint", ENDPOINT_KEY);
+        configuration.setString(CONFIG_PREFIX + ".key", AZURE_ACCOUNT_KEY);
+        FileSystem.initialize(configuration, null);
     }
 
-    void testPathAndScheme() throws Exception {}
-
     @Override
-    protected FileSystem getFileSystem() {
-        return fileSystem;
+    protected FileSystem getFileSystem() throws IOException {
+        return getBasePath().getFileSystem();
     }
 
     @Override
-    protected FsPath getBasePath() {
-        return new FsPath(ABFS_FS_PATH);
-    }
-
-    private static FileSystem createFileSystem() throws IOException {
-        AbfsFileSystemPlugin abfsFileSystemPlugin = new AbfsFileSystemPlugin();
-        Configuration configuration = new Configuration();
-        configuration.setString(CONFIG_PREFIX + ".oauth2.id", CLIENT_ID);
-        configuration.setString(CONFIG_PREFIX + ".oauth2.secret", CLIENT_SECRET);
-        configuration.setString(CONFIG_PREFIX + ".oauth2.endpoint", ENDPOINT_KEY);
-        configuration.setString(CONFIG_PREFIX + ".key", AZURE_ACCOUNT_KEY);
-
-        FileSystem fileSystem =
-                abfsFileSystemPlugin.create(
-                        URI.create("abfs://[email protected]/test"), configuration);
-
-        applyMockStorage(fileSystem);
-
-        return fileSystem;
+    protected FsPath getBasePath() throws IOException {
+        FsPath fsPath = new FsPath(ABFS_FS_PATH);
+        applyMockStorage(fsPath.getFileSystem());
+        return fsPath;
     }
 
     private static void applyMockStorage(FileSystem fileSystem) throws IOException {
         try {
-            MemoryFileSystem memoryFileSystem = new MemoryFileSystem();
+            MemoryFileSystem memoryFileSystem = new MemoryFileSystem(URI.create(ABFS_FS_PATH));
             FieldUtils.writeField(fileSystem, "fs", memoryFileSystem, true);
         } catch (IllegalAccessException e) {
             throw new RuntimeException(e);

fluss-filesystems/fluss-fs-abfs/src/test/java/org/apache/fluss/fs/abfs/MemoryFileSystem.java

@@ -41,18 +41,23 @@
 /** Util file system abstraction. */
 public class MemoryFileSystem extends FileSystem {
 
+    private final URI uri;
     private final Map<Path, byte[]> files = MapUtils.newConcurrentHashMap();
     private final Set<Path> directories =
             Collections.newSetFromMap(MapUtils.newConcurrentHashMap());
 
+    public MemoryFileSystem(URI uri) {
+        this.uri = uri;
+    }
+
     @Override
     public boolean exists(Path f) throws IOException {
         return files.containsKey(f) || directories.contains(f);
     }
 
     @Override
     public URI getUri() {
-        throw new UnsupportedOperationException();
+        return uri;
     }
 
     @Override