[hotfix] Fix lakehouse cli name (alibaba#224)

sunxiaojian · Dec 18, 2024 · 9255d03 · 9255d03
1 parent 0e570d8
commit 9255d03
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/.../fluss/lakehouse/cli/FlussCliFronted.java → ...fluss/lakehouse/cli/FlussCliFrontend.java b/.../fluss/lakehouse/cli/FlussCliFronted.java → ...fluss/lakehouse/cli/FlussCliFrontend.java
@@ -33,12 +33,12 @@
  * PackagedProgram)} to respect the configuration key {@link PipelineOptions#JARS} so that the
  * additional jar needed to run lakehouse tiering service can be submitted to fluss cluster as well.
  */
-public class FlussCliFronted extends CliFrontend {
+public class FlussCliFrontend extends CliFrontend {
 
     // the origin flink configuration before method #executeProgram
     private final Configuration originConfiguration;
 
-    public FlussCliFronted(
+    public FlussCliFrontend(
             Configuration configuration, List<CustomCommandLine> customCommandLines) {
         super(configuration, customCommandLines);
         this.originConfiguration = configuration;

diff --git a/.../fluss-lakehouse-cli/src/main/java/com/alibaba/fluss/lakehouse/cli/FlussLakehouseCli.java b/.../fluss-lakehouse-cli/src/main/java/com/alibaba/fluss/lakehouse/cli/FlussLakehouseCli.java
@@ -130,7 +130,7 @@ private static int run(
         List<CustomCommandLine> customCommandLines = new ArrayList<>();
         customCommandLines.add(new DefaultCLI());
 
-        CliFrontend cliFrontend = new FlussCliFronted(flinkConfig, customCommandLines);
+        CliFrontend cliFrontend = new FlussCliFrontend(flinkConfig, customCommandLines);
         // let's combine fluss config and lake config as arguments
         List<String> arguments =
                 new ArrayList<>(