4545import org .apache .hudi .testutils .HoodieClientTestHarness ;
4646import org .apache .hudi .timeline .service .TimelineService ;
4747
48- import org .apache .hadoop .conf .Configuration ;
49- import org .apache .hadoop .fs .FileSystem ;
5048import org .apache .hadoop .fs .Path ;
5149import org .apache .log4j .LogManager ;
5250import org .apache .log4j .Logger ;
@@ -80,9 +78,8 @@ public class TestRemoteFileSystemViewWithMetadataTable extends HoodieClientTestH
8078
8179 @ BeforeEach
8280 public void setUp () throws Exception {
83- initPath ();
81+ basePath = tempDir . toUri (). toString ();
8482 initSparkContexts ();
85- initFileSystem ();
8683 initMetaClient ();
8784 initTimelineService ();
8885 dataGen = new HoodieTestDataGenerator (0x1f86 );
@@ -93,8 +90,6 @@ public void tearDown() throws Exception {
9390 cleanupTimelineService ();
9491 cleanupClients ();
9592 cleanupSparkContexts ();
96- cleanupFileSystem ();
97- cleanupExecutorService ();
9893 dataGen = null ;
9994 System .gc ();
10095 }
@@ -110,10 +105,10 @@ public void initTimelineService() {
110105 .withFileSystemViewConfig (FileSystemViewStorageConfig .newBuilder ()
111106 .withRemoteServerPort (incrementTimelineServicePortToUse ()).build ())
112107 .build ();
113- timelineService = new TimelineService (localEngineContext , new Configuration (),
108+ timelineService = new TimelineService (localEngineContext , metaClient . getHadoopConf (),
114109 TimelineService .Config .builder ().enableMarkerRequests (true )
115110 .serverPort (config .getViewStorageConfig ().getRemoteViewServerPort ()).build (),
116- FileSystem . get ( new Configuration () ),
111+ metaClient . getFs ( ),
117112 FileSystemViewManager .createViewManager (
118113 context , config .getMetadataConfig (), config .getViewStorageConfig (),
119114 config .getCommonConfig (),
0 commit comments