[jira] [Created] (FLINK-33791) Fix NPE when array is null in PostgresArrayConverter in flink-connector-jdbc

["JingWei Li (Jira)" <ji...@apache.org>]

JingWei Li created FLINK-33791:
----------------------------------

             Summary: Fix NPE when array is null in PostgresArrayConverter in flink-connector-jdbc
                 Key: FLINK-33791
                 URL: https://issues.apache.org/jira/browse/FLINK-33791
             Project: Flink
          Issue Type: Bug
          Components: Connectors / JDBC
            Reporter: JingWei Li


{code:java}
// private JdbcDeserializationConverter createPostgresArrayConverter(ArrayType arrayType) {
    // Since PGJDBC 42.2.15 (https://github.com/pgjdbc/pgjdbc/pull/1194) bytea[] is wrapped in
    // primitive byte arrays
    final Class<?> elementClass =
            LogicalTypeUtils.toInternalConversionClass(arrayType.getElementType());
    final JdbcDeserializationConverter elementConverter =
            createNullableInternalConverter(arrayType.getElementType());
    return val -> {
        @SuppressWarnings("unchecked")
        T pgArray = (T) val;
        Object[] in = (Object[]) pgArray.getArray();
        final Object[] array = (Object[]) Array.newInstance(elementClass, in.length);
        for (int i = 0; i < in.length; i++) {
            array[i] = elementConverter.deserialize(in[i]);
        }
        return new GenericArrayData(array);
    };
} {code}
When use this method, array is null pgArray.getArray() will throw NPE。



--
This message was sent by Atlassian Jira
(v8.20.10#820010)