flink-cdc
flink-cdc copied to clipboard
[oceanbase] fix npe in getTableSchema from UPDATE logmessage
Half of the elements in columnNames will be null if we try to generate table schema from a UPDATE type log message, so we should skip these null values when create column instances.
@whhe Are there some tests that already produce this error?
@whhe Are there some tests that already produce this error?
There is a user in the DingTalk group of Flink CDC who meets this issue, it's not covered by the integration tests for now.
BTW, this fix will not be required after #1356 is merged.