udf 映射函数 returns 具有未命名模式的 table

Question

代码：

func = udf(log_parser, result_type=DataTypes.ROW(
                                     [DataTypes.FIELD("ts", DataTypes.TIMESTAMP(precision=3)),
                                      DataTypes.FIELD("clientip", DataTypes.STRING()),
                                      DataTypes.FIELD("recordtime", DataTypes.STRING())]))
table = table.map(func)
table.print_schema()

输出：

(
  `_c0` TIMESTAMP(3),
  `_c1` STRING,
  `_c2` STRING
)

这对我来说很奇怪，它不应该打印一个定义了列名的模式吗？

Answer 1

这是一个已知问题，应该在 FLINK-27282 中解决。它最近已修复，因此仍未发布。

udf 映射函数 returns 具有未命名模式的 table

udf map function returns a table with unnamed schema

pyflink