This is an automated email from the ASF dual-hosted git repository.
codope 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 3108af46061 [HUDI-6917] Fix docker integ tests (#9843)
3108af46061 is described below
commit 3108af460614d996fec43b709a7c67e956e7497a
Author: Sagar Sumit <[email protected]>
AuthorDate: Thu Oct 12 17:12:14 2023 +0530
[HUDI-6917] Fix docker integ tests (#9843)
---
.github/workflows/bot.yml | 2 ++
.../hudi/common/functional/TestHoodieLogFormat.java | 17 -----------------
2 files changed, 2 insertions(+), 17 deletions(-)
diff --git a/.github/workflows/bot.yml b/.github/workflows/bot.yml
index 790ceb8623c..78c3ba9ed3c 100644
--- a/.github/workflows/bot.yml
+++ b/.github/workflows/bot.yml
@@ -455,4 +455,6 @@ jobs:
mkdir /tmp/spark-events/
SPARK_ARCHIVE_BASENAME=$(basename $SPARK_ARCHIVE)
export SPARK_HOME=$GITHUB_WORKSPACE/${SPARK_ARCHIVE_BASENAME%.*}
+ rm -f $GITHUB_WORKSPACE/$SPARK_ARCHIVE
+ docker system prune --all --force
mvn verify $SCALA_PROFILE -D"$SPARK_PROFILE" -Pintegration-tests -pl
!hudi-flink-datasource/hudi-flink $MVN_ARGS
diff --git
a/hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java
b/hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java
index b94005b3c3f..ab5999c54f8 100755
---
a/hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java
+++
b/hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java
@@ -62,7 +62,6 @@ import
org.apache.hudi.common.util.collection.ClosableIterator;
import org.apache.hudi.common.util.collection.ExternalSpillableMap;
import org.apache.hudi.common.util.collection.Pair;
import org.apache.hudi.exception.CorruptedLogFileException;
-import org.apache.hudi.exception.HoodieIOException;
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericData;
@@ -458,22 +457,6 @@ public class TestHoodieLogFormat extends
HoodieCommonTestHarness {
}
assertEquals(logBlockWrittenNum, logBlockReadNum, "All written log should
be correctly found");
reader.close();
-
- // test writing oversize data block which should be rejected
- Writer oversizeWriter =
-
HoodieLogFormat.newWriterBuilder().onParentPath(partitionPath).withFileExtension(HoodieLogFile.DELTA_EXTENSION)
-
.withFileId("test-fileid1").withDeltaCommit("100").withSizeThreshold(3L * 1024
* 1024 * 1024).withFs(fs)
- .build();
- // write to the existing file
- ((HoodieLogFormatWriter)
writer).withOutputStream(fs.append(writer.getLogFile().getPath()));
- List<HoodieLogBlock> dataBlocks = new ArrayList<>(logBlockWrittenNum + 1);
- for (int i = 0; i < logBlockWrittenNum + 1; i++) {
- dataBlocks.add(reusableDataBlock);
- }
- assertThrows(HoodieIOException.class, () -> {
- oversizeWriter.appendBlocks(dataBlocks);
- }, "Blocks appended may overflow. Please decrease log block size or log
block amount");
- oversizeWriter.close();
}
@ParameterizedTest