cshuo opened a new issue, #19538: URL: https://github.com/apache/hudi/issues/19538
### Problem The DAG builders and shared utilities in `hudi-flink-datasource/hudi-flink` have insufficient direct unit-test coverage. Important configuration, data type, serialization, time-wait, compaction, and pipeline assembly paths are not exercised consistently. ### Scope Improve unit coverage for: - `sink/utils/Pipelines.java` - `util/HoodiePipeline.java` - `util/StreamerUtil.java` - `sink/utils/TimeWait.java` - `sink/utils/CoordinationResponseSerDe.java` - `util/CompactionUtil.java` - `util/DataTypeUtils.java` For pipeline builders, validate the assembled operator graph, including transformation names and parallelism, without requiring full end-to-end job execution. ### Acceptance criteria - Add focused unit tests for configuration, data types, serialization, time-wait behavior, and compaction helpers. - Cover the major pipeline assembly modes, including bucket bulk-insert graph variants. - Bring each listed utility or pipeline class to at least 80% line coverage. - Keep the changes test-only with no public API or runtime behavior changes. -- 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]
