add log

hyperpaas · Aug 23, 2024 · 6eda5ff · 6eda5ff
1 parent 7d062f8
commit 6eda5ff
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...rc/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataWithMetaSerializer.java b/...rc/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataWithMetaSerializer.java
@@ -72,6 +72,7 @@ public DorisRecord serialize(RowDataWithMeta meta) throws IOException {
     } else {
       throw new IllegalArgumentException("The type " + type + " is not supported!");
     }
+    LOG.info("rowDataWithMeta serialize success, valString:{}", valString);
     return DorisRecord.of(
         meta.getDatabase(), meta.getTable(), valString.getBytes(StandardCharsets.UTF_8));
   }