dianfu commented on code in PR #20499:
URL: https://github.com/apache/flink/pull/20499#discussion_r941447936
##########
flink-python/pyflink/fn_execution/coders.py:
##########
@@ -725,13 +725,17 @@ def from_type_info_proto(type_info):
return RowCoder(
[from_type_info_proto(f.field_type) for f in
type_info.row_type_info.fields],
[f.field_name for f in type_info.row_type_info.fields])
- elif field_type_name == type_info_name.PRIMITIVE_ARRAY:
+ elif field_type_name in (
+ type_info_name.PRIMITIVE_ARRAY,
Review Comment:
Could you describe a bit more about the bug? What's the effect? How to
reproduce it? Besides, it would be great to create separate tickets and PRs for
bug fixes as the update code was there since Flink 1.14 and we may need to
backport this fix to prior release if it's indeed a bug.
--
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]
