cshuo opened a new issue, #19397: URL: https://github.com/apache/hudi/issues/19397
## Description Improve unit test coverage for the Flink clustering and compaction operators and update strategy in `hudi-flink-datasource/hudi-flink`. The following classes have low or missing line coverage: - `sink/clustering/ClusteringOperator.java` (49%) - `sink/clustering/ClusteringCommitSink.java` (64%) - `sink/clustering/update/strategy/FlinkConsistentBucketUpdateStrategy.java` (0%) - `sink/compact/CompactionPlanSourceFunction.java` (0%) ## Scope Add unit-level tests using the Flink operator test harness where applicable, covering: - synchronous and asynchronous clustering execution - base-file and file-slice-with-logs reads - clustering sort execution - clustering commit, rollback, and inline cleaning - consistent-bucket dual-write routing and state refresh - compaction plan emission only for pending compaction instants `HoodieFlinkClusteringJob` and `HoodieFlinkCompactor` are exercised by integration tests and remain tracked separately by ENG-44609 because that coverage is not currently uploaded. ## Acceptance criteria - Each of the four operator/strategy classes reaches at least 75% line coverage on Codecov. - Targeted tests pass in the `hudi-flink` Maven module. - The pull request reports before/after per-class coverage. -- 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]
