@Override
    public Map<String, String> tableOptions() {
        Map<String, String> options = super.tableOptions();
        options.put(PostgresConstant.CONNECTOR, PostgresConstant.JDBC_INLONG);
        options.put(PostgresConstant.URL, url);
        options.put("dialect-impl", "org.apache.inlong.sort.jdbc.dialect.GreenplumDialect");
        options.put(PostgresConstant.USERNAME, username);
        options.put(PostgresConstant.PASSWORD, password);
        options.put(PostgresConstant.TABLE_NAME, tableName);
        return options;
    }
Please declare primary key for sink table when query contains update/delete record if your version support
upsert. You can change source stream mode is "append" if your version can't support upsert.
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/GreenplumLoadNode.java