lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Fix a failing test case intermittenly in TestMergeOnRead due to incorrect prev commit time

Browse Source
This commit is contained in:
Nishith Agarwal
2018-09-07 00:17:49 -07:00
committed by vinoth chandar
parent e2dee68ccd
commit 0fe92dee55
2 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hoodie-client/src/main/java/com/uber/hoodie/io/HoodieAppendHandle.java
View File

@@ -246,7 +246,6 @@ public class HoodieAppendHandle<T extends HoodieRecordPayload> extends HoodieIOH
if (writer != null) { if (writer != null) {
writer.close(); writer.close();
} }
writeStatus.getStat().setPrevCommit(commitTime);
writeStatus.getStat().setFileId(this.fileId); writeStatus.getStat().setFileId(this.fileId);
writeStatus.getStat().setNumWrites(recordsWritten); writeStatus.getStat().setNumWrites(recordsWritten);
writeStatus.getStat().setNumUpdateWrites(updatedRecordsWritten); writeStatus.getStat().setNumUpdateWrites(updatedRecordsWritten);

1
hoodie-client/src/test/java/com/uber/hoodie/table/TestMergeOnReadTable.java
View File

@@ -488,6 +488,7 @@ public class TestMergeOnReadTable {
recordsRead = HoodieMergeOnReadTestUtils.getRecordsUsingInputFormat(dataFiles, basePath); recordsRead = HoodieMergeOnReadTestUtils.getRecordsUsingInputFormat(dataFiles, basePath);
assertEquals(recordsRead.size(), 200); assertEquals(recordsRead.size(), 200);
writeRecords = jsc.parallelize(copyOfRecords, 1);
writeStatusJavaRDD = client.upsert(writeRecords, commitTime2); writeStatusJavaRDD = client.upsert(writeRecords, commitTime2);
client.commit(commitTime2, writeStatusJavaRDD); client.commit(commitTime2, writeStatusJavaRDD);
statuses = writeStatusJavaRDD.collect(); statuses = writeStatusJavaRDD.collect();