lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Fix Integration test flakiness in HoodieJavaStreamingApp (#1967)

Browse Source
This commit is contained in:
Balaji Varadarajan
2020-08-14 01:42:15 -07:00
committed by GitHub
parent 9bde6d616c
commit b8f4a30efd
5 changed files with 37 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-spark/src/main/java/org/apache/hudi/HoodieDataSourceHelpers.java
View File

@@ -74,7 +74,7 @@ public class HoodieDataSourceHelpers {
if (metaClient.getTableType().equals(HoodieTableType.MERGE_ON_READ)) {
return metaClient.getActiveTimeline().getTimelineOfActions(
CollectionUtils.createSet(HoodieActiveTimeline.COMMIT_ACTION,
HoodieActiveTimeline.DELTA_COMMIT_ACTION));
HoodieActiveTimeline.DELTA_COMMIT_ACTION)).filterCompletedInstants();
} else {
return metaClient.getCommitTimeline().filterCompletedInstants();
}