wenjin272 opened a new pull request, #1075:
URL: https://github.com/apache/flink-agents/pull/1075
Linked issue: N/A (hotfix)
### Purpose of change
Python agent execution expects input values to use PyFlink's default pickle
representation, but this contract was not enforced at the Java bridge. As a
result, explicitly typed inputs could reach the bridge in an unsupported
representation.
This change validates the PyFlink keyed-stream input type before constructing
the agent operator. It accepts values described by `PickledByteArrayTypeInfo`
and rejects raw byte-array and other explicitly typed values with an
actionable
error. The Row-field validation is shared by the existing key check and the
new
value check.
### Tests
- `mvn --batch-mode --no-transfer-progress -pl runtime -am test`
- API: 376 tests, 0 failures, 0 errors, 11 skipped.
- Plan: 288 tests, 0 failures, 0 errors, 1 skipped.
- Runtime: 751 tests, 0 failures, 0 errors, 0 skipped.
- Inspected real PyFlink graph types: explicitly typed raw bytes use
`PrimitiveArrayTypeInfo`, while default Python objects use
`PickledByteArrayTypeInfo`.
- `git diff --check`
### API
No public APIs are changed. Unsupported raw byte-array inputs now fail early
with guidance to convert them through a Python operator using the default
pickle output type.
### Documentation
- [ ] `doc-needed`
- [x] `doc-not-needed`
- [ ] `doc-included`
### Was this patch authored or co-authored using generative AI tooling?
- [x] Yes
- [ ] No
Generated-by: OpenAI Codex 0.144.5 (GPT-5)
--
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]
