This is an automated email from the ASF dual-hosted git repository. yihua pushed a commit to branch branch-0.x in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 5020b2a9e18546cfe70e422f2b30b08bee9a47b5 Author: Sagar Sumit <[email protected]> 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());
