rosemarYuan opened a new pull request, #713: URL: https://github.com/apache/flink-agents/pull/713
- Python: check content presence in joined output instead of positional indexing, since StreamingFileSink + checkpoint may produce multiple part files whose iterdir() order is non-deterministic. - Java: add requestTimeout=240 to pythonChatModelConnection to prevent timeouts on slow CI runners. <!-- * Thank you very much for contributing to Flink Agents. * Please add the relevant components in the PR title. E.g., [api], [runtime], [java], [python], [hotfix], etc. --> Linked issue: N/A (CI flaky test fix) ### Purpose of change Fix flaky `YamlCrossLanguageTest` Python e2e test that fails intermittently. Root cause: `StreamingFileSink` produces multiple part files across checkpoints, and `Path.iterdir()` returns them in non-deterministic order. The original assertion checked content by positional index, which is unreliable. ### Tests Existing e2e test `yaml_cross_language_test.py` — this PR fixes its flakiness. No new tests needed. ### API No public API changes. ### Documentation - [x] `doc-not-needed` -- 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]
