diff --git a/chunjun-connectors/chunjun-connector-postgresql/src/main/java/com/dtstack/chunjun/connector/postgresql/sink/PostgresOutputFormat.java b/chunjun-connectors/chunjun-connector-postgresql/src/main/java/com/dtstack/chunjun/connector/postgresql/sink/PostgresOutputFormat.java
index a5dd6f4601..8e3f69629a 100644
--- a/chunjun-connectors/chunjun-connector-postgresql/src/main/java/com/dtstack/chunjun/connector/postgresql/sink/PostgresOutputFormat.java
+++ b/chunjun-connectors/chunjun-connector-postgresql/src/main/java/com/dtstack/chunjun/connector/postgresql/sink/PostgresOutputFormat.java
@@ -88,10 +88,12 @@ protected void openInternal(int taskNumber, int numTasks) {
                 LOG.info("write sql:{}", copySql);
             }
             checkUpsert();
-            if (jdbcDialect.dialectName().equals("PostgreSQL")) {
-                ((PostgresqlColumnConverter) rowConverter).setConnection((BaseConnection) dbConn);
+            if (rowConverter instanceof JdbcColumnConverter) {
+                if (jdbcDialect.dialectName().equals("PostgresSQL")) {
+                    ((PostgresqlColumnConverter) rowConverter).setConnection((BaseConnection) dbConn);
+                }
+                ((PostgresqlColumnConverter) rowConverter).setFieldTypeList(columnTypeList);
             }
-            ((PostgresqlColumnConverter) rowConverter).setFieldTypeList(columnTypeList);
         } catch (SQLException sqe) {
             throw new IllegalArgumentException("checkUpsert() failed.", sqe);
         }