[jira] [Commented] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

[Jane Chan (Jira)]

Title: Message Title

Jane Chan commented on FLINK-26051   Re: one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode Sorry for the late reply. The reason why FlinkLogicalRankRuleForRangeEnd is not matched is due to the null condition(See FlinkLogicalRankRuleForRangeEnd#L177), which caused by the following two nested calc node. FlinkLogicalSink(table=[default_catalog.default_database.oprms_order_base_order_item_one_group], fields=[order_id, item_no, parent_type, fed_sku_total_price, foodbox_total_price, update_time]) +- FlinkLogicalCalc(select=[order_id, item_no, parent_type, fed_sku_total_price, foodbox_total_price, CAST(LOCALTIMESTAMP() AS TIMESTAMP(6)) AS update_time])    +- FlinkLogicalAggregate(group=[{0, 1, 2}], fed_sku_total_price=[SUM($3)], foodbox_total_price=[SUM($4)])       +- FlinkLogicalCalc(select=[order_id, item_no_p2 AS item_no, parent_type_p2 AS parent_type, IF(=(parent_type_p1, 2), *(IF(=(is_combo, 1), spu_count, 1), original_total_price), 0) AS $f3, IF(=(parent_type_p1, 5), *(IF(=(is_combo, 1), spu_count, 1), original_total_price), 0) AS $f4], where=[AND(=(w0$o0, 1:BIGINT), ob_retract_flag, ot1_retract_flag, ot2_retract_flag)])          +- FlinkLogicalCalc(select=[order_id, item_no_p2, parent_type_p2, is_combo, spu_count, original_total_price, parent_type_p1, ob_retract_flag, ot1_retract_flag, ot2_retract_flag, w0$o0])             +- FlinkLogicalOverAggregate(window#0=[window(partition {0, 7} order by [12 DESC-nulls-last, 14 DESC-nulls-last, 15 DESC-nulls-last] rows between UNBOUNDED PRECEDING and CURRENT ROW aggs [ROW_NUMBER()])])                +- FlinkLogicalCalc(select=[order_id, item_no_p2, parent_type_p2, is_combo, spu_count, original_total_price, parent_type_p1, item_no_p1, update_time, ob_retract_flag, ot1_retract_flag, ot2_retract_flag, order_version, ____retract_flag, ____emit_time, ____emit_order], where=[____retract_flag])                   +- FlinkLogicalTableSourceScan(table=[[default_catalog, default_database, oprms_order_base_order_item_one]], fields=[order_id, item_no_p2, parent_type_p2, is_combo, spu_count, original_total_price, parent_type_p1, item_no_p1, update_time, ob_retract_flag, ot1_retract_flag, ot2_retract_flag, order_version, ____retract_flag, ____emit_time, ____emit_order]) The calc nodes are not merged because CommonCalc cannot produce right CPU cost for computations. cc godfrey he  Add Comment   This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9)