JNSimba opened a new pull request, #701: URL: https://github.com/apache/doris-flink-connector/pull/701
# Proposed changes Issue Number: N/A ## Problem Summary: When automatic redirect is enabled without explicit BE nodes, the connector uses FE nodes as stream load endpoints. Repeated health checks during backend selection can block checkpoints when an FE is unreachable. This change filters unavailable FE nodes once when `BackendUtil` is initialized and keeps the existing round-robin selection and Flink recovery behavior afterward. Explicit BE nodes and discovered BE nodes retain their existing health-check behavior. Writer, committer, and batch stream load now use the same `BackendUtil` creation path. ## Checklist(Required) 1. Does it affect the original behavior: Yes 2. Has unit tests been added: Yes 3. Has document been added or modified: No Need 4. Does it need to update dependencies: No 5. Are there any changes that cannot be rolled back: No ## Testing - `mvn -o -Pflink1 -pl flink-doris-connector-base test` - `mvn -o -Pflink2 -pl flink-doris-connector-base -Dtest=TestBackendUtil,TestDorisWriter,TestDorisCommitter,TestDorisBatchStreamLoad,TestDorisBatchWriter test` - `mvn -o -Pflink1 -pl flink-doris-connector-flink1 -am -Dtest=DorisSinkTest -Dsurefire.failIfNoSpecifiedTests=false test` - `mvn -o -Pflink2 -pl flink-doris-connector-flink2 -am -Dtest=DorisSinkTest -Dsurefire.failIfNoSpecifiedTests=false test` -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
