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

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

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

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


apache-flink flink-sql
person yinhua    schedule 11.06.2018    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Оценка скалярных UDF параллельно в разных потоках не поддерживается.

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

person Fabian Hueske    schedule 11.06.2018