From 00b21b06b4692847748ccf9b47b4295df45b3838 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Thu, 25 Apr 2024 18:22:54 +0800 Subject: [PATCH] =?UTF-8?q?fix(command):=20=E4=BF=AE=E5=A4=8D=E5=8F=82?= =?UTF-8?q?=E6=95=B0=E5=90=8D=E5=A4=8D=E6=95=B0=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/command/commands/CompactionCommand.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/CompactionCommand.java b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/CompactionCommand.java index 2c7c252..d00a2ba 100644 --- a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/CompactionCommand.java +++ b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/CompactionCommand.java @@ -35,14 +35,14 @@ public class CompactionCommand extends AbstractUtilShellComponent { @ShellMethod("启动表压缩任务") public String compactionRun( - @ShellOption(help = "Flink job id") Long flinkJobIds, + @ShellOption(help = "Flink job id") Long flinkJobId, @ShellOption(help = "别名") String alias, @ShellOption( help = "Ignore double check", defaultValue = "false" ) Boolean ignoreCheck ) { - TableMeta meta = infoService.tableMetaDetail(flinkJobIds, alias); + TableMeta meta = infoService.tableMetaDetail(flinkJobId, alias); return CommandLineUtils.generateResultLines( () -> { if (ObjectUtil.isEmpty(meta)) {