我正在运行一个包含多个投影的sql，每个投影都非常耗时，例如：
SELECT UDF1(id), UDF2(id) FROM prod
udf1和udf2可能是一个耗时的函数，但看起来flink sql是按顺序运行udf1和udf2的，我的问题是udf1和udf2是否可以并行运行以减少延迟？
daupos2t1#
不支持在不同线程中并行计算标量UDF。不过，这可能是一个有趣的特性。请创建一个jira问题或开始讨论flink的dev邮件列表。
1条答案
按热度按时间daupos2t1#
不支持在不同线程中并行计算标量UDF。
不过，这可能是一个有趣的特性。请创建一个jira问题或开始讨论flink的dev邮件列表。