[FLINK-27797] PythonTableUtils.getCollectionInputFormat cannot correctly handle None values

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.0
• Fix Version/s: 1.15.1
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: EMing Zhou
• Reporter: Yunfeng Zhou
• Created: 26/May/22 07:31
• Updated: 01/Jun/22 12:50
• Resolved: 01/Jun/22 12:50

Description

In `PythonTableUtils.getCollectionInputFormat` there are implementations like follows.
This code can be found at https://github.com/apache/flink/blob/8488368b86a99a064446ca74e775b67ffff0b94a/flink-python/src/main/java/org/apache/flink/table/utils/python/PythonTableUtils.java#L515

```
c -> {
if (c.getClass() != byte[].class || dataType instanceof PickledByteArrayTypeInfo)

{ return c; }

```

Here, the generated function did not check `c != null` before doing `c.getClass()`. which might cause that tables created through pyflink cannot parse it when values are `None`.

Issue Links

• links to: GitHub Pull Request #19834