yuzhaojing commented on code in PR #5890: URL: https://github.com/apache/hudi/pull/5890#discussion_r900697528
########## hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java: ########## @@ -100,15 +104,32 @@ public class ClusteringOperator extends TableStreamOperator<ClusteringCommitEven private transient AvroToRowDataConverters.AvroToRowDataConverter avroToRowDataConverter; private transient HoodieFlinkWriteClient writeClient; private transient BulkInsertWriterHelper writerHelper; - private transient String instantTime; private transient BinaryExternalSorter sorter; private transient StreamRecordCollector<ClusteringCommitEvent> collector; private transient BinaryRowDataSerializer binarySerializer; + /** + * Whether to execute compaction asynchronously. + */ + private final boolean asyncClustering; + + /** + * Executor service to execute the clustering task. + */ + private transient NonThrownExecutor executor; + + /** + * Flag saying whether the schema is initialized, + * the table may be empty when start up, in order to fetch the latest schema, + * initializes the schema lazily. + */ + private boolean initialized = false; Review Comment: Modify it, passed schema from `rowType`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
