diff --git a/chunjun-connectors/chunjun-connector-oracle/src/main/java/com/dtstack/chunjun/connector/oracle/converter/OracleSqlConverter.java b/chunjun-connectors/chunjun-connector-oracle/src/main/java/com/dtstack/chunjun/connector/oracle/converter/OracleSqlConverter.java index c79b472aac..6d1748e6a2 100644 --- a/chunjun-connectors/chunjun-connector-oracle/src/main/java/com/dtstack/chunjun/connector/oracle/converter/OracleSqlConverter.java +++ b/chunjun-connectors/chunjun-connector-oracle/src/main/java/com/dtstack/chunjun/connector/oracle/converter/OracleSqlConverter.java @@ -67,6 +67,7 @@ public OracleSqlConverter(RowType rowType) { wrapIntoNullableInternalConverter( createAsyncInternalConverter(rowType.getTypeAt(i)))); } + toInternalConverters = toAsyncInternalConverters; } protected IDeserializationConverter createAsyncInternalConverter(LogicalType type) {