Flink SQL 是否支持并行运行投影

Question

我正在运行一个带有多个预测的 SQL，每个都非常耗时，例如：

SELECT UDF1(id), UDF2(id) 
FROM prod

UDF1 和 UDF2 可能是耗时的函数，但是 Flink SQL 看起来是顺序运行 UDF1 和 UDF2，我的问题是 UDF1 和 UDF2 是否可以并行运行以减少延迟？

Answer 1

不支持在不同线程中并行评估标量 UDF。

不过，这可能是一个有趣的功能。请创建 Jira 问题或在 Flink 的开发邮件列表上开始讨论。