@Override
    public synchronized void flush() throws IOException {
        // when batch count > 0, execute flush operation
        if (batchCount == 0) {
            return;
        }
        checkFlushException();
        attemptFlush();
        batchCount = 0;
    }
Convert fieldMap(data) to GenericRowData with rowType(schema)
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java