Fix a typo

Signed-off-by: jaden <[email protected]> Signed-off-by: Jiandong Chen <[email protected]>
StarRocks · Apr 18, 2024 · 8847f57 · 8847f57
1 parent ba84f11
commit 8847f57
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksDynamicSinkFunction.java b/src/main/java/com/starrocks/connector/flink/table/sink/StarRocksDynamicSinkFunction.java
@@ -107,7 +107,7 @@ public synchronized void invoke(T value, Context context) throws Exception {
             if (value instanceof StarRocksSinkRowDataWithMeta) {
                 StarRocksSinkRowDataWithMeta data = (StarRocksSinkRowDataWithMeta)value;
                 if (Strings.isNullOrEmpty(data.getDatabase()) || Strings.isNullOrEmpty(data.getTable()) || null == data.getDataRows()) {
-                    LOG.warn(String.format("json row data not fullfilled. {database: %s, table: %s, dataRows: %s}", data.getDatabase(), data.getTable(), data.getDataRows()));
+                    LOG.warn(String.format("json row data not fulfilled. {database: %s, table: %s, dataRows: %s}", data.getDatabase(), data.getTable(), data.getDataRows()));
                     return;
                 }
                 sinkManager.writeRecords(data.getDatabase(), data.getTable(), data.getDataRows());