This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new ff72186936eb fix(cli): Fix the typo in show-inflight CLI command
(#18868)
ff72186936eb is described below
commit ff72186936eb516f5cf18448781e21969b8a9a44
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)
---
.../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));