Apache Flink 1.11.0 Python表API目录: postgresql
通过Table API抛出UUID数据类型unsupportedOperatorException,从包含UUID数据类型列的postgresql Catalog表中读取和写入数据。
如何处理pyFlink中的UUID数据类型?
发布于 2020-10-21 10:40:44
我对PostgreSQL的类型系统了解不多。UUID数据类型是类似于字符串的类型吗?PyFlink支持的类型与Flink的表的类型基本相同。有关详细信息,请参阅document1
发布于 2020-11-06 12:17:53
看起来还没有一种优雅的方法来立即处理Postgres UUID,但一旦Table API的类型系统返工完成,就会涉及到这一点。我找到了同样的JIRA:https://issues.apache.org/jira/browse/FLINK-19869
https://stackoverflow.com/questions/64409766
复制相似问题