(hudi) branch master updated: [HUDI-7643] Fix test by using the right StreamSync constructor (#11056)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 7ac26bce3f3 [HUDI-7643] Fix test by using the right StreamSync constructor (#11056)
7ac26bce3f3 is described below

commit 7ac26bce3f3aad2c9aebeb55febc4375c4f7bd1d
Author: Sagar Sumit <sa...@gmail.com>
AuthorDate: Fri Apr 19 15:55:46 2024 +0530

    [HUDI-7643] Fix test by using the right StreamSync constructor (#11056)
---
 .../org/apache/hudi/utilities/streamer/TestStreamSyncUnitTests.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamSyncUnitTests.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamSyncUnitTests.java
index 8ff5b6ee933..fe775f95a36 100644
--- a/hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamSyncUnitTests.java
+++ b/hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamSyncUnitTests.java
@@ -141,7 +141,7 @@ public class TestStreamSyncUnitTests {
   @MethodSource("getCheckpointToResumeCases")
   void testGetCheckpointToResume(HoodieStreamer.Config cfg, HoodieCommitMetadata commitMetadata, Option<String> expectedResumeCheckpoint) throws IOException {
     HoodieSparkEngineContext hoodieSparkEngineContext = mock(HoodieSparkEngineContext.class);
-    FileSystem fs = mock(FileSystem.class);
+    HoodieStorage storage = HoodieStorageUtils.getStorage(mock(FileSystem.class));
     TypedProperties props = new TypedProperties();
     SparkSession sparkSession = mock(SparkSession.class);
     Configuration configuration = mock(Configuration.class);
@@ -152,7 +152,7 @@ public class TestStreamSyncUnitTests {
     when(commitsTimeline.lastInstant()).thenReturn(Option.of(hoodieInstant));
 
     StreamSync streamSync = new StreamSync(cfg, sparkSession, props, hoodieSparkEngineContext,
-        fs, configuration, client -> true, null,Option.empty(),null,Option.empty(),true,true);
+        storage, configuration, client -> true, null,Option.empty(),null,Option.empty(),true,true);
     StreamSync spy = spy(streamSync);
     doReturn(Option.of(commitMetadata)).when(spy).getLatestCommitMetadataWithValidCheckpointInfo(any());