rahil-c commented on code in PR #14041:
URL: https://github.com/apache/hudi/pull/14041#discussion_r2400512209
##########
hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestPayloadDeprecationFlow.scala:
##########
@@ -597,11 +605,18 @@ class TestPayloadDeprecationFlow extends
SparkClientFunctionalTestHarness {
"Data should remain consistent after downgrade including new row")
}
- def getExpectedResultForSnapshotQuery(payloadClazz: String,
usesDeleteMarker: Boolean): Seq[(Int, Long, String, String, Double, String,
String, Int, Int, String)] = {
+ def getExpectedResultForSnapshotQuery(payloadClazz: String,
usesDeleteMarker: Boolean, hasOrderingField: Boolean, tableType: String,
startVersion: String = "8"): Seq[(Int, Long, String, String, Double, String,
String, Int, Int, String)] = {
+ // V6 backward compatibility: OverwriteWithLatestAvroPayload with MOR +
ordering field uses EVENT_TIME
+ val isV6BackwardCompatCase = startVersion == "6" &&
Review Comment:
will remove this now as we are not covering this case in this test, and will
be doing a different approach
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
