From 8847f5769b477b8b85231a2254f7a12ff4ba3a32 Mon Sep 17 00:00:00 2001 From: jaden Date: Thu, 18 Apr 2024 10:30:16 +0800 Subject: [PATCH] Fix a typo Signed-off-by: jaden Signed-off-by: Jiandong Chen --- .../flink/table/sink/StarRocksDynamicSinkFunction.java | 2 +- 1 file changed, 1 insertion(+), 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 index 201502f5..6bb1888e 100644 --- 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());