Hi,

Currently the sort operator in blink planner is global, which has
bottleneck if we sort a lot of data.

And I found 'table.exec.range-sort.enabled' config in BatchExecSortRule,
which makes me very exciting.
After enabling this config, I found that it's not implemented completely
now. This config changes the distribution
 from SINGLETON to range for sort operator, however in BatchExecExchange we
do not deal with range
distribution, and will throw UnsupportedOperationException.

My question is,
1. Is this config just a mistake when we merge blink into flink, and we
actually didn't plan to implement this?
2. If this is in the plan, then which version may we expect it to be ready?


-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenc...@gmail.com; libenc...@pku.edu.cn

Reply via email to