Search before asking
Please describe the bug 🐞
Error: ITConversionController.testVariousOperations:266->checkDatasetEquivalence:955->checkDatasetEquivalence:1029->lambda$checkDatasetEquivalence$10:1036 Datasets have different row counts when reading from Spark. Source: PAIMON, Target: HUDI ==> expected: <100> but was: <0>
In Hudi 1.x, all the partition paths from MDT are coming in as empty causing the failures as compared to 0.x.
protected List<PartitionPath> listPartitionPaths(List<String> relativePartitionPaths) {
List<String> matchedPartitionPaths;
try {
if (isPartitionedTable()) {
if (queryType == HoodieTableQueryType.INCREMENTAL && incrementalQueryStartTime.isPresent() && !isBeforeTimelineStarts()) {
HoodieTimeline timelineToQuery = findInstantsInRange();
matchedPartitionPaths = TimelineUtils.getWrittenPartitions(timelineToQuery);
} else {
matchedPartitionPaths = tableMetadata.getPartitionPathWithPathPrefixes(relativePartitionPaths);
}
} else {
matchedPartitionPaths = Collections.singletonList(StringUtils.EMPTY_STRING);
}
} catch (IOException e) {
throw new HoodieIOException("Error fetching partition paths", e);
}
https://github.com/apache/hudi/blob/master/hudi-common/src/main/java/org/apache/hudi/BaseHoodieTableFileIndex.java#L346
Are you willing to submit PR?
Code of Conduct
Search before asking
Please describe the bug 🐞
In Hudi 1.x, all the partition paths from MDT are coming in as empty causing the failures as compared to 0.x.
https://github.com/apache/hudi/blob/master/hudi-common/src/main/java/org/apache/hudi/BaseHoodieTableFileIndex.java#L346
Are you willing to submit PR?
Code of Conduct