Hi When i look for what kind of optimizations flink does, i found https://cwiki.apache.org/confluence/display/FLINK/Optimizer+Internals is it up to date? Also i couldnt understand:
"Reusing of partitionings and sort orders across operators. If one operator leaves the data in partitioned fashion (and or sorted order), the next operator will automatically try and reuse these characteristics. The planning for this is done holistically and can cause earlier operators to pick more expensive algorithms, if they allow for better reusing of sort-order and partitioning." Can you give example for "earlier operators to pick more expensive algorithms" ? Regards