This is an automated email from the ASF dual-hosted git repository. yihua pushed a commit to branch release-0.13.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 2ce0869ef341395b286cfcc1192f055d03b0633c Author: Shiyan Xu <[email protected]> AuthorDate: Sun Jan 29 00:59:02 2023 -0600 [MINOR] Fix `HoodieCDCRDD` setting flag `usesVirtualKeys` (#7777) --- .../src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala index 767300f3659..1e4bf0098a1 100644 --- a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala +++ b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala @@ -153,7 +153,7 @@ class HoodieCDCRDD( Some(split.changes.last.getInstant), recordKeyField, preCombineFieldOpt, - usesVirtualKeys = false, + usesVirtualKeys = !populateMetaFields, metaClient.getTableConfig.getPayloadClass, metadataConfig, // TODO support CDC with spark record
