From d07c904c8dc7c20311325f45f20ce4b86ccb0ad3 Mon Sep 17 00:00:00 2001 From: zhangboya1 <49148006+zhangboya1@users.noreply.github.com> Date: Sun, 6 Jun 2021 22:06:57 +0800 Subject: [PATCH] [Log] Fix a mistake in DorisDynamicOutputFormat.java (#5963) Fix a mistake DorisDynamicOutputFormat.java --- .../org/apache/doris/flink/table/DorisDynamicOutputFormat.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java b/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java index baa7b07f2..44880b555 100644 --- a/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java +++ b/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java @@ -70,7 +70,7 @@ public void open(int taskNumber, int numTasks) throws IOException { options.getTableIdentifier().split("\\.")[1], options.getUsername(), options.getPassword()); - LOG.info("Steamload BE:{}",dorisStreamLoad.getLoadUrlStr()); + LOG.info("Streamload BE:{}",dorisStreamLoad.getLoadUrlStr()); } @Override