ERROR ApplicationMaster: User class threw exception: org.apache.spark.sql.catalyst.errors.package$TreeNodeException: execute, tree: Exchange SinglePartition

19/09/27 10:03:29 ERROR ApplicationMaster: User class threw exception: org.apache.spark.sql.catalyst.errors.package$TreeNodeException: execute, tree:
Exchange SinglePartition
+- *Project [vid#5 AS vid#870, phone#1 AS phone#871, owner#0 AS owner#872, vehicle_count#2L AS vehicle_count#873L, daka_user#3 AS daka_user#874, abbreviate#4 AS abbreviate#875, car_number#6 AS car_number#876, color#7 AS color#877, vehicle_type#8 AS vehicle_type#878, drivecard_register_date#9 AS drivecard_register_date#879, drivecard_release_date#10 AS drivecard_release_date#880, network_time#11 AS network_time#881, coalesce(thr_day_mile#663, 0.0) AS thr_day_mile#882, coalesce(one_week_mile#664, 0.0) AS one_week_mile#883, coalesce(one_month_mile#665, 0.0) AS one_month_mile#884, coalesce(thr_month_mile#666, 0.0) AS thr_month_mile#885, coalesce(half_year_mile#667, 0.0) AS half_year_mile#886, coalesce(one_year_mile#668, 0.0) AS one_year_mile#887, owner_masking#12 AS owner_masking#888, phone_masking#13 AS phone_masking#889, car_number_masking#14 AS car_number_masking#890, 1569549798760000 AS create_time#915, 1569549798760000 AS update_time#916]
   +- SortMergeJoin [vid#5], [vid#662], LeftOuter
      :- *Sort [vid#5 ASC NULLS FIRST], false, 0
      :  +- Exchange hashpartitioning(vid#5, 400)
      :     +- InMemoryTableScan [owner#0, phone#1, vehicle_count#2L, daka_user#3, abbreviate#4, vid#5, car_number#6, color#7, vehicle_type#8, drivecard_register_date#9, drivecard_release_date#10, network_time#11, owner_masking#12, phone_masking#13, car_number_masking#14]
      :           +- InMemoryRelation [owner#0, phone#1, vehicle_count#2L, daka_user#3, abbreviate#4, vid#5, car_number#6, color#7, vehicle_type#8, drivecard_register_date#9, drivecard_release_date#10, network_time#11, owner_masking#12, phone_masking#13, car_number_masking#14], true, 10000, StorageLevel(disk, memory, deserialized, 1 replicas), user_vehicle_info
      :                 +- *Project [owner#15 AS owner#0, phone#16 AS phone#1, vehicle_count#28L AS vehicle_count#2L, coalesce(daka_user#29, 非大卡用户) AS daka_user#3, abbreviate#18 AS abbreviate#4, vid#17 AS vid#5, car_number#19 AS car_number#6, color#20 AS color#7, vehicle_type#21 AS vehicle_type#8, drivecard_register_date#22 AS drivecard_register_date#9, drivecard_release_date#23 AS drivecard_release_date#10, network_time#24 AS network_time#11, owner_masking#25 AS owner_masking#12, phone_masking#26 AS phone_masking#13, car_number_masking#27 AS car_number_masking#14]
      :                    +- SortMergeJoin [phone#16], [phone#311], LeftOuter
      :                       :- *Project [owner#15, phone#16, vid#17, abbreviate#18, car_number#19, color#20, vehicle_type#21, drivecard_register_date#22, drivecard_release_date#23, network_time#24, owner_masking#25, phone_masking#26, car_number_masking#27, vehicle_count#28L]
      :                       :  +- SortMergeJoin [phone#16], [vehicle_owner_phone#215], LeftOuter
      :                       :     :- *Sort [phone#16 ASC NULLS FIRST], false, 0
      :                       :     :  +- Exchange hashpartitioning(phone#16, 400)
      :                       :     :     +- *Project [owner#97 AS owner#15, vehicle_owner_phone#78 AS phone#16, vid#30 AS vid#17, substring(car_number_masking#32, 1, 1) AS abbreviate#18, car_number#31 AS car_number#19, color#33 AS color#20, vehicle_type#38 AS vehicle_type#21, from_unixtime(unix_timestamp(drivecard_register_date#109, yyyyMMdd), yyyy-MM-dd) AS drivecard_register_date#22, from_unixtime(unix_timestamp(drivecard_release_date#87, yyyyMMdd), yyyy-MM-dd) AS drivecard_release_date#23, from_unixtime(cast(cast((cast(enter_network_time#60 as double) / 1000.0) as int) as bigint), yyyy-MM-dd) AS network_time#24, owner_masking#98 AS owner_masking#25, vehicle_owner_phone_masking#79 AS phone_masking#26, car_number_masking#32 AS car_number_masking#27]
      :                       :     :        +- *Filter (((from_unixtime(cast(cast((cast(enter_network_time#60 as double) / 1000.0) as int) as bigint), yyyy-MM-dd) >= 2019-09-26) && (from_unixtime(cast(cast((cast(enter_network_time#60 as double) / 1000.0) as int) as bigint), yyyy-MM-dd) <= 2019-09-26)) && (length(vehicle_owner_phone#78) > 0))
      :                       :     :           +- HiveTableScan [enter_network_time#60, vid#30, car_number_masking#32, drivecard_register_date#109, vehicle_type#38, vehicle_owner_phone#78, car_number#31, owner#97, color#33, vehicle_owner_phone_masking#79, owner_masking#98, drivecard_release_date#87], MetastoreRelation bigdata_warehouse, d_vehicle
      :                       :     +- *Sort [vehicle_owner_phone#215 ASC NULLS FIRST], false, 0
      :                       :        +- *HashAggregate(keys=[vehicle_owner_phone#215], functions=[count(vid#167)], output=[vehicle_owner_phone#215, vehicle_count#28L])
      :                       :           +- Exchange hashpartitioning(vehicle_owner_phone#215, 400)
      :                       :              +- *HashAggregate(keys=[vehicle_owner_phone#215], functions=[partial_count(vid#167)], output=[vehicle_owner_phone#215, count#586L])
      :                       :                 +- *Filter (length(vehicle_owner_phone#215) > 0)
      :                       :                    +- HiveTableScan [vid#167, vehicle_owner_phone#215], MetastoreRelation bigdata_warehouse, d_vehicle
      :                       +- *Sort [phone#311 ASC NULLS FIRST], false, 0
      :                          +- Exchange hashpartitioning(phone#311, 400)
      :                             +- *Project [phone#311, if ((cast(is_gray_flag_owner#351 as double) = 1.0)) 大卡灰标用户 else if ((cast(is_daka_user#337 as double) = 1.0)) 大卡用户 else 非大卡用户 AS daka_user#29]
      :                                +- HiveTableScan [phone#311, is_gray_flag_owner#351, is_daka_user#337], MetastoreRelation bigdata_warehouse, user_portrait
      +- *Sort [vid#662 ASC NULLS FIRST], false, 0
         +- Exchange hashpartitioning(vid#662, 400)
            +- *Project [vid#676 AS vid#662, thr_day_mile#669 AS thr_day_mile#663, one_week_mile#670 AS one_week_mile#664, one_month_mile#671 AS one_month_mile#665, thr_month_mile#672 AS thr_month_mile#666, half_year_mile#673 AS half_year_mile#667, one_year_mile#674 AS one_year_mile#668]
               +- SortMergeJoin [vid#676], [vid#831], LeftOuter
                  :- *Project [vid#676, thr_day_mile#669, one_week_mile#670, one_month_mile#671, thr_month_mile#672, half_year_mile#673]
                  :  +- SortMergeJoin [vid#676], [vid#800], LeftOuter
                  :     :- *Project [vid#676, thr_day_mile#669, one_week_mile#670, one_month_mile#671, thr_month_mile#672]
                  :     :  +- SortMergeJoin [vid#676], [vid#769], LeftOuter
                  :     :     :- *Project [vid#676, thr_day_mile#669, one_week_mile#670, one_month_mile#671]
                  :     :     :  +- SortMergeJoin [vid#676], [vid#738], LeftOuter
                  :     :     :     :- *Project [vid#676, thr_day_mile#669, one_week_mile#670]
                  :     :     :     :  +- SortMergeJoin [vid#676], [vid#707], LeftOuter
                  :     :     :     :     :- *Sort [vid#676 ASC NULLS FIRST], false, 0
                  :     :     :     :     :  +- *HashAggregate(keys=[vid#676], functions=[sum((cast(highwaymile#685 as double) + 0.0))], output=[vid#676, thr_day_mile#669])
                  :     :     :     :     :     +- Exchange hashpartitioning(vid#676, 400)
                  :     :     :     :     :        +- *HashAggregate(keys=[vid#676], functions=[partial_sum((cast(highwaymile#685 as double) + 0.0))], output=[vid#676, sum#1032])
                  :     :     :     :     :           +- *Project [vid#676, highwaymile#685]
                  :     :     :     :     :              +- *Filter ((isnotnull(yearmonthday#680) && (yearmonthday#680 >= 2019-09-24)) && (yearmonthday#680 <= 2019-09-26))
                  :     :     :     :     :                 +- HiveTableScan [vid#676, highwaymile#685, yearmonthday#680], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  :     :     :     :     +- *Sort [vid#707 ASC NULLS FIRST], false, 0
                  :     :     :     :        +- *HashAggregate(keys=[vid#707], functions=[sum((cast(highwaymile#716 as double) + 0.0))], output=[vid#707, one_week_mile#670])
                  :     :     :     :           +- Exchange hashpartitioning(vid#707, 400)
                  :     :     :     :              +- *HashAggregate(keys=[vid#707], functions=[partial_sum((cast(highwaymile#716 as double) + 0.0))], output=[vid#707, sum#1034])
                  :     :     :     :                 +- *Project [vid#707, highwaymile#716]
                  :     :     :     :                    +- *Filter ((isnotnull(yearmonthday#711) && (yearmonthday#711 >= 2019-09-20)) && (yearmonthday#711 <= 2019-09-26))
                  :     :     :     :                       +- HiveTableScan [vid#707, highwaymile#716, yearmonthday#711], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  :     :     :     +- *Sort [vid#738 ASC NULLS FIRST], false, 0
                  :     :     :        +- *HashAggregate(keys=[vid#738], functions=[sum((cast(highwaymile#747 as double) + 0.0))], output=[vid#738, one_month_mile#671])
                  :     :     :           +- Exchange hashpartitioning(vid#738, 400)
                  :     :     :              +- *HashAggregate(keys=[vid#738], functions=[partial_sum((cast(highwaymile#747 as double) + 0.0))], output=[vid#738, sum#1036])
                  :     :     :                 +- *Project [vid#738, highwaymile#747]
                  :     :     :                    +- *Filter ((isnotnull(yearmonthday#742) && (yearmonthday#742 >= 2019-08-27)) && (yearmonthday#742 <= 2019-09-27))
                  :     :     :                       +- HiveTableScan [vid#738, highwaymile#747, yearmonthday#742], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  :     :     +- *Sort [vid#769 ASC NULLS FIRST], false, 0
                  :     :        +- *HashAggregate(keys=[vid#769], functions=[sum((cast(highwaymile#778 as double) + 0.0))], output=[vid#769, thr_month_mile#672])
                  :     :           +- Exchange hashpartitioning(vid#769, 400)
                  :     :              +- *HashAggregate(keys=[vid#769], functions=[partial_sum((cast(highwaymile#778 as double) + 0.0))], output=[vid#769, sum#1038])
                  :     :                 +- *Project [vid#769, highwaymile#778]
                  :     :                    +- *Filter ((isnotnull(yearmonthday#773) && (yearmonthday#773 >= 2019-06-27)) && (yearmonthday#773 <= 2019-09-27))
                  :     :                       +- HiveTableScan [vid#769, highwaymile#778, yearmonthday#773], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  :     +- *Sort [vid#800 ASC NULLS FIRST], false, 0
                  :        +- *HashAggregate(keys=[vid#800], functions=[sum((cast(highwaymile#809 as double) + 0.0))], output=[vid#800, half_year_mile#673])
                  :           +- Exchange hashpartitioning(vid#800, 400)
                  :              +- *HashAggregate(keys=[vid#800], functions=[partial_sum((cast(highwaymile#809 as double) + 0.0))], output=[vid#800, sum#1040])
                  :                 +- *Project [vid#800, highwaymile#809]
                  :                    +- *Filter ((isnotnull(yearmonthday#804) && (yearmonthday#804 >= 2019-03-27)) && (yearmonthday#804 <= 2019-09-27))
                  :                       +- HiveTableScan [vid#800, highwaymile#809, yearmonthday#804], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  +- *Sort [vid#831 ASC NULLS FIRST], false, 0
                     +- *HashAggregate(keys=[vid#831], functions=[sum((cast(highwaymile#840 as double) + 0.0))], output=[vid#831, one_year_mile#674])
                        +- Exchange hashpartitioning(vid#831, 400)
                           +- *HashAggregate(keys=[vid#831], functions=[partial_sum((cast(highwaymile#840 as double) + 0.0))], output=[vid#831, sum#1042])
                              +- *Project [vid#831, highwaymile#840]
                                 +- *Filter ((isnotnull(yearmonthday#835) && (yearmonthday#835 >= 2018-09-27)) && (yearmonthday#835 <= 2019-09-27))
                                    +- HiveTableScan [vid#831, highwaymile#840, yearmonthday#835], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d

org.apache.spark.sql.catalyst.errors.package$TreeNodeException: execute, tree:
Exchange SinglePartition
+- *Project [vid#5 AS vid#870, phone#1 AS phone#871, owner#0 AS owner#872, vehicle_count#2L AS vehicle_count#873L, daka_user#3 AS daka_user#874, abbreviate#4 AS abbreviate#875, car_number#6 AS car_number#876, color#7 AS color#877, vehicle_type#8 AS vehicle_type#878, drivecard_register_date#9 AS drivecard_register_date#879, drivecard_release_date#10 AS drivecard_release_date#880, network_time#11 AS network_time#881, coalesce(thr_day_mile#663, 0.0) AS thr_day_mile#882, coalesce(one_week_mile#664, 0.0) AS one_week_mile#883, coalesce(one_month_mile#665, 0.0) AS one_month_mile#884, coalesce(thr_month_mile#666, 0.0) AS thr_month_mile#885, coalesce(half_year_mile#667, 0.0) AS half_year_mile#886, coalesce(one_year_mile#668, 0.0) AS one_year_mile#887, owner_masking#12 AS owner_masking#888, phone_masking#13 AS phone_masking#889, car_number_masking#14 AS car_number_masking#890, 1569549798760000 AS create_time#915, 1569549798760000 AS update_time#916]
   +- SortMergeJoin [vid#5], [vid#662], LeftOuter
      :- *Sort [vid#5 ASC NULLS FIRST], false, 0
      :  +- Exchange hashpartitioning(vid#5, 400)
      :     +- InMemoryTableScan [owner#0, phone#1, vehicle_count#2L, daka_user#3, abbreviate#4, vid#5, car_number#6, color#7, vehicle_type#8, drivecard_register_date#9, drivecard_release_date#10, network_time#11, owner_masking#12, phone_masking#13, car_number_masking#14]
      :           +- InMemoryRelation [owner#0, phone#1, vehicle_count#2L, daka_user#3, abbreviate#4, vid#5, car_number#6, color#7, vehicle_type#8, drivecard_register_date#9, drivecard_release_date#10, network_time#11, owner_masking#12, phone_masking#13, car_number_masking#14], true, 10000, StorageLevel(disk, memory, deserialized, 1 replicas), user_vehicle_info
      :                 +- *Project [owner#15 AS owner#0, phone#16 AS phone#1, vehicle_count#28L AS vehicle_count#2L, coalesce(daka_user#29, 非大卡用户) AS daka_user#3, abbreviate#18 AS abbreviate#4, vid#17 AS vid#5, car_number#19 AS car_number#6, color#20 AS color#7, vehicle_type#21 AS vehicle_type#8, drivecard_register_date#22 AS drivecard_register_date#9, drivecard_release_date#23 AS drivecard_release_date#10, network_time#24 AS network_time#11, owner_masking#25 AS owner_masking#12, phone_masking#26 AS phone_masking#13, car_number_masking#27 AS car_number_masking#14]
      :                    +- SortMergeJoin [phone#16], [phone#311], LeftOuter
      :                       :- *Project [owner#15, phone#16, vid#17, abbreviate#18, car_number#19, color#20, vehicle_type#21, drivecard_register_date#22, drivecard_release_date#23, network_time#24, owner_masking#25, phone_masking#26, car_number_masking#27, vehicle_count#28L]
      :                       :  +- SortMergeJoin [phone#16], [vehicle_owner_phone#215], LeftOuter
      :                       :     :- *Sort [phone#16 ASC NULLS FIRST], false, 0
      :                       :     :  +- Exchange hashpartitioning(phone#16, 400)
      :                       :     :     +- *Project [owner#97 AS owner#15, vehicle_owner_phone#78 AS phone#16, vid#30 AS vid#17, substring(car_number_masking#32, 1, 1) AS abbreviate#18, car_number#31 AS car_number#19, color#33 AS color#20, vehicle_type#38 AS vehicle_type#21, from_unixtime(unix_timestamp(drivecard_register_date#109, yyyyMMdd), yyyy-MM-dd) AS drivecard_register_date#22, from_unixtime(unix_timestamp(drivecard_release_date#87, yyyyMMdd), yyyy-MM-dd) AS drivecard_release_date#23, from_unixtime(cast(cast((cast(enter_network_time#60 as double) / 1000.0) as int) as bigint), yyyy-MM-dd) AS network_time#24, owner_masking#98 AS owner_masking#25, vehicle_owner_phone_masking#79 AS phone_masking#26, car_number_masking#32 AS car_number_masking#27]
      :                       :     :        +- *Filter (((from_unixtime(cast(cast((cast(enter_network_time#60 as double) / 1000.0) as int) as bigint), yyyy-MM-dd) >= 2019-09-26) && (from_unixtime(cast(cast((cast(enter_network_time#60 as double) / 1000.0) as int) as bigint), yyyy-MM-dd) <= 2019-09-26)) && (length(vehicle_owner_phone#78) > 0))
      :                       :     :           +- HiveTableScan [enter_network_time#60, vid#30, car_number_masking#32, drivecard_register_date#109, vehicle_type#38, vehicle_owner_phone#78, car_number#31, owner#97, color#33, vehicle_owner_phone_masking#79, owner_masking#98, drivecard_release_date#87], MetastoreRelation bigdata_warehouse, d_vehicle
      :                       :     +- *Sort [vehicle_owner_phone#215 ASC NULLS FIRST], false, 0
      :                       :        +- *HashAggregate(keys=[vehicle_owner_phone#215], functions=[count(vid#167)], output=[vehicle_owner_phone#215, vehicle_count#28L])
      :                       :           +- Exchange hashpartitioning(vehicle_owner_phone#215, 400)
      :                       :              +- *HashAggregate(keys=[vehicle_owner_phone#215], functions=[partial_count(vid#167)], output=[vehicle_owner_phone#215, count#586L])
      :                       :                 +- *Filter (length(vehicle_owner_phone#215) > 0)
      :                       :                    +- HiveTableScan [vid#167, vehicle_owner_phone#215], MetastoreRelation bigdata_warehouse, d_vehicle
      :                       +- *Sort [phone#311 ASC NULLS FIRST], false, 0
      :                          +- Exchange hashpartitioning(phone#311, 400)
      :                             +- *Project [phone#311, if ((cast(is_gray_flag_owner#351 as double) = 1.0)) 大卡灰标用户 else if ((cast(is_daka_user#337 as double) = 1.0)) 大卡用户 else 非大卡用户 AS daka_user#29]
      :                                +- HiveTableScan [phone#311, is_gray_flag_owner#351, is_daka_user#337], MetastoreRelation bigdata_warehouse, user_portrait
      +- *Sort [vid#662 ASC NULLS FIRST], false, 0
         +- Exchange hashpartitioning(vid#662, 400)
            +- *Project [vid#676 AS vid#662, thr_day_mile#669 AS thr_day_mile#663, one_week_mile#670 AS one_week_mile#664, one_month_mile#671 AS one_month_mile#665, thr_month_mile#672 AS thr_month_mile#666, half_year_mile#673 AS half_year_mile#667, one_year_mile#674 AS one_year_mile#668]
               +- SortMergeJoin [vid#676], [vid#831], LeftOuter
                  :- *Project [vid#676, thr_day_mile#669, one_week_mile#670, one_month_mile#671, thr_month_mile#672, half_year_mile#673]
                  :  +- SortMergeJoin [vid#676], [vid#800], LeftOuter
                  :     :- *Project [vid#676, thr_day_mile#669, one_week_mile#670, one_month_mile#671, thr_month_mile#672]
                  :     :  +- SortMergeJoin [vid#676], [vid#769], LeftOuter
                  :     :     :- *Project [vid#676, thr_day_mile#669, one_week_mile#670, one_month_mile#671]
                  :     :     :  +- SortMergeJoin [vid#676], [vid#738], LeftOuter
                  :     :     :     :- *Project [vid#676, thr_day_mile#669, one_week_mile#670]
                  :     :     :     :  +- SortMergeJoin [vid#676], [vid#707], LeftOuter
                  :     :     :     :     :- *Sort [vid#676 ASC NULLS FIRST], false, 0
                  :     :     :     :     :  +- *HashAggregate(keys=[vid#676], functions=[sum((cast(highwaymile#685 as double) + 0.0))], output=[vid#676, thr_day_mile#669])
                  :     :     :     :     :     +- Exchange hashpartitioning(vid#676, 400)
                  :     :     :     :     :        +- *HashAggregate(keys=[vid#676], functions=[partial_sum((cast(highwaymile#685 as double) + 0.0))], output=[vid#676, sum#1032])
                  :     :     :     :     :           +- *Project [vid#676, highwaymile#685]
                  :     :     :     :     :              +- *Filter ((isnotnull(yearmonthday#680) && (yearmonthday#680 >= 2019-09-24)) && (yearmonthday#680 <= 2019-09-26))
                  :     :     :     :     :                 +- HiveTableScan [vid#676, highwaymile#685, yearmonthday#680], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  :     :     :     :     +- *Sort [vid#707 ASC NULLS FIRST], false, 0
                  :     :     :     :        +- *HashAggregate(keys=[vid#707], functions=[sum((cast(highwaymile#716 as double) + 0.0))], output=[vid#707, one_week_mile#670])
                  :     :     :     :           +- Exchange hashpartitioning(vid#707, 400)
                  :     :     :     :              +- *HashAggregate(keys=[vid#707], functions=[partial_sum((cast(highwaymile#716 as double) + 0.0))], output=[vid#707, sum#1034])
                  :     :     :     :                 +- *Project [vid#707, highwaymile#716]
                  :     :     :     :                    +- *Filter ((isnotnull(yearmonthday#711) && (yearmonthday#711 >= 2019-09-20)) && (yearmonthday#711 <= 2019-09-26))
                  :     :     :     :                       +- HiveTableScan [vid#707, highwaymile#716, yearmonthday#711], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  :     :     :     +- *Sort [vid#738 ASC NULLS FIRST], false, 0
                  :     :     :        +- *HashAggregate(keys=[vid#738], functions=[sum((cast(highwaymile#747 as double) + 0.0))], output=[vid#738, one_month_mile#671])
                  :     :     :           +- Exchange hashpartitioning(vid#738, 400)
                  :     :     :              +- *HashAggregate(keys=[vid#738], functions=[partial_sum((cast(highwaymile#747 as double) + 0.0))], output=[vid#738, sum#1036])
                  :     :     :                 +- *Project [vid#738, highwaymile#747]
                  :     :     :                    +- *Filter ((isnotnull(yearmonthday#742) && (yearmonthday#742 >= 2019-08-27)) && (yearmonthday#742 <= 2019-09-27))
                  :     :     :                       +- HiveTableScan [vid#738, highwaymile#747, yearmonthday#742], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  :     :     +- *Sort [vid#769 ASC NULLS FIRST], false, 0
                  :     :        +- *HashAggregate(keys=[vid#769], functions=[sum((cast(highwaymile#778 as double) + 0.0))], output=[vid#769, thr_month_mile#672])
                  :     :           +- Exchange hashpartitioning(vid#769, 400)
                  :     :              +- *HashAggregate(keys=[vid#769], functions=[partial_sum((cast(highwaymile#778 as double) + 0.0))], output=[vid#769, sum#1038])
                  :     :                 +- *Project [vid#769, highwaymile#778]
                  :     :                    +- *Filter ((isnotnull(yearmonthday#773) && (yearmonthday#773 >= 2019-06-27)) && (yearmonthday#773 <= 2019-09-27))
                  :     :                       +- HiveTableScan [vid#769, highwaymile#778, yearmonthday#773], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  :     +- *Sort [vid#800 ASC NULLS FIRST], false, 0
                  :        +- *HashAggregate(keys=[vid#800], functions=[sum((cast(highwaymile#809 as double) + 0.0))], output=[vid#800, half_year_mile#673])
                  :           +- Exchange hashpartitioning(vid#800, 400)
                  :              +- *HashAggregate(keys=[vid#800], functions=[partial_sum((cast(highwaymile#809 as double) + 0.0))], output=[vid#800, sum#1040])
                  :                 +- *Project [vid#800, highwaymile#809]
                  :                    +- *Filter ((isnotnull(yearmonthday#804) && (yearmonthday#804 >= 2019-03-27)) && (yearmonthday#804 <= 2019-09-27))
                  :                       +- HiveTableScan [vid#800, highwaymile#809, yearmonthday#804], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d
                  +- *Sort [vid#831 ASC NULLS FIRST], false, 0
                     +- *HashAggregate(keys=[vid#831], functions=[sum((cast(highwaymile#840 as double) + 0.0))], output=[vid#831, one_year_mile#674])
                        +- Exchange hashpartitioning(vid#831, 400)
                           +- *HashAggregate(keys=[vid#831], functions=[partial_sum((cast(highwaymile#840 as double) + 0.0))], output=[vid#831, sum#1042])
                              +- *Project [vid#831, highwaymile#840]
                                 +- *Filter ((isnotnull(yearmonthday#835) && (yearmonthday#835 >= 2018-09-27)) && (yearmonthday#835 <= 2019-09-27))
                                    +- HiveTableScan [vid#831, highwaymile#840, yearmonthday#835], MetastoreRelation bigdata_warehouse, dws_vehicle_gathermile_d

要回复问题请先登录注册