diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java index c2073c703d959..3e6b4ad623bd9 100644 --- a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java +++ b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java @@ -893,7 +893,7 @@ static void deltaStreamerTestRunner(HoodieDeltaStreamer ds, HoodieDeltaStreamer. throw new RuntimeException(ex.getMessage(), ex); } }); - TestHelpers.waitTillCondition(condition, dsFuture, 360); + TestHelpers.waitTillCondition(condition, dsFuture, 600); if (cfg != null && !cfg.postWriteTerminationStrategyClass.isEmpty()) { awaitDeltaStreamerShutdown(ds); } else { diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java index fd684e95b2d6d..c96d7e56a5c22 100644 --- a/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java +++ b/hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java @@ -202,7 +202,6 @@ void testUpsertsContinuousModeWithMultipleWritersWithoutConflicts(HoodieTableTyp cfgIngestionJob2, backfillJob2, cfgBackfillJob2, false, "batch2"); } - @Disabled @ParameterizedTest @EnumSource(value = HoodieTableType.class, names = {"COPY_ON_WRITE"}) void testLatestCheckpointCarryOverWithMultipleWriters(HoodieTableType tableType) throws Exception { @@ -244,10 +243,6 @@ void testLatestCheckpointCarryOverWithMultipleWriters(HoodieTableType tableType) cfgBackfillJob.continuousMode = false; HoodieTableMetaClient meta = HoodieTableMetaClient.builder().setConf(hadoopConf()).setBasePath(tableBasePath).build(); - HoodieTimeline timeline = meta.getActiveTimeline().getCommitsTimeline().filterCompletedInstants(); - HoodieCommitMetadata commitMetadataForFirstInstant = HoodieCommitMetadata - .fromBytes(timeline.getInstantDetails(timeline.firstInstant().get()).get(), HoodieCommitMetadata.class); - // run the backfill job props = prepareMultiWriterProps(fs(), basePath, propsFilePath); props.setProperty("hoodie.write.lock.provider", "org.apache.hudi.client.transaction.lock.InProcessLockProvider");