[FLINK-9565] Evaluating scalar UDFs in parallel

• Type: New Feature
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.4.2
• Component/s: Table SQL / API
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: yinhua.dai
• Created: 11/Jun/18 08:07
• Updated: 07/Dec/21 22:38

Description

As per https://stackoverflow.com/questions/50790023/does-flink-sql-support-to-run-projections-in-parallel, scalar UDF in the same SQL is always evaluated sequentially even when those UDF are irrelevant, it may increase latency when the UDF is time consuming function.

It would be great if Flink SQL can support to run those UDF in parallel to reduce calculation latency.

 

cc fhueske