From 0fe92dee558631873c01c22f254f59af57120282 Mon Sep 17 00:00:00 2001 From: Nishith Agarwal Date: Fri, 7 Sep 2018 00:17:49 -0700 Subject: [PATCH] Fix a failing test case intermittenly in TestMergeOnRead due to incorrect prev commit time --- .../src/main/java/com/uber/hoodie/io/HoodieAppendHandle.java | 1 - .../test/java/com/uber/hoodie/table/TestMergeOnReadTable.java | 1 + 2 files changed, 1 insertion(+), 1 deletion(-) diff --git a/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieAppendHandle.java b/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieAppendHandle.java index 9f4f0924d..c60384475 100644 --- a/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieAppendHandle.java +++ b/hoodie-client/src/main/java/com/uber/hoodie/io/HoodieAppendHandle.java @@ -246,7 +246,6 @@ public class HoodieAppendHandle extends HoodieIOH if (writer != null) { writer.close(); } - writeStatus.getStat().setPrevCommit(commitTime); writeStatus.getStat().setFileId(this.fileId); writeStatus.getStat().setNumWrites(recordsWritten); writeStatus.getStat().setNumUpdateWrites(updatedRecordsWritten); diff --git a/hoodie-client/src/test/java/com/uber/hoodie/table/TestMergeOnReadTable.java b/hoodie-client/src/test/java/com/uber/hoodie/table/TestMergeOnReadTable.java index aa2744043..92c40e7e8 100644 --- a/hoodie-client/src/test/java/com/uber/hoodie/table/TestMergeOnReadTable.java +++ b/hoodie-client/src/test/java/com/uber/hoodie/table/TestMergeOnReadTable.java @@ -488,6 +488,7 @@ public class TestMergeOnReadTable { recordsRead = HoodieMergeOnReadTestUtils.getRecordsUsingInputFormat(dataFiles, basePath); assertEquals(recordsRead.size(), 200); + writeRecords = jsc.parallelize(copyOfRecords, 1); writeStatusJavaRDD = client.upsert(writeRecords, commitTime2); client.commit(commitTime2, writeStatusJavaRDD); statuses = writeStatusJavaRDD.collect();