Поддерживает ли Flink SQL параллельное выполнение проекций?

Question

Я запускаю SQL с несколькими проекциями, каждый из которых отнимает много времени, например:

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

UDF1 и UDF2 могут занимать много времени, но похоже, что Flink SQL выполняет UDF1 и UDF2 последовательно,У меня вопрос, могут ли UDF1 и UDF2 работать параллельно, чтобы уменьшить задержку?

Answer 1

Параллельная оценка скалярных пользовательских функций в разных потоках не поддерживается.

Однако это может быть интересной функцией.Пожалуйста, создайте проблему Jira или начните обсуждение в списке рассылки Флинка.