apache-flink - Flink SQL 是否支持并行运行投影

Question

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

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

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

标签： apache-flinkflink-sql

Answer 1

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

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