pyflink JDBC Postgresql Catalog 对数据类型 UUID 抛出错误，如何处理 Flink Table API 中的 uuid 数据类型？答案

【问题标题】：pyflink JDBC Postgresql Catalog throwing errors for data type UUID , How to handle the uuid datatype in Flink Table API?pyflink JDBC Postgresql Catalog 对数据类型 UUID 抛出错误，如何处理 Flink Table API 中的 uuid 数据类型？
【发布时间】：2020-10-18 04:33:34
【问题描述】：

Apache Flink 1.11.0 Python 表 API 目录：postgresql

通过 Table API 从包含 UUID 数据类型列的 postgresql 目录表中读取和写入数据，抛出 UUID 数据类型 unsupportedOperatorException。

pyFlink 中如何处理 UUID 数据类型？

【问题讨论】：

标签： postgresql apache-flink pyflink flink-table-api

【解决方案1】：

我对 PostgreSQL 的类型系统了解不多。 UUID 数据类型是类似于字符串的类型吗？ PyFlink 支持的类型与 Flink 的 Table 类型基本一致。具体可以参考文档[1]

[1]https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/python/table-api-users-guide/python_types.html

【讨论】：

【解决方案2】：

看起来目前还没有一种优雅的方式来处理 Postgres UUID，但是一旦 Table API 的类型系统返工完成，就会涉及到这一点。我找到了相同的 JIRA：https://issues.apache.org/jira/browse/FLINK-19869

【讨论】：