Danny Chan

Results 335 comments of Danny Chan
trafficstars

@lokeshj1703 Thanks for the contribution, I have reviewed and created a patch: [7779.patch.zip](https://github.com/user-attachments/files/16276593/7779.patch.zip)

@SML0127 Flink does not support inline clustering but only async plan scheduling for consistent-hashing, you need to execute the plan in a separate job. ```java hudiOptions.put(HoodieClusteringConfig.INLINE_CLUSTERING.key(), "true"); ```

Flink never supprts any inline table services because the DAG of Flink operators are kind of deterministic during compile time. The case Flink does not support async clustering simultaniously with...

A "inline" table service indicates it is executed synchonously after each commit, instead, we do support async compaction and clustering in the ingestion job for both plan scheduling and execution.