danny0405 opened a new pull request, #19392: URL: https://github.com/apache/hudi/pull/19392
### Describe the issue this Pull Request addresses Several unit-testable configuration, streamer wiring, option resolution, and schema provider classes in `hudi-flink` had low or no line coverage. This left option parsing and validation, derived configuration, schema loading, and schema registry behavior largely unverified outside integration tests. ### Summary and Changelog - Add representative JCommander parsing and derived-configuration assertions for the Flink streamer, clustering, and compaction configuration classes. - Exercise the Flink streamer entry-point wiring with mocked pipelines and execution environment while leaving the run loop to integration coverage. - Expand option inference and resolution tests across task derivation, table modes, write operations, conflict strategies, partitioners, and buffer settings. - Add file-based schema provider tests for source, target, fallback, and failure behavior. - Add schema registry provider tests with mocked HTTP responses and authorization verification. Local JaCoCo unit coverage before and after: | Class | Before | After | | --- | ---: | ---: | | `FlinkStreamerConfig` | 0% | 100.0% (248/248) | | `FlinkClusteringConfig` | 0% | 97.8% (89/91) | | `FlinkCompactionConfig` | 66% | 97.3% (73/75) | | `HoodieFlinkStreamer` | 0% | 80.9% (38/47) | | `OptionsInference` | 13% | 81.4% (35/43) | | `OptionsResolver` | 74% | 83.5% (152/182) | | `SchemaRegistryProvider` | 0% | 97.0% (32/33) | | `FilebasedSchemaProvider` | 20% | 91.7% (22/24) | No code was copied. ### Impact No public API, runtime behavior, configuration default, or performance impact. The change is limited to `hudi-flink` unit tests and should improve the Flink unit-test Codecov upload. ### Risk Level none ### Documentation Update none ### Contributor's checklist - [x] Read through [contributor's guide](https://hudi.apache.org/contribute/how-to-contribute) - [x] Enough context is provided in the sections above - [x] Adequate tests were added if applicable ### Testing - Focused coverage run: 35 tests, 0 failures, 0 errors. - Full `hudi-flink` unit suite: 1,372 tests, 0 failures, 0 errors, 1 skipped. - Maven checkstyle: 0 violations. -- 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]
