From 69f1f2207ae33eef1d9662f3c1941ed3ec1b111a Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Tue, 21 May 2024 19:06:52 +0800 Subject: [PATCH] =?UTF-8?q?fix(command):=20=E8=A1=A5=E5=85=85hoodie.proper?= =?UTF-8?q?ties=E6=96=87=E4=BB=B6=E7=9A=84=E5=8D=87=E9=99=8D=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/command/commands/ToolCommand.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/ToolCommand.java b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/ToolCommand.java index b613896..f25c6b0 100644 --- a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/ToolCommand.java +++ b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/ToolCommand.java @@ -40,9 +40,8 @@ public class ToolCommand { if (hudiService.existsPath(hdfs)) { String propertiesPath = StrUtil.format("{}/.hoodie/hoodie.properties", hdfs); String content = hudiService.read(propertiesPath); - if (content.contains("org.apache.hudi.common.model.OverwriteWithLatestAvroPayload") && content.contains("org.apache.hudi.keygen.SimpleKeyGenerator")) { - content = content.replace("org.apache.hudi.common.model.OverwriteWithLatestAvroPayload", "org.apache.hudi.common.model.TraceOverwriteWithLatestAvroPayload"); - content = content.replace("org.apache.hudi.keygen.SimpleKeyGenerator", "org.apache.hudi.keygen.DefaultPartitionNameKeyGenerator"); + if (content.contains("org.apache.hudi.common.model.OverwriteWithLatestAvroPayload")) { + content = content.replace("org.apache.hudi.common.model.OverwriteWithLatestAvroPayload", "org.apache.hudi.common.model.TraceEventTimeAvroPayload"); hudiService.write(propertiesPath, content, true); logger.info("{} has rewrote", hdfs); results.add(StrUtil.format("{} {}", meta.getJob().getId(), meta.getAlias())); @@ -63,9 +62,8 @@ public class ToolCommand { if (hudiService.existsPath(hdfs)) { String propertiesPath = StrUtil.format("{}/.hoodie/hoodie.properties", hdfs); String content = hudiService.read(propertiesPath); - if (content.contains("org.apache.hudi.common.model.TraceOverwriteWithLatestAvroPayload") && content.contains("org.apache.hudi.keygen.DefaultPartitionNameKeyGenerator")) { - content = content.replace("org.apache.hudi.common.model.TraceOverwriteWithLatestAvroPayload", "org.apache.hudi.common.model.OverwriteWithLatestAvroPayload"); - content = content.replace("org.apache.hudi.keygen.DefaultPartitionNameKeyGenerator", "org.apache.hudi.keygen.SimpleKeyGenerator"); + if (content.contains("org.apache.hudi.common.model.TraceEventTimeAvroPayload")) { + content = content.replace("org.apache.hudi.common.model.TraceEventTimeAvroPayload", "org.apache.hudi.common.model.OverwriteWithLatestAvroPayload"); hudiService.write(propertiesPath, content, true); logger.info("{} has rewrote", hdfs); results.add(StrUtil.format("{} {}", meta.getJob().getId(), meta.getAlias()));