Re: manual scaling with savepoint

Thanks for your detail explanation. -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/manual-scaling-with-savepoint-tp10974p10995.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

manual scaling with savepoint

Hi, everyone. Now, Flink can't do with auto-scaling and we can realize this by restart the savepoint with different parallelism. I wonder how flink handle with state managerment. For example, for parallelism=3 to 4, how the state of 3 deal with new parallelism? Can you explain the internal to me ?

Re: Logical plan optimization with Calcite

Thanks Max and Timo for the explanation. :) -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Logical-plan-optimization-with-Calcite-tp8037p8106.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Logical plan optimization with Calcite

;a, 'b, 'c) val filterDs = ds.filter( 'a % 2 === 0 ).filter( 'a % 3 === 0 ) Would the filter condition be optimized to filter('a % 6 === 0) by the calcite or by flink internal optimization rule? Thanks, gallenvara -- View this message in context: http://apache-flink-u