lw309637554 commented on a change in pull request #2428:
URL: https://github.com/apache/hudi/pull/2428#discussion_r554690895



##########
File path: 
hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMORDataSource.scala
##########
@@ -278,7 +278,6 @@ class TestMORDataSource extends HoodieClientTestBase {
     val inputDF5: Dataset[Row] = 
spark.read.json(spark.sparkContext.parallelize(records5, 2))
     inputDF5.write.format("org.apache.hudi")
       .options(commonOpts)
-      .option("hoodie.compact.inline", "true")

Review comment:
       @garyli1019 Please also help to review, i delete the 
hoodie.compact.inline = true . Because when overwrite use replace commit, 
"Fifth Operation: " compaction will postponed until "Sixth Operation:", so " 
assertEquals(152, hudiIncDF6.count())" will be ok. 
   But when i modify the overwrite to fs.delete, compaction will do in "Fifth 
Operation: ", so after commit5Time will not have compaction commit, 
hudiIncDF6.count() will be 2. 
   So delete the inline compaction in "Fifth Operation: ", and it will do in 
"Sixth Operation:"
   https://github.com/apache/hudi/pull/1938/files




----------------------------------------------------------------
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]


Reply via email to