yjc408 commented on code in PR #13831:
URL: https://github.com/apache/hudi/pull/13831#discussion_r2323175979
##########
hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java:
##########
@@ -163,6 +163,9 @@ public HoodieStreamer(Config cfg, JavaSparkContext jssc,
FileSystem fs, Configur
cfg.recordMergeMode = mergingConfigs.getLeft();
cfg.payloadClassName = mergingConfigs.getMiddle();
cfg.recordMergeStrategyId = mergingConfigs.getRight();
+ this.properties.put(HoodieTableConfig.RECORD_MERGE_MODE.key(),
cfg.recordMergeMode.name());
Review Comment:
@nsivabalan from my understanding, the RECORD_MERGE_STRATEGY_ID and mode
should always be consistent. Do we have a case where mode stays the same but
the strategy id gets changed? (just wondering if just use mode / id would be
sufficient for this check.
--
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]
