nsivabalan commented on a change in pull request #1004: [HUDI-328] Adding
delete api to HoodieWriteClient
URL: https://github.com/apache/incubator-hudi/pull/1004#discussion_r349825756
##########
File path:
hudi-integ-test/src/test/java/org/apache/hudi/integ/ITTestHoodieSanity.java
##########
@@ -152,10 +152,10 @@ public void testRunHoodieJavaApp(String hiveTableName,
String tableType, Partiti
Assert.assertEquals("Expecting 100 rows to be present in the new table",
80,
Integer.parseInt(stdOutErr.getLeft().trim()));
- // If is MOR table, ensure realtime table row count is 100 (without
duplicates)
+ // If is MOR table, ensure realtime table row count is 100 - 20 = 80
(without duplicates)
if (tableType.equals(HoodieTableType.MERGE_ON_READ.name())) {
stdOutErr = executeHiveCommand("select count(1) from " + hiveTableName +
"_rt");
- Assert.assertEquals("Expecting 100 rows to be present in the realtime
table,", 100,
+ Assert.assertEquals("Expecting 100 rows to be present in the realtime
table,", 80,
Review comment:
Bcoz, in HoodieJavaApp, I added a delete batch which deletes 20 records.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
