[BugFix][Postgres][DTStack#1463] The cast is bad, only when 'rowConve…

…rter' instance of the 'JdbcColumnConverter' should cast.
FlechazoW · Jan 5, 2023 · 95bfcec · 95bfcec
1 parent 3c72eae
commit 95bfcec
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...sql/src/main/java/com/dtstack/chunjun/connector/postgresql/sink/PostgresOutputFormat.java b/...sql/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);
  }