This is an automated email from the ASF dual-hosted git repository. voonhous pushed a commit to branch release-1.2.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit f690a22350352917bad5d1e9f724b2b50ac05453 Author: Y Ethan Guo <[email protected]> AuthorDate: Thu May 28 09:33:55 2026 -0700 fix(cli): Fix the typo in show-inflight CLI command (#18868) (cherry picked from commit ff72186936eb516f5cf18448781e21969b8a9a44) --- .../main/java/org/apache/hudi/cli/commands/CommitsCommand.java | 2 +- .../java/org/apache/hudi/cli/commands/TestCommitsCommand.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java index fa177eca9952..f2089c9d3844 100644 --- a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java +++ b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java @@ -363,7 +363,7 @@ public class CommitsCommand { limit, headerOnly, rows, exportTableName); } - @ShellMethod(key = "commits show_infights", value = "Show inflight instants that are left longer than a certain duration") + @ShellMethod(key = "commits show_inflights", value = "Show inflight instants that are left longer than a certain duration") public String showInflightCommits( @ShellOption(value = {"--lookbackInMins"}, help = "Only show inflight commits that started before the specified lookback duration (in minutes).", defaultValue = "0") final Long durationInMins) { HoodieTableMetaClient metaClient = HoodieCLI.getTableMetaClient(); diff --git a/hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestCommitsCommand.java b/hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestCommitsCommand.java index 7a0fd534309b..9c80bbd2ec80 100644 --- a/hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestCommitsCommand.java +++ b/hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestCommitsCommand.java @@ -609,7 +609,7 @@ public class TestCommitsCommand extends CLIFunctionalTestHarness { // Reload meta client to pick up new instants metaClient = HoodieTableMetaClient.reload(HoodieCLI.getTableMetaClient()); - Object lookupBackInZeroMinsResult = shell.evaluate(() -> "commits show_infights --lookbackInMins 0"); + Object lookupBackInZeroMinsResult = shell.evaluate(() -> "commits show_inflights --lookbackInMins 0"); assertTrue(ShellEvaluationResultUtil.isSuccess(lookupBackInZeroMinsResult)); // All three instants should be shown when duration is 0 @@ -619,21 +619,21 @@ public class TestCommitsCommand extends CLIFunctionalTestHarness { assertTrue(output.contains(oldInstantTime3)); // Only one instants should be shown when duration is 15 since 2nd commit is a completed commit. - Object lookupBackIn15MinsResult = shell.evaluate(() -> "commits show_infights --lookbackInMins 15"); + Object lookupBackIn15MinsResult = shell.evaluate(() -> "commits show_inflights --lookbackInMins 15"); assertTrue(ShellEvaluationResultUtil.isSuccess(lookupBackIn15MinsResult)); output = lookupBackIn15MinsResult.toString(); assertTrue(output.contains(oldInstantTime1)); assertFalse(output.contains(oldInstantTime2)); // Only one instant should be shown when duration is 50 - Object lookupBackIn50MinsResult = shell.evaluate(() -> "commits show_infights --lookbackInMins 50"); + Object lookupBackIn50MinsResult = shell.evaluate(() -> "commits show_inflights --lookbackInMins 50"); assertTrue(ShellEvaluationResultUtil.isSuccess(lookupBackIn50MinsResult)); output = lookupBackIn50MinsResult.toString(); assertTrue(output.contains(oldInstantTime1)); assertFalse(output.contains(oldInstantTime2)); // No instants should be shown when duration is > 60 - Object lookupBackIn70MinsResult = shell.evaluate(() -> "commits show_infights --lookbackInMins 70"); + Object lookupBackIn70MinsResult = shell.evaluate(() -> "commits show_inflights --lookbackInMins 70"); assertTrue(ShellEvaluationResultUtil.isSuccess(lookupBackIn70MinsResult)); output = lookupBackIn70MinsResult.toString(); assertTrue(output.contains(oldInstantTime1));
