leesf commented on a change in pull request #1810:
URL: https://github.com/apache/hudi/pull/1810#discussion_r465417539
##########
File path:
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
##########
@@ -475,12 +480,38 @@ private String startCommit() {
throw lastException;
}
- /**
- * Sync to Hive.
- */
- public void syncHiveIfNeeded() {
+ private void syncMeta(HoodieDeltaStreamerMetrics metrics) {
+ String syncClientToolClass = cfg.syncClientToolClass;
+ // for backward compatibility
if (cfg.enableHiveSync) {
- syncHive();
+ cfg.enableMetaSync = true;
+ syncClientToolClass = String.format("%s,%s", cfg.syncClientToolClass,
"org.apache.hudi.hive.HiveSyncTool");
Review comment:
use HiveSyncTool.class.getName here?
----------------------------------------------------------------
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:
us...@infra.apache.org
