@Override
    public String genTableName() {
        return String.format("table_%s", super.getId());
    }
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/PostgresLoadNode.java