@Override
    public void open() throws Exception {
        super.open();

        final String operatorID = getRuntimeContext().getOperatorUniqueID();
        this.workerPool =
                ThreadPools.newWorkerPool("iceberg-worker-pool-" + operatorID, workerPoolSize);
    }
Write all the complete data files to a newly created manifest file and return the manifest's
avro serialized bytes.
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/IcebergFilesCommitter.java