wForget commented on issue #2389: URL: https://github.com/apache/datafusion-comet/issues/2389#issuecomment-3291287147
This plan should match the fix `ReusedExchange [s_store_sk#246], CometBroadcastExchange [s_store_sk#45]` ``` [broadcast-exchange-2] Total RDDs prepared for zipping: 1 [broadcast-exchange-2] ----------------------------------------------------------------- [broadcast-exchange-2] --> Input RDD #0 (partitions: 1) [broadcast-exchange-2] Plan Origin: CometExchange (unknown) [broadcast-exchange-2] Plan Output Partitioning: SinglePartition [broadcast-exchange-2] Plan Tree: [broadcast-exchange-2] CometExchange SinglePartition, ENSURE_REQUIREMENTS, CometNativeShuffle, [plan_id=8306] [broadcast-exchange-2] +- !CometHashAggregate Partial, [partial_count(1)] [broadcast-exchange-2] +- CometProject [broadcast-exchange-2] +- CometBroadcastHashJoin [ss_store_sk#215], [s_store_sk#246], Inner, BuildRight [broadcast-exchange-2] :- CometProject [ss_store_sk#215], [ss_store_sk#215] [broadcast-exchange-2] : +- CometBroadcastHashJoin [ss_sold_time_sk#209], [t_time_sk#236], Inner, BuildRight [broadcast-exchange-2] : :- CometProject [ss_sold_time_sk#209, ss_store_sk#215], [ss_sold_time_sk#209, ss_store_sk#215] [broadcast-exchange-2] : : +- CometBroadcastHashJoin [ss_hdemo_sk#213], [hd_demo_sk#231], Inner, BuildRight [broadcast-exchange-2] : : :- CometFilter [ss_sold_time_sk#209, ss_hdemo_sk#213, ss_store_sk#215], ((isnotnull(ss_hdemo_sk#213) AND isnotnull(ss_sold_time_sk#209)) AND isnotnull(ss_store_sk#215)) [broadcast-exchange-2] : : : +- CometBatchScan spark_catalog.training.store_sales[ss_sold_time_sk#209, ss_hdemo_sk#213, ss_store_sk#215] spark_catalog.training.store_sales (branch=null) [filters=ss_hdemo_sk IS NOT NULL, ss_sold_time_sk IS NOT NULL, ss_store_sk IS NOT NULL, groupedBy=] RuntimeFilters: [] [broadcast-exchange-2] : : +- ReusedExchange [hd_demo_sk#231], CometBroadcastExchange [hd_demo_sk#30] [broadcast-exchange-2] : +- CometBroadcastExchange [t_time_sk#236] [broadcast-exchange-2] : +- CometProject [t_time_sk#236], [t_time_sk#236] [broadcast-exchange-2] : +- CometFilter [t_time_sk#236, t_hour#239, t_minute#240], ((((isnotnull(t_hour#239) AND isnotnull(t_minute#240)) AND (t_hour#239 = 10)) AND (t_minute#240 >= 30)) AND isnotnull(t_time_sk#236)) [broadcast-exchange-2] : +- CometBatchScan spark_catalog.training.time_dim[t_time_sk#236, t_hour#239, t_minute#240] spark_catalog.training.time_dim (branch=null) [filters=t_hour IS NOT NULL, t_minute IS NOT NULL, t_hour = 10, t_minute >= 30, t_time_sk IS NOT NULL, groupedBy=] RuntimeFilters: [] [broadcast-exchange-2] +- ReusedExchange [s_store_sk#246], CometBroadcastExchange [s_store_sk#45] ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
