Skip to content

Commit 9255d03

Browse files
authored
[hotfix] Fix lakehouse cli name (alibaba#224)
1 parent 0e570d8 commit 9255d03

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

fluss-lakehouse/fluss-lakehouse-cli/src/main/java/com/alibaba/fluss/lakehouse/cli/FlussCliFronted.java fluss-lakehouse/fluss-lakehouse-cli/src/main/java/com/alibaba/fluss/lakehouse/cli/FlussCliFrontend.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -33,12 +33,12 @@
3333
* PackagedProgram)} to respect the configuration key {@link PipelineOptions#JARS} so that the
3434
* additional jar needed to run lakehouse tiering service can be submitted to fluss cluster as well.
3535
*/
36-
public class FlussCliFronted extends CliFrontend {
36+
public class FlussCliFrontend extends CliFrontend {
3737

3838
// the origin flink configuration before method #executeProgram
3939
private final Configuration originConfiguration;
4040

41-
public FlussCliFronted(
41+
public FlussCliFrontend(
4242
Configuration configuration, List<CustomCommandLine> customCommandLines) {
4343
super(configuration, customCommandLines);
4444
this.originConfiguration = configuration;

fluss-lakehouse/fluss-lakehouse-cli/src/main/java/com/alibaba/fluss/lakehouse/cli/FlussLakehouseCli.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ private static int run(
130130
List<CustomCommandLine> customCommandLines = new ArrayList<>();
131131
customCommandLines.add(new DefaultCLI());
132132

133-
CliFrontend cliFrontend = new FlussCliFronted(flinkConfig, customCommandLines);
133+
CliFrontend cliFrontend = new FlussCliFrontend(flinkConfig, customCommandLines);
134134
// let's combine fluss config and lake config as arguments
135135
List<String> arguments =
136136
new ArrayList<>(

0 commit comments

Comments
 (0)