[PR] [hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents]

["wenjin272 (via GitHub)" <gi...@apache.org>]

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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] [hotfix][runtime] Reject raw bytes from PyFlink inputs [flink-agents]

["wenjin272 (via GitHub)" <gi...@apache.org>]

wenjin272 merged PR #1075:
URL: https://github.com/apache/flink-agents/pull/1075


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org