feat: log current process record

eric666666 · Aug 22, 2024 · 72cfafd · 72cfafd
1 parent 38c9b51
commit 72cfafd
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java b/...-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcRecordStoreMultiWriteOperator.java
@@ -33,6 +33,7 @@
 import org.apache.paimon.options.Options;
 import org.apache.paimon.table.FileStoreTable;
 import org.apache.paimon.utils.ExecutorThreadFactory;
+import org.apache.paimon.utils.JsonSerdeUtil;
 
 import org.apache.flink.runtime.state.StateInitializationContext;
 import org.apache.flink.runtime.state.StateSnapshotContext;
@@ -165,7 +166,7 @@ public void processElement(StreamRecord<CdcMultiplexRecord> element) throws Exce
         try {
             write.write(optionalConverted.get());
         } catch (Exception e) {
-            throw new IOException(e);
+            throw new IOException("Error when write value" + JsonSerdeUtil.toJson(record), e);
         }
     }