mysql> EXPLAIN ANALYZE select count(*),`api` from tracing_normal group by `api` order by 1 desc limit 10\G *************************** 1. row *************************** stage: 0 node: 0 plan: SortPreservingMergeExec: [count(*)@0 DESC], fetch=10 metrics=[output_rows: 10, elapsed_compute: 13770, ] SortExec: TopK(fetch=10), expr=[count(*)@0 DESC], preserve_partitioning=[true] metrics=[output_rows: 320, elapsed_compute: 48937359, row_replacements: 1135, ] ProjectionExec: expr=[count(*)@1 as count(*), api@0 as api] metrics=[output_rows: 798719, elapsed_compute: 133362, ] AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[count(*)] metrics=[output_rows: 798719, elapsed_compute: 1684242482, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 188344376, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 1706058, elapsed_compute: 119683865, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 200204846642, repartition_time: 153038834, send_time: 600332400, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[count(*)] metrics=[output_rows: 1706058, elapsed_compute: 3635398681, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 389231712, ] MergeScanExec: peers=[4569845202944(1064, 0), 4569845202945(1064, 1), 4569845202946(1064, 2), 4569845202947(1064, 3), 4569845202948(1064, 4), 4569845202949(1064, 5), 4569845202950(1064, 6), 4569845202951(1064, 7), 4569845202952(1064, 8), 4569845202953(1064, 9), 4569845202954(1064, 10), 4569845202955(1064, 11), 4569845202956(1064, 12), 4569845202957(1064, 13), 4569845202958(1064, 14), 4569845202959(1064, 15), 4569845202960(1064, 16), 4569845202961(1064, 17), 4569845202962(1064, 18), 4569845202963(1064, 19), 4569845202964(1064, 20), 4569845202965(1064, 21), 4569845202966(1064, 22), 4569845202967(1064, 23), 4569845202968(1064, 24), 4569845202969(1064, 25), 4569845202970(1064, 26), 4569845202971(1064, 27), 4569845202972(1064, 28), 4569845202973(1064, 29), 4569845202974(1064, 30), 4569845202975(1064, 31), 4569845202976(1064, 32), 4569845202977(1064, 33), 4569845202978(1064, 34), 4569845202979(1064, 35), 4569845202980(1064, 36), 4569845202981(1064, 37), 4569845202982(1064, 38), 4569845202983(1064, 39), 4569845202984(1064, 40), 4569845202985(1064, 41), 4569845202986(1064, 42), 4569845202987(1064, 43), 4569845202988(1064, 44), 4569845202989(1064, 45), 4569845202990(1064, 46), 4569845202991(1064, 47), 4569845202992(1064, 48), 4569845202993(1064, 49), 4569845202994(1064, 50), 4569845202995(1064, 51), 4569845202996(1064, 52), 4569845202997(1064, 53), 4569845202998(1064, 54), 4569845202999(1064, 55), 4569845203000(1064, 56), 4569845203001(1064, 57), 4569845203002(1064, 58), 4569845203003(1064, 59), 4569845203004(1064, 60), 4569845203005(1064, 61), 4569845203006(1064, 62), 4569845203007(1064, 63), 4569845203008(1064, 64), 4569845203009(1064, 65), 4569845203010(1064, 66), 4569845203011(1064, 67), 4569845203012(1064, 68), 4569845203013(1064, 69), 4569845203014(1064, 70), 4569845203015(1064, 71), 4569845203016(1064, 72), 4569845203017(1064, 73), 4569845203018(1064, 74), 4569845203019(1064, 75), 4569845203020(1064, 76), 4569845203021(1064, 77), 4569845203022(1064, 78), 4569845203023(1064, 79), 4569845203024(1064, 80), 4569845203025(1064, 81), 4569845203026(1064, 82), 4569845203027(1064, 83), 4569845203028(1064, 84), 4569845203029(1064, 85), 4569845203030(1064, 86), 4569845203031(1064, 87), 4569845203032(1064, 88), 4569845203033(1064, 89), 4569845203034(1064, 90), 4569845203035(1064, 91), 4569845203036(1064, 92), 4569845203037(1064, 93), 4569845203038(1064, 94), 4569845203039(1064, 95), 4569845203040(1064, 96), 4569845203041(1064, 97), 4569845203042(1064, 98), 4569845203043(1064, 99), 4569845203044(1064, 100), 4569845203045(1064, 101), 4569845203046(1064, 102), 4569845203047(1064, 103), 4569845203048(1064, 104), 4569845203049(1064, 105), 4569845203050(1064, 106), 4569845203051(1064, 107), 4569845203052(1064, 108), 4569845203053(1064, 109), 4569845203054(1064, 110), 4569845203055(1064, 111), 4569845203056(1064, 112), 4569845203057(1064, 113), 4569845203058(1064, 114), 4569845203059(1064, 115), 4569845203060(1064, 116), 4569845203061(1064, 117), 4569845203062(1064, 118), 4569845203063(1064, 119), 4569845203064(1064, 120), 4569845203065(1064, 121), 4569845203066(1064, 122), 4569845203067(1064, 123), 4569845203068(1064, 124), 4569845203069(1064, 125), 4569845203070(1064, 126), 4569845203071(1064, 127), ] metrics=[output_rows: 2720054, greptime_exec_read_cost: 0, finish_time: 199665886311, first_consume_time: 52435332483, ready_time: 53000271, ] *************************** 2. row *************************** stage: 1 node: 0 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22294, elapsed_compute: 108769927, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6822584, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 70611, elapsed_compute: 5275498, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18564543512, repartition_time: 18247027, send_time: 13273248314, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 70611, elapsed_compute: 458316834, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16507696, ] UnorderedScan: region=4569845202996(1064, 52), "partition_count":{"count":62, "mem_ranges":2, "files":15, "file_ranges":60} metrics=[output_rows: 5295949, mem_used: 1043272488, build_parts_cost: 129035501, build_reader_cost: 17551516953, convert_cost: 14953854, elapsed_await: 18086120564, elapsed_poll: 638821564, scan_cost: 18062996335, yield_cost: 473959629, ] *************************** 3. row *************************** stage: 1 node: 1 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22739, elapsed_compute: 161162282, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6787920, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 67704, elapsed_compute: 6017307, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10042603581, repartition_time: 20444593, send_time: 1276566121, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 67704, elapsed_compute: 443833817, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16164544, ] UnorderedScan: region=4569845203055(1064, 111), "partition_count":{"count":59, "mem_ranges":2, "files":14, "file_ranges":57} metrics=[output_rows: 5189844, mem_used: 965232840, build_parts_cost: 192073321, build_reader_cost: 9013660448, convert_cost: 14239135, elapsed_await: 9570708047, elapsed_poll: 660366524, scan_cost: 9544817580, yield_cost: 459920358, ] *************************** 4. row *************************** stage: 1 node: 2 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19212, elapsed_compute: 88472613, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6017712, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 54030, elapsed_compute: 4661015, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12233971420, repartition_time: 8908404, send_time: 6320639014, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 54030, elapsed_compute: 341108470, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12647920, ] UnorderedScan: region=4569845202983(1064, 39), "partition_count":{"count":48, "mem_ranges":1, "files":12, "file_ranges":47} metrics=[output_rows: 4081065, mem_used: 739079669, build_parts_cost: 198743599, build_reader_cost: 11381811821, convert_cost: 11245280, elapsed_await: 11878198367, elapsed_poll: 426133340, scan_cost: 11858080599, yield_cost: 357830551, ] *************************** 5. row *************************** stage: 1 node: 3 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19172, elapsed_compute: 99764027, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5926168, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 51019, elapsed_compute: 5034265, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 25958559100, repartition_time: 11645402, send_time: 11771156949, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 51019, elapsed_compute: 337887853, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12336016, ] UnorderedScan: region=4569845202982(1064, 38), "partition_count":{"count":50, "mem_ranges":2, "files":12, "file_ranges":48} metrics=[output_rows: 4067479, mem_used: 732625688, build_parts_cost: 34768060, build_reader_cost: 25245900606, convert_cost: 8333201, elapsed_await: 25601556589, elapsed_poll: 495110174, scan_cost: 25588604552, yield_cost: 350352722, ] *************************** 6. row *************************** stage: 1 node: 4 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19129, elapsed_compute: 126516374, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5976080, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 53420, elapsed_compute: 4428689, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 23848305932, repartition_time: 8447467, send_time: 10559577715, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 53420, elapsed_compute: 315374684, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13063456, ] UnorderedScan: region=4569845202950(1064, 6), "partition_count":{"count":45, "mem_ranges":1, "files":11, "file_ranges":44} metrics=[output_rows: 3915885, mem_used: 719338560, build_parts_cost: 8721684, build_reader_cost: 23188472111, convert_cost: 6014686, elapsed_await: 23518481622, elapsed_poll: 453543606, scan_cost: 23503217373, yield_cost: 317976881, ] *************************** 7. row *************************** stage: 1 node: 5 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19114, elapsed_compute: 72050103, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6124760, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 61855, elapsed_compute: 4817467, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 23321701584, repartition_time: 12611334, send_time: 23339285664, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 61855, elapsed_compute: 375993430, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14494960, ] UnorderedScan: region=4569845202956(1064, 12), "partition_count":{"count":51, "mem_ranges":2, "files":16, "file_ranges":49} metrics=[output_rows: 4236495, mem_used: 904816201, build_parts_cost: 32087687, build_reader_cost: 22523513179, convert_cost: 12601266, elapsed_await: 22927716572, elapsed_poll: 536829811, scan_cost: 22910249317, yield_cost: 380591085, ] *************************** 8. row *************************** stage: 1 node: 6 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19376, elapsed_compute: 149186291, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6036176, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 51258, elapsed_compute: 7083044, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10672443595, repartition_time: 8252852, send_time: 3678696626, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 51258, elapsed_compute: 321399350, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12445904, ] UnorderedScan: region=4569845203018(1064, 74), "partition_count":{"count":44, "mem_ranges":2, "files":11, "file_ranges":42} metrics=[output_rows: 3834552, mem_used: 700086944, build_parts_cost: 316121989, build_reader_cost: 9653412563, convert_cost: 6916576, elapsed_await: 10315419060, elapsed_poll: 664440533, scan_cost: 10303033832, yield_cost: 333595447, ] *************************** 9. row *************************** stage: 1 node: 7 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19176, elapsed_compute: 93468854, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5958920, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 50993, elapsed_compute: 4653901, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 15313737322, repartition_time: 14303459, send_time: 1987804639, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 50993, elapsed_compute: 355717492, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12255008, ] UnorderedScan: region=4569845202986(1064, 42), "partition_count":{"count":44, "mem_ranges":2, "files":11, "file_ranges":42} metrics=[output_rows: 3851943, mem_used: 708997524, build_parts_cost: 5249224, build_reader_cost: 14576157875, convert_cost: 6630584, elapsed_await: 14928915564, elapsed_poll: 490549411, scan_cost: 14915683356, yield_cost: 355551958, ] *************************** 10. row *************************** stage: 1 node: 8 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18921, elapsed_compute: 110138199, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5954136, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 51925, elapsed_compute: 4880301, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11118345680, repartition_time: 8803838, send_time: 5317854686, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 51925, elapsed_compute: 327472472, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12429800, ] UnorderedScan: region=4569845202980(1064, 36), "partition_count":{"count":46, "mem_ranges":2, "files":10, "file_ranges":44} metrics=[output_rows: 3923477, mem_used: 708047384, build_parts_cost: 11948171, build_reader_cost: 10399975965, convert_cost: 26337622, elapsed_await: 10773267745, elapsed_poll: 483840071, scan_cost: 10741802111, yield_cost: 346500648, ] *************************** 11. row *************************** stage: 1 node: 9 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22246, elapsed_compute: 149100661, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6911888, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 73870, elapsed_compute: 12887147, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 17515789516, repartition_time: 14856573, send_time: 2688183474, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 73870, elapsed_compute: 468273254, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17799208, ] UnorderedScan: region=4569845202999(1064, 55), "partition_count":{"count":60, "mem_ranges":2, "files":15, "file_ranges":58} metrics=[output_rows: 5177327, mem_used: 1074607112, build_parts_cost: 16579719, build_reader_cost: 16504801376, convert_cost: 11173425, elapsed_await: 17007951938, elapsed_poll: 656855629, scan_cost: 16988425912, yield_cost: 490551137, ] *************************** 12. row *************************** stage: 1 node: 10 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18184, elapsed_compute: 90338701, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6367368, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 77281, elapsed_compute: 9635172, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18647300440, repartition_time: 11998964, send_time: 18228312699, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 77281, elapsed_compute: 609738775, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18411072, ] UnorderedScan: region=4569845203019(1064, 75), "partition_count":{"count":75, "mem_ranges":2, "files":27, "file_ranges":73} metrics=[output_rows: 6283976, mem_used: 1431105800, build_parts_cost: 15834373, build_reader_cost: 17338715128, convert_cost: 17123807, elapsed_await: 18000434417, elapsed_poll: 941398472, scan_cost: 17971495213, yield_cost: 639935035, ] *************************** 13. row *************************** stage: 1 node: 11 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23247, elapsed_compute: 87878994, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6813808, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 67892, elapsed_compute: 6526293, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 26660899067, repartition_time: 11068183, send_time: 16408395213, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 67892, elapsed_compute: 442142175, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16141504, ] UnorderedScan: region=4569845203005(1064, 61), "partition_count":{"count":59, "mem_ranges":2, "files":12, "file_ranges":57} metrics=[output_rows: 5380073, mem_used: 947611164, build_parts_cost: 192225110, build_reader_cost: 25585982710, convert_cost: 11263255, elapsed_await: 26198484639, elapsed_poll: 619286929, scan_cost: 26179957936, yield_cost: 445892448, ] *************************** 14. row *************************** stage: 1 node: 12 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19446, elapsed_compute: 96297329, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6192232, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 60105, elapsed_compute: 4863917, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18168504277, repartition_time: 9263647, send_time: 13423916018, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 60105, elapsed_compute: 351562519, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14630720, ] UnorderedScan: region=4569845203038(1064, 94), "partition_count":{"count":48, "mem_ranges":2, "files":14, "file_ranges":46} metrics=[output_rows: 3893208, mem_used: 869975044, build_parts_cost: 10607466, build_reader_cost: 17435057980, convert_cost: 7552080, elapsed_await: 17795655824, elapsed_poll: 501747676, scan_cost: 17781288524, yield_cost: 366337889, ] *************************** 15. row *************************** stage: 1 node: 13 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24920, elapsed_compute: 96969945, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7063848, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 74773, elapsed_compute: 5329396, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 32974366613, repartition_time: 11017108, send_time: 6838219404, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 74773, elapsed_compute: 518706696, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17634688, ] UnorderedScan: region=4569845202967(1064, 23), "partition_count":{"count":69, "mem_ranges":2, "files":14, "file_ranges":67} metrics=[output_rows: 6119083, mem_used: 1057905118, build_parts_cost: 21158776, build_reader_cost: 31925335656, convert_cost: 9646274, elapsed_await: 32432176480, elapsed_poll: 748485683, scan_cost: 32410296567, yield_cost: 534946265, ] *************************** 16. row *************************** stage: 1 node: 14 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19095, elapsed_compute: 126062168, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5970160, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 40596, elapsed_compute: 4035998, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 21037343699, repartition_time: 6612231, send_time: 11854680635, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 40596, elapsed_compute: 309462212, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 9556112, ] UnorderedScan: region=4569845202969(1064, 25), "partition_count":{"count":45, "mem_ranges":2, "files":9, "file_ranges":43} metrics=[output_rows: 3934011, mem_used: 557415448, build_parts_cost: 10570135, build_reader_cost: 20420144611, convert_cost: 10048180, elapsed_await: 20716348971, elapsed_poll: 385983835, scan_cost: 20702269583, yield_cost: 310615419, ] *************************** 17. row *************************** stage: 1 node: 15 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19350, elapsed_compute: 79646849, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6049008, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 53018, elapsed_compute: 16683079, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12701041571, repartition_time: 8758134, send_time: 5692425947, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 53018, elapsed_compute: 321242235, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12659936, ] UnorderedScan: region=4569845203012(1064, 68), "partition_count":{"count":48, "mem_ranges":1, "files":13, "file_ranges":47} metrics=[output_rows: 3964184, mem_used: 751038928, build_parts_cost: 61220757, build_reader_cost: 12018930667, convert_cost: 15661122, elapsed_await: 12365754229, elapsed_poll: 437404557, scan_cost: 12340475849, yield_cost: 334810414, ] *************************** 18. row *************************** stage: 1 node: 16 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22964, elapsed_compute: 174835119, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6821680, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 68526, elapsed_compute: 5597837, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 26546036919, repartition_time: 10151758, send_time: 731362651, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 68526, elapsed_compute: 426609354, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16309040, ] UnorderedScan: region=4569845203020(1064, 76), "partition_count":{"count":59, "mem_ranges":2, "files":12, "file_ranges":57} metrics=[output_rows: 5113883, mem_used: 975277456, build_parts_cost: 51444041, build_reader_cost: 25507115381, convert_cost: 18237515, elapsed_await: 26098059727, elapsed_poll: 741583797, scan_cost: 26072181941, yield_cost: 447872280, ] *************************** 19. row *************************** stage: 1 node: 17 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24075, elapsed_compute: 134513001, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6927808, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 71030, elapsed_compute: 8781645, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 20232441176, repartition_time: 10937291, send_time: 13960803012, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 71030, elapsed_compute: 409178636, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17075648, ] UnorderedScan: region=4569845202954(1064, 10), "partition_count":{"count":65, "mem_ranges":1, "files":15, "file_ranges":64} metrics=[output_rows: 5466908, mem_used: 999070424, build_parts_cost: 58529681, build_reader_cost: 19378880503, convert_cost: 9794446, elapsed_await: 19804159424, elapsed_poll: 538575827, scan_cost: 19781967164, yield_cost: 418626938, ] *************************** 20. row *************************** stage: 1 node: 18 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19463, elapsed_compute: 112730667, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6080816, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 52220, elapsed_compute: 4701845, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12485898153, repartition_time: 14635625, send_time: 2863149418, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 52220, elapsed_compute: 340063690, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12512016, ] UnorderedScan: region=4569845203047(1064, 103), "partition_count":{"count":47, "mem_ranges":1, "files":12, "file_ranges":46} metrics=[output_rows: 3949249, mem_used: 725017837, build_parts_cost: 13870886, build_reader_cost: 11802252295, convert_cost: 6447175, elapsed_await: 12125333649, elapsed_poll: 490018549, scan_cost: 12112987417, yield_cost: 345969616, ] *************************** 21. row *************************** stage: 1 node: 19 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 25160, elapsed_compute: 176860597, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7015624, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 71401, elapsed_compute: 21425330, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 20018214976, repartition_time: 14922609, send_time: 2220542607, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 71401, elapsed_compute: 419035215, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17073408, ] UnorderedScan: region=4569845203059(1064, 115), "partition_count":{"count":64, "mem_ranges":2, "files":12, "file_ranges":62} metrics=[output_rows: 5838807, mem_used: 962967836, build_parts_cost: 122881290, build_reader_cost: 19031088459, convert_cost: 9384853, elapsed_await: 19581089888, elapsed_poll: 614287220, scan_cost: 19564120970, yield_cost: 429846658, ] *************************** 22. row *************************** stage: 1 node: 20 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19036, elapsed_compute: 99030060, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6019008, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 55248, elapsed_compute: 12621830, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 15536367898, repartition_time: 14532638, send_time: 19677351345, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 55248, elapsed_compute: 409287449, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13083680, ] UnorderedScan: region=4569845202964(1064, 20), "partition_count":{"count":47, "mem_ranges":2, "files":10, "file_ranges":45} metrics=[output_rows: 4229752, mem_used: 762445280, build_parts_cost: 52559256, build_reader_cost: 14646670904, convert_cost: 6718717, elapsed_await: 15104598829, elapsed_poll: 574618014, scan_cost: 15092144029, yield_cost: 414949067, ] *************************** 23. row *************************** stage: 1 node: 21 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 26350, elapsed_compute: 78736654, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7203864, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 81647, elapsed_compute: 6569432, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 20207063822, repartition_time: 12215304, send_time: 2104643647, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 81647, elapsed_compute: 594965000, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19390976, ] UnorderedScan: region=4569845202991(1064, 47), "partition_count":{"count":75, "mem_ranges":2, "files":17, "file_ranges":73} metrics=[output_rows: 6607924, mem_used: 1257478496, build_parts_cost: 39216951, build_reader_cost: 18951467472, convert_cost: 19171871, elapsed_await: 19581445828, elapsed_poll: 897638216, scan_cost: 19550107264, yield_cost: 613616282, ] *************************** 24. row *************************** stage: 1 node: 22 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24557, elapsed_compute: 153282160, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6958328, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 69905, elapsed_compute: 4906664, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11673799414, repartition_time: 15533257, send_time: 3689068813, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 69905, elapsed_compute: 533658703, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16737456, ] UnorderedScan: region=4569845203067(1064, 123), "partition_count":{"count":62, "mem_ranges":2, "files":9, "file_ranges":60} metrics=[output_rows: 5835862, mem_used: 932577440, build_parts_cost: 134421870, build_reader_cost: 10289674136, convert_cost: 17451036, elapsed_await: 11104812379, elapsed_poll: 1029976411, scan_cost: 11078913811, yield_cost: 543845307, ] *************************** 25. row *************************** stage: 1 node: 23 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24985, elapsed_compute: 131618059, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7136024, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 81357, elapsed_compute: 9570988, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 30625484929, repartition_time: 29214743, send_time: 32048036018, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 81357, elapsed_compute: 542306597, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19518992, ] UnorderedScan: region=4569845202984(1064, 40), "partition_count":{"count":73, "mem_ranges":2, "files":19, "file_ranges":71} metrics=[output_rows: 6063601, mem_used: 1215698563, build_parts_cost: 97102877, build_reader_cost: 29437839933, convert_cost: 13509274, elapsed_await: 30055241218, elapsed_poll: 867026385, scan_cost: 30032009697, yield_cost: 554676910, ] *************************** 26. row *************************** stage: 1 node: 24 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24327, elapsed_compute: 121499758, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7048424, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 76403, elapsed_compute: 9129056, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 23879824660, repartition_time: 10991615, send_time: 2546907914, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 76403, elapsed_compute: 427939033, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18320624, ] UnorderedScan: region=4569845202966(1064, 22), "partition_count":{"count":63, "mem_ranges":2, "files":14, "file_ranges":61} metrics=[output_rows: 5659296, mem_used: 1048351775, build_parts_cost: 266423345, build_reader_cost: 22701696851, convert_cost: 9383755, elapsed_await: 23431749715, elapsed_poll: 594103875, scan_cost: 23410339095, yield_cost: 442509329, ] *************************** 27. row *************************** stage: 1 node: 25 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18881, elapsed_compute: 75917438, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6135912, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 60551, elapsed_compute: 4789361, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18026114361, repartition_time: 10719883, send_time: 9833980192, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 60551, elapsed_compute: 371780651, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14553680, ] UnorderedScan: region=4569845203010(1064, 66), "partition_count":{"count":47, "mem_ranges":2, "files":13, "file_ranges":45} metrics=[output_rows: 3829456, mem_used: 810707488, build_parts_cost: 9806200, build_reader_cost: 17162228089, convert_cost: 10511779, elapsed_await: 17639014588, elapsed_poll: 600546469, scan_cost: 17622481970, yield_cost: 383364306, ] *************************** 28. row *************************** stage: 1 node: 26 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22958, elapsed_compute: 113144368, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6921792, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 72884, elapsed_compute: 5797845, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 14153842279, repartition_time: 17221976, send_time: 8194836531, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 72884, elapsed_compute: 505635675, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17369296, ] UnorderedScan: region=4569845203041(1064, 97), "partition_count":{"count":69, "mem_ranges":2, "files":20, "file_ranges":67} metrics=[output_rows: 5592493, mem_used: 1091948518, build_parts_cost: 35944508, build_reader_cost: 13192833776, convert_cost: 12103924, elapsed_await: 13623945104, elapsed_poll: 584772456, scan_cost: 13603242770, yield_cost: 508708125, ] *************************** 29. row *************************** stage: 1 node: 27 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23044, elapsed_compute: 126375429, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6819240, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 67741, elapsed_compute: 5112163, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 35062925728, repartition_time: 13598160, send_time: 13791053188, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 67741, elapsed_compute: 423652985, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16269088, ] UnorderedScan: region=4569845202945(1064, 1), "partition_count":{"count":64, "mem_ranges":2, "files":15, "file_ranges":62} metrics=[output_rows: 5348348, mem_used: 939896500, build_parts_cost: 7826207, build_reader_cost: 34259972369, convert_cost: 8030802, elapsed_await: 34614086247, elapsed_poll: 501906562, scan_cost: 34595551710, yield_cost: 438561307, ] *************************** 30. row *************************** stage: 1 node: 28 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19248, elapsed_compute: 75417923, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6213472, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 61900, elapsed_compute: 4931928, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 14030655498, repartition_time: 12009450, send_time: 2615478604, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 61900, elapsed_compute: 346639222, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14549008, ] UnorderedScan: region=4569845203007(1064, 63), "partition_count":{"count":50, "mem_ranges":2, "files":15, "file_ranges":48} metrics=[output_rows: 3999231, mem_used: 884401869, build_parts_cost: 10614204, build_reader_cost: 13359077769, convert_cost: 7454665, elapsed_await: 13662300224, elapsed_poll: 433580190, scan_cost: 13648560865, yield_cost: 353885406, ] *************************** 31. row *************************** stage: 1 node: 29 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19699, elapsed_compute: 119538207, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6407688, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 65039, elapsed_compute: 5368833, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 13825688389, repartition_time: 12465545, send_time: 5638286970, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 65039, elapsed_compute: 390384619, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15294112, ] UnorderedScan: region=4569845202994(1064, 50), "partition_count":{"count":48, "mem_ranges":2, "files":16, "file_ranges":46} metrics=[output_rows: 3983299, mem_used: 933552472, build_parts_cost: 9677814, build_reader_cost: 13015955312, convert_cost: 10940265, elapsed_await: 13407673947, elapsed_poll: 537085737, scan_cost: 13396105702, yield_cost: 403156733, ] *************************** 32. row *************************** stage: 1 node: 30 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19407, elapsed_compute: 86308490, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6183088, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 59196, elapsed_compute: 4898190, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 35082448283, repartition_time: 9307072, send_time: 22742073617, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 59196, elapsed_compute: 368681913, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14176192, ] UnorderedScan: region=4569845202965(1064, 21), "partition_count":{"count":50, "mem_ranges":2, "files":15, "file_ranges":48} metrics=[output_rows: 4049874, mem_used: 883123648, build_parts_cost: 10040381, build_reader_cost: 34336662071, convert_cost: 15676716, elapsed_await: 34696343940, elapsed_poll: 483677731, scan_cost: 34674130717, yield_cost: 373928711, ] *************************** 33. row *************************** stage: 1 node: 31 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18997, elapsed_compute: 120218581, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6088320, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 55954, elapsed_compute: 10254993, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11746286675, repartition_time: 12671834, send_time: 6275343421, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 55954, elapsed_compute: 304469510, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13779112, ] UnorderedScan: region=4569845202955(1064, 11), "partition_count":{"count":46, "mem_ranges":2, "files":11, "file_ranges":44} metrics=[output_rows: 3852745, mem_used: 747639192, build_parts_cost: 19382018, build_reader_cost: 10920756004, convert_cost: 10123085, elapsed_await: 11427607380, elapsed_poll: 595446094, scan_cost: 11407736117, yield_cost: 314402691, ] *************************** 34. row *************************** stage: 1 node: 32 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19104, elapsed_compute: 150467421, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6215504, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 65066, elapsed_compute: 5117560, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 20815889413, repartition_time: 9405628, send_time: 2706657860, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 65066, elapsed_compute: 310618752, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15358848, ] UnorderedScan: region=4569845202958(1064, 14), "partition_count":{"count":54, "mem_ranges":2, "files":20, "file_ranges":52} metrics=[output_rows: 4103273, mem_used: 991927904, build_parts_cost: 9567213, build_reader_cost: 20230361049, convert_cost: 7957848, elapsed_await: 20487450585, elapsed_poll: 344543355, scan_cost: 20472406900, yield_cost: 323935138, ] *************************** 35. row *************************** stage: 1 node: 33 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23990, elapsed_compute: 151137582, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7057384, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 77497, elapsed_compute: 18434941, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10048387298, repartition_time: 12484390, send_time: 993929075, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 77497, elapsed_compute: 563443573, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18457400, ] UnorderedScan: region=4569845203044(1064, 100), "partition_count":{"count":70, "mem_ranges":4, "files":15, "file_ranges":66} metrics=[output_rows: 5959533, mem_used: 1133778128, build_parts_cost: 75708279, build_reader_cost: 8966072141, convert_cost: 10575647, elapsed_await: 9439594681, elapsed_poll: 698562956, scan_cost: 9419922142, yield_cost: 582122842, ] *************************** 36. row *************************** stage: 1 node: 34 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19524, elapsed_compute: 159501278, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6103456, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 58780, elapsed_compute: 5192680, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 17360322365, repartition_time: 16327525, send_time: 4124771518, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 58780, elapsed_compute: 339292045, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14240264, ] UnorderedScan: region=4569845203003(1064, 59), "partition_count":{"count":47, "mem_ranges":2, "files":14, "file_ranges":45} metrics=[output_rows: 3907556, mem_used: 806864472, build_parts_cost: 16068042, build_reader_cost: 16570002394, convert_cost: 7561796, elapsed_await: 17005048733, elapsed_poll: 548212574, scan_cost: 16991443281, yield_cost: 351164320, ] *************************** 37. row *************************** stage: 1 node: 35 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19087, elapsed_compute: 124711537, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6247472, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 63020, elapsed_compute: 17569491, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12966461027, repartition_time: 9287545, send_time: 2603432029, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 63020, elapsed_compute: 362226700, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14770848, ] UnorderedScan: region=4569845203042(1064, 98), "partition_count":{"count":49, "mem_ranges":2, "files":16, "file_ranges":47} metrics=[output_rows: 3985000, mem_used: 905773318, build_parts_cost: 22320660, build_reader_cost: 12259610241, convert_cost: 9007278, elapsed_await: 12580056480, elapsed_poll: 442050469, scan_cost: 12564297950, yield_cost: 375714235, ] *************************** 38. row *************************** stage: 1 node: 36 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19046, elapsed_compute: 203062969, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5917168, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 46554, elapsed_compute: 11560300, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10573046419, repartition_time: 7950125, send_time: 16285651526, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 46554, elapsed_compute: 324212746, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 11551040, ] UnorderedScan: region=4569845202972(1064, 28), "partition_count":{"count":44, "mem_ranges":2, "files":7, "file_ranges":42} metrics=[output_rows: 3974444, mem_used: 600545752, build_parts_cost: 8355100, build_reader_cost: 9734661331, convert_cost: 11197222, elapsed_await: 10234717154, elapsed_poll: 593627687, scan_cost: 10219104434, yield_cost: 335084244, ] *************************** 39. row *************************** stage: 1 node: 37 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23342, elapsed_compute: 112541386, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6969856, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 74540, elapsed_compute: 5182624, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 33849407101, repartition_time: 10774568, send_time: 18308651988, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 74540, elapsed_compute: 450023895, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17958336, ] UnorderedScan: region=4569845203002(1064, 58), "partition_count":{"count":65, "mem_ranges":2, "files":17, "file_ranges":63} metrics=[output_rows: 5438491, mem_used: 1096298275, build_parts_cost: 28761104, build_reader_cost: 32905757949, convert_cost: 10310072, elapsed_await: 33363829302, elapsed_poll: 671212015, scan_cost: 33336740414, yield_cost: 473359199, ] *************************** 40. row *************************** stage: 1 node: 38 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19055, elapsed_compute: 132073592, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6079264, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 54474, elapsed_compute: 7685660, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 19622055884, repartition_time: 11039775, send_time: 3504484932, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 54474, elapsed_compute: 376727132, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13030128, ] UnorderedScan: region=4569845203016(1064, 72), "partition_count":{"count":49, "mem_ranges":2, "files":15, "file_ranges":47} metrics=[output_rows: 3819231, mem_used: 793761016, build_parts_cost: 270146890, build_reader_cost: 18554219507, convert_cost: 11991572, elapsed_await: 19216850782, elapsed_poll: 584316054, scan_cost: 19198785561, yield_cost: 384182365, ] *************************** 41. row *************************** stage: 1 node: 39 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23148, elapsed_compute: 133079329, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7063952, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 83370, elapsed_compute: 14053796, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18431278664, repartition_time: 11774913, send_time: 1533109464, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 83370, elapsed_compute: 513062918, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19749472, ] UnorderedScan: region=4569845203015(1064, 71), "partition_count":{"count":67, "mem_ranges":2, "files":18, "file_ranges":65} metrics=[output_rows: 5760531, mem_used: 1251322798, build_parts_cost: 61969709, build_reader_cost: 17423261134, convert_cost: 11188300, elapsed_await: 17892945139, elapsed_poll: 639654865, scan_cost: 17872089044, yield_cost: 523225156, ] *************************** 42. row *************************** stage: 1 node: 40 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24537, elapsed_compute: 118187026, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7128952, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 83161, elapsed_compute: 5628268, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 26621181531, repartition_time: 11847352, send_time: 6237678441, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 83161, elapsed_compute: 556973735, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19783760, ] UnorderedScan: region=4569845203030(1064, 86), "partition_count":{"count":70, "mem_ranges":2, "files":20, "file_ranges":68} metrics=[output_rows: 6074979, mem_used: 1271271761, build_parts_cost: 247727636, build_reader_cost: 25304036362, convert_cost: 15521860, elapsed_await: 26028382160, elapsed_poll: 713903465, scan_cost: 25990990434, yield_cost: 598488068, ] *************************** 43. row *************************** stage: 1 node: 41 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19532, elapsed_compute: 79588616, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6100232, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 54233, elapsed_compute: 4626197, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 19786503154, repartition_time: 10134352, send_time: 9434115539, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 54233, elapsed_compute: 346165163, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12894272, ] UnorderedScan: region=4569845202973(1064, 29), "partition_count":{"count":49, "mem_ranges":2, "files":12, "file_ranges":47} metrics=[output_rows: 4025958, mem_used: 750212383, build_parts_cost: 23312602, build_reader_cost: 19002412694, convert_cost: 6503613, elapsed_await: 19421422764, elapsed_poll: 524744735, scan_cost: 19406221526, yield_cost: 361032775, ] *************************** 44. row *************************** stage: 1 node: 42 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18944, elapsed_compute: 84784050, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6004064, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 58028, elapsed_compute: 7526502, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 13227992964, repartition_time: 8887274, send_time: 4172500007, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 58028, elapsed_compute: 336474744, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14171280, ] UnorderedScan: region=4569845203000(1064, 56), "partition_count":{"count":51, "mem_ranges":2, "files":18, "file_ranges":49} metrics=[output_rows: 3968106, mem_used: 899884994, build_parts_cost: 9497340, build_reader_cost: 12530156688, convert_cost: 7861807, elapsed_await: 12870071530, elapsed_poll: 445841353, scan_cost: 12851546330, yield_cost: 354625321, ] *************************** 45. row *************************** stage: 1 node: 43 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23592, elapsed_compute: 129861162, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7015144, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 76653, elapsed_compute: 5495688, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 24777586033, repartition_time: 11151358, send_time: 4332332513, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 76653, elapsed_compute: 465412711, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17818720, ] UnorderedScan: region=4569845202953(1064, 9), "partition_count":{"count":68, "mem_ranges":1, "files":17, "file_ranges":67} metrics=[output_rows: 5832088, mem_used: 1113237891, build_parts_cost: 10789138, build_reader_cost: 23836873363, convert_cost: 9639080, elapsed_await: 24284294819, elapsed_poll: 628824478, scan_cost: 24267656151, yield_cost: 476891005, ] *************************** 46. row *************************** stage: 1 node: 44 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 26473, elapsed_compute: 241691316, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7203408, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 80852, elapsed_compute: 9980931, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 20539443389, repartition_time: 11404035, send_time: 1791154281, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 80852, elapsed_compute: 609836899, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19231856, ] UnorderedScan: region=4569845203051(1064, 107), "partition_count":{"count":71, "mem_ranges":2, "files":14, "file_ranges":69} metrics=[output_rows: 6429023, mem_used: 1122725808, build_parts_cost: 246824314, build_reader_cost: 18959980941, convert_cost: 24390900, elapsed_await: 19895078137, elapsed_poll: 971264470, scan_cost: 19859739816, yield_cost: 632050749, ] *************************** 47. row *************************** stage: 1 node: 45 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19026, elapsed_compute: 112061066, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5952184, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 51051, elapsed_compute: 4758899, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 7436375667, repartition_time: 10503702, send_time: 8303366868, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 51051, elapsed_compute: 289837740, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12147024, ] UnorderedScan: region=4569845202949(1064, 5), "partition_count":{"count":46, "mem_ranges":2, "files":10, "file_ranges":44} metrics=[output_rows: 3966209, mem_used: 715910424, build_parts_cost: 4857430, build_reader_cost: 6809459264, convert_cost: 6678988, elapsed_await: 7131224763, elapsed_poll: 416572983, scan_cost: 7119542519, yield_cost: 294199684, ] *************************** 48. row *************************** stage: 1 node: 46 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 21776, elapsed_compute: 138506299, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6929280, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 76816, elapsed_compute: 5342715, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18223431512, repartition_time: 12414759, send_time: 6587974930, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 76816, elapsed_compute: 462320534, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17913984, ] UnorderedScan: region=4569845203004(1064, 60), "partition_count":{"count":58, "mem_ranges":2, "files":15, "file_ranges":56} metrics=[output_rows: 5084600, mem_used: 1072943712, build_parts_cost: 34834363, build_reader_cost: 17063457325, convert_cost: 14151396, elapsed_await: 17733366607, elapsed_poll: 820847530, scan_cost: 17704857587, yield_cost: 487914659, ] *************************** 49. row *************************** stage: 1 node: 47 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 28604, elapsed_compute: 156275177, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7756488, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 76273, elapsed_compute: 5427902, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12468201860, repartition_time: 21835327, send_time: 5229095186, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 76273, elapsed_compute: 605734777, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18409136, ] UnorderedScan: region=4569845202976(1064, 32), "partition_count":{"count":80, "mem_ranges":2, "files":10, "file_ranges":78} metrics=[output_rows: 7356766, mem_used: 1029696072, build_parts_cost: 17465715, build_reader_cost: 11106575485, convert_cost: 11355536, elapsed_await: 11842312702, elapsed_poll: 977308535, scan_cost: 11819694292, yield_cost: 615462671, ] *************************** 50. row *************************** stage: 1 node: 48 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19130, elapsed_compute: 89968807, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6074368, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 53412, elapsed_compute: 5443258, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 23814367937, repartition_time: 10452992, send_time: 13774271687, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 53412, elapsed_compute: 350595708, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12999456, ] UnorderedScan: region=4569845202988(1064, 44), "partition_count":{"count":45, "mem_ranges":2, "files":11, "file_ranges":43} metrics=[output_rows: 3852739, mem_used: 691002079, build_parts_cost: 11974765, build_reader_cost: 23022102979, convert_cost: 9954991, elapsed_await: 23447627178, elapsed_poll: 583837062, scan_cost: 23432550046, yield_cost: 352026874, ] *************************** 51. row *************************** stage: 1 node: 49 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19086, elapsed_compute: 100953318, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5970312, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 48861, elapsed_compute: 12817676, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12074712036, repartition_time: 8306900, send_time: 3479231209, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 48861, elapsed_compute: 304602813, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 11401680, ] UnorderedScan: region=4569845203036(1064, 92), "partition_count":{"count":43, "mem_ranges":2, "files":8, "file_ranges":41} metrics=[output_rows: 3762897, mem_used: 636213480, build_parts_cost: 198825165, build_reader_cost: 11108778147, convert_cost: 6504414, elapsed_await: 11754073882, elapsed_poll: 648943079, scan_cost: 11734771233, yield_cost: 315760246, ] *************************** 52. row *************************** stage: 1 node: 50 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19154, elapsed_compute: 129310051, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6136280, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 61007, elapsed_compute: 15809583, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 24345461669, repartition_time: 9460156, send_time: 8544235443, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 61007, elapsed_compute: 407210798, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14548928, ] UnorderedScan: region=4569845202989(1064, 45), "partition_count":{"count":50, "mem_ranges":2, "files":14, "file_ranges":48} metrics=[output_rows: 4285869, mem_used: 894655992, build_parts_cost: 13703235, build_reader_cost: 23298873971, convert_cost: 8988921, elapsed_await: 23911860601, elapsed_poll: 808696592, scan_cost: 23896794213, yield_cost: 413216684, ] *************************** 53. row *************************** stage: 1 node: 51 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 21924, elapsed_compute: 153001393, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6825712, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 71174, elapsed_compute: 6296202, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 31682541121, repartition_time: 13716542, send_time: 3225292230, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 71174, elapsed_compute: 436855281, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16602192, ] UnorderedScan: region=4569845202968(1064, 24), "partition_count":{"count":60, "mem_ranges":1, "files":17, "file_ranges":59} metrics=[output_rows: 4909710, mem_used: 1026228436, build_parts_cost: 11227267, build_reader_cost: 30844255100, convert_cost: 9779933, elapsed_await: 31224947813, elapsed_poll: 530421402, scan_cost: 31207462529, yield_cost: 448117432, ] *************************** 54. row *************************** stage: 1 node: 52 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 25986, elapsed_compute: 154561406, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7167856, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 79330, elapsed_compute: 7166929, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12427116354, repartition_time: 15737684, send_time: 773540280, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 79330, elapsed_compute: 549830342, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18808832, ] UnorderedScan: region=4569845203066(1064, 122), "partition_count":{"count":73, "mem_ranges":2, "files":15, "file_ranges":71} metrics=[output_rows: 6410222, mem_used: 1116859749, build_parts_cost: 36652470, build_reader_cost: 11297442348, convert_cost: 10320642, elapsed_await: 11851787243, elapsed_poll: 744409173, scan_cost: 11833412023, yield_cost: 553010847, ] *************************** 55. row *************************** stage: 1 node: 53 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23892, elapsed_compute: 92112283, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6884656, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 70830, elapsed_compute: 5702940, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18745684639, repartition_time: 10506631, send_time: 2973346029, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 70830, elapsed_compute: 517672258, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16900048, ] UnorderedScan: region=4569845202979(1064, 35), "partition_count":{"count":72, "mem_ranges":2, "files":17, "file_ranges":70} metrics=[output_rows: 6130335, mem_used: 1049805623, build_parts_cost: 18085077, build_reader_cost: 17682640956, convert_cost: 19616134, elapsed_await: 18201200724, elapsed_poll: 726161798, scan_cost: 18172995530, yield_cost: 533761549, ] *************************** 56. row *************************** stage: 1 node: 54 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 21604, elapsed_compute: 95511092, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6509592, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 64299, elapsed_compute: 10674284, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 20702971148, repartition_time: 18835103, send_time: 24804788464, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 64299, elapsed_compute: 455093160, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15407808, ] UnorderedScan: region=4569845203033(1064, 89), "partition_count":{"count":59, "mem_ranges":2, "files":15, "file_ranges":57} metrics=[output_rows: 5053543, mem_used: 966297634, build_parts_cost: 20977943, build_reader_cost: 19837074260, convert_cost: 10449238, elapsed_await: 20222051428, elapsed_poll: 545325078, scan_cost: 20203236716, yield_cost: 475921089, ] *************************** 57. row *************************** stage: 1 node: 55 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19259, elapsed_compute: 144175772, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6168552, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 58267, elapsed_compute: 13259020, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 9305832385, repartition_time: 17665885, send_time: 4172215544, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 58267, elapsed_compute: 384066317, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14044272, ] UnorderedScan: region=4569845203023(1064, 79), "partition_count":{"count":45, "mem_ranges":2, "files":10, "file_ranges":43} metrics=[output_rows: 3930139, mem_used: 758277568, build_parts_cost: 11884913, build_reader_cost: 8382749221, convert_cost: 7186578, elapsed_await: 8902135179, elapsed_poll: 672587292, scan_cost: 8887734631, yield_cost: 398180967, ] *************************** 58. row *************************** stage: 1 node: 56 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19097, elapsed_compute: 90632555, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6328016, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 64836, elapsed_compute: 24475905, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11910009866, repartition_time: 10825967, send_time: 4466801610, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 64836, elapsed_compute: 356659863, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15110144, ] UnorderedScan: region=4569845203009(1064, 65), "partition_count":{"count":51, "mem_ranges":2, "files":15, "file_ranges":49} metrics=[output_rows: 3989961, mem_used: 916552794, build_parts_cost: 7850877, build_reader_cost: 11161596213, convert_cost: 8996632, elapsed_await: 11530558008, elapsed_poll: 503027242, scan_cost: 11512712263, yield_cost: 368758536, ] *************************** 59. row *************************** stage: 1 node: 57 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19097, elapsed_compute: 97170868, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6023832, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 55485, elapsed_compute: 11845937, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11129111337, repartition_time: 8666601, send_time: 1029379252, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 55485, elapsed_compute: 336443108, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13582704, ] UnorderedScan: region=4569845203069(1064, 125), "partition_count":{"count":56, "mem_ranges":2, "files":19, "file_ranges":54} metrics=[output_rows: 4312018, mem_used: 837913510, build_parts_cost: 75831109, build_reader_cost: 10343584463, convert_cost: 8355348, elapsed_await: 10763791701, elapsed_poll: 471716880, scan_cost: 10746606213, yield_cost: 360829283, ] *************************** 60. row *************************** stage: 1 node: 58 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 25792, elapsed_compute: 140837291, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7103632, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 74514, elapsed_compute: 5761875, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18219925630, repartition_time: 11412879, send_time: 397130287, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 74514, elapsed_compute: 547471490, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17900304, ] UnorderedScan: region=4569845202997(1064, 53), "partition_count":{"count":74, "mem_ranges":2, "files":15, "file_ranges":72} metrics=[output_rows: 6417167, mem_used: 1055247352, build_parts_cost: 36354936, build_reader_cost: 17097613390, convert_cost: 17462954, elapsed_await: 17640998168, elapsed_poll: 827625356, scan_cost: 17614788869, yield_cost: 571002371, ] *************************** 61. row *************************** stage: 1 node: 59 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23694, elapsed_compute: 105426819, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7085032, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 82729, elapsed_compute: 8549473, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 23797173919, repartition_time: 17037404, send_time: 10530512982, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 82729, elapsed_compute: 473076050, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19817888, ] UnorderedScan: region=4569845203039(1064, 95), "partition_count":{"count":63, "mem_ranges":2, "files":16, "file_ranges":61} metrics=[output_rows: 5570846, mem_used: 1181814192, build_parts_cost: 298691085, build_reader_cost: 22434165076, convert_cost: 13033340, elapsed_await: 23285130782, elapsed_poll: 779896538, scan_cost: 23258573008, yield_cost: 509683785, ] *************************** 62. row *************************** stage: 1 node: 60 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19252, elapsed_compute: 121289629, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6010928, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 44750, elapsed_compute: 5695985, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 14549281477, repartition_time: 8058113, send_time: 11132004821, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 44750, elapsed_compute: 259867605, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 11126784, ] UnorderedScan: region=4569845202963(1064, 19), "partition_count":{"count":44, "mem_ranges":2, "files":8, "file_ranges":42} metrics=[output_rows: 3914488, mem_used: 585242256, build_parts_cost: 10535609, build_reader_cost: 13978020522, convert_cost: 4850596, elapsed_await: 14276842240, elapsed_poll: 385243814, scan_cost: 14267920635, yield_cost: 257183063, ] *************************** 63. row *************************** stage: 1 node: 61 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18944, elapsed_compute: 137887041, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6014928, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 59386, elapsed_compute: 11059976, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 8208558307, repartition_time: 13499824, send_time: 221387393, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 59386, elapsed_compute: 427126402, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14098336, ] UnorderedScan: region=4569845203061(1064, 117), "partition_count":{"count":50, "mem_ranges":2, "files":18, "file_ranges":48} metrics=[output_rows: 3947211, mem_used: 901283704, build_parts_cost: 290178651, build_reader_cost: 7034127222, convert_cost: 22075612, elapsed_await: 7752040759, elapsed_poll: 711787262, scan_cost: 7718735863, yield_cost: 447334326, ] *************************** 64. row *************************** stage: 1 node: 62 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19267, elapsed_compute: 96946941, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6000592, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 55656, elapsed_compute: 7202557, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 16607810307, repartition_time: 8908862, send_time: 18033075394, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 55656, elapsed_compute: 336798520, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13766112, ] UnorderedScan: region=4569845203001(1064, 57), "partition_count":{"count":60, "mem_ranges":1, "files":24, "file_ranges":59} metrics=[output_rows: 4509975, mem_used: 880236470, build_parts_cost: 7498831, build_reader_cost: 15907074380, convert_cost: 7273698, elapsed_await: 16248485839, elapsed_poll: 451458043, scan_cost: 16235026595, yield_cost: 349176349, ] *************************** 65. row *************************** stage: 1 node: 63 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 25616, elapsed_compute: 149275683, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7035440, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 71142, elapsed_compute: 5407164, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 28901690143, repartition_time: 9927697, send_time: 3779792990, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 71142, elapsed_compute: 455137917, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16922224, ] UnorderedScan: region=4569845202947(1064, 3), "partition_count":{"count":69, "mem_ranges":2, "files":12, "file_ranges":67} metrics=[output_rows: 6138757, mem_used: 968603583, build_parts_cost: 9752153, build_reader_cost: 28016309594, convert_cost: 8239408, elapsed_await: 28424060858, elapsed_poll: 543340955, scan_cost: 28404566806, yield_cost: 465935449, ] *************************** 66. row *************************** stage: 1 node: 64 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19024, elapsed_compute: 131105982, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6059024, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 60322, elapsed_compute: 7355344, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 8050951893, repartition_time: 9480701, send_time: 12470833139, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 60322, elapsed_compute: 309563566, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14456304, ] UnorderedScan: region=4569845202946(1064, 2), "partition_count":{"count":46, "mem_ranges":2, "files":14, "file_ranges":44} metrics=[output_rows: 3763024, mem_used: 865589643, build_parts_cost: 5693560, build_reader_cost: 7391503157, convert_cost: 7114483, elapsed_await: 7725017526, elapsed_poll: 428822653, scan_cost: 7712089346, yield_cost: 316321776, ] *************************** 67. row *************************** stage: 1 node: 65 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18914, elapsed_compute: 87664410, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5887640, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 47751, elapsed_compute: 4077544, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12286819593, repartition_time: 13408158, send_time: 3254808738, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 47751, elapsed_compute: 364944464, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 11273344, ] UnorderedScan: region=4569845203040(1064, 96), "partition_count":{"count":47, "mem_ranges":1, "files":11, "file_ranges":46} metrics=[output_rows: 4053689, mem_used: 680103232, build_parts_cost: 26209129, build_reader_cost: 11574333399, convert_cost: 6557033, elapsed_await: 11906984427, elapsed_poll: 489585234, scan_cost: 11895269304, yield_cost: 365169500, ] *************************** 68. row *************************** stage: 1 node: 66 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22702, elapsed_compute: 168325316, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6880832, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 71348, elapsed_compute: 6016458, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 14774828331, repartition_time: 15212005, send_time: 3527545967, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 71348, elapsed_compute: 478091469, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17356464, ] UnorderedScan: region=4569845203057(1064, 113), "partition_count":{"count":64, "mem_ranges":2, "files":15, "file_ranges":62} metrics=[output_rows: 5307423, mem_used: 975725424, build_parts_cost: 54979713, build_reader_cost: 13792267828, convert_cost: 10088932, elapsed_await: 14271352512, elapsed_poll: 658419193, scan_cost: 14251382033, yield_cost: 486222505, ] *************************** 69. row *************************** stage: 1 node: 67 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19210, elapsed_compute: 80436890, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6068496, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 56294, elapsed_compute: 8015465, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 14677734727, repartition_time: 9012878, send_time: 3681147348, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 56294, elapsed_compute: 383742225, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13258352, ] UnorderedScan: region=4569845202998(1064, 54), "partition_count":{"count":47, "mem_ranges":2, "files":13, "file_ranges":45} metrics=[output_rows: 3882310, mem_used: 746314110, build_parts_cost: 7520711, build_reader_cost: 13955912643, convert_cost: 6986468, elapsed_await: 14279131305, elapsed_poll: 450403814, scan_cost: 14266620137, yield_cost: 384575578, ] *************************** 70. row *************************** stage: 1 node: 68 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18842, elapsed_compute: 107936667, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5895336, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 57337, elapsed_compute: 4480096, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 19680569452, repartition_time: 13153060, send_time: 19570556453, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 57337, elapsed_compute: 322847478, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13695200, ] UnorderedScan: region=4569845203032(1064, 88), "partition_count":{"count":49, "mem_ranges":2, "files":15, "file_ranges":47} metrics=[output_rows: 3840927, mem_used: 847489619, build_parts_cost: 6281912, build_reader_cost: 19025143045, convert_cost: 9327528, elapsed_await: 19337330773, elapsed_poll: 446540557, scan_cost: 19316492473, yield_cost: 341776438, ] *************************** 71. row *************************** stage: 1 node: 69 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19110, elapsed_compute: 129838000, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5912016, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 45526, elapsed_compute: 5041748, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 7965131506, repartition_time: 13790223, send_time: 1437720736, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 45526, elapsed_compute: 377408707, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 10809680, ] UnorderedScan: region=4569845203065(1064, 121), "partition_count":{"count":45, "mem_ranges":1, "files":11, "file_ranges":44} metrics=[output_rows: 3846904, mem_used: 629812416, build_parts_cost: 56576188, build_reader_cost: 7206364918, convert_cost: 6359120, elapsed_await: 7568787047, elapsed_poll: 474331699, scan_cost: 7557424798, yield_cost: 387680981, ] *************************** 72. row *************************** stage: 1 node: 70 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18901, elapsed_compute: 108359231, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5918456, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 47585, elapsed_compute: 5114919, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12978914464, repartition_time: 8999929, send_time: 25609531129, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 47585, elapsed_compute: 343523937, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 11559360, ] UnorderedScan: region=4569845202985(1064, 41), "partition_count":{"count":48, "mem_ranges":1, "files":11, "file_ranges":47} metrics=[output_rows: 3971872, mem_used: 649504556, build_parts_cost: 36113197, build_reader_cost: 12309703609, convert_cost: 5983094, elapsed_await: 12621047664, elapsed_poll: 458185681, scan_cost: 12610304261, yield_cost: 342716131, ] *************************** 73. row *************************** stage: 1 node: 71 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18917, elapsed_compute: 101901596, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5975464, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 54615, elapsed_compute: 4783764, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 17645640142, repartition_time: 8678745, send_time: 13599903968, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 54615, elapsed_compute: 403975472, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13064720, ] UnorderedScan: region=4569845202957(1064, 13), "partition_count":{"count":49, "mem_ranges":1, "files":13, "file_ranges":48} metrics=[output_rows: 4032398, mem_used: 762527588, build_parts_cost: 6411998, build_reader_cost: 16920059458, convert_cost: 6357197, elapsed_await: 17214728829, elapsed_poll: 413373476, scan_cost: 17202767561, yield_cost: 395747034, ] *************************** 74. row *************************** stage: 1 node: 72 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24901, elapsed_compute: 169190350, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7093000, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 78531, elapsed_compute: 5358421, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 29513970570, repartition_time: 14677136, send_time: 10233087861, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 78531, elapsed_compute: 445879007, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18599344, ] UnorderedScan: region=4569845202959(1064, 15), "partition_count":{"count":71, "mem_ranges":2, "files":19, "file_ranges":69} metrics=[output_rows: 6177528, mem_used: 1142915842, build_parts_cost: 299575034, build_reader_cost: 28249738554, convert_cost: 11007155, elapsed_await: 29046998501, elapsed_poll: 659307389, scan_cost: 29024242455, yield_cost: 462759495, ] *************************** 75. row *************************** stage: 1 node: 73 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 27025, elapsed_compute: 136492706, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7200096, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 77126, elapsed_compute: 5934613, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 12004652929, repartition_time: 13472357, send_time: 3418826287, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 77126, elapsed_compute: 609658716, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18675456, ] UnorderedScan: region=4569845203063(1064, 119), "partition_count":{"count":73, "mem_ranges":2, "files":13, "file_ranges":71} metrics=[output_rows: 6731095, mem_used: 1083967888, build_parts_cost: 566479441, build_reader_cost: 10311846521, convert_cost: 10837933, elapsed_await: 11368859595, elapsed_poll: 859675118, scan_cost: 11344748920, yield_cost: 625786250, ] *************************** 76. row *************************** stage: 1 node: 74 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22083, elapsed_compute: 126469183, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6854728, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 71799, elapsed_compute: 10196514, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 8890910932, repartition_time: 24315024, send_time: 1880301414, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 71799, elapsed_compute: 548070703, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16758464, ] UnorderedScan: region=4569845203046(1064, 102), "partition_count":{"count":58, "mem_ranges":3, "files":14, "file_ranges":55} metrics=[output_rows: 5015020, mem_used: 1008551980, build_parts_cost: 226270102, build_reader_cost: 7654431019, convert_cost: 9646985, elapsed_await: 8309145786, elapsed_poll: 798015256, scan_cost: 8290249210, yield_cost: 565986115, ] *************************** 77. row *************************** stage: 1 node: 75 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19080, elapsed_compute: 90072713, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6056056, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 55519, elapsed_compute: 13388818, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18154970466, repartition_time: 9632172, send_time: 7338243424, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 55519, elapsed_compute: 399794290, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12757312, ] UnorderedScan: region=4569845203013(1064, 69), "partition_count":{"count":49, "mem_ranges":2, "files":15, "file_ranges":47} metrics=[output_rows: 4027177, mem_used: 823097703, build_parts_cost: 7398415, build_reader_cost: 17390094646, convert_cost: 7592916, elapsed_await: 17736684513, elapsed_poll: 505706670, scan_cost: 17716224490, yield_cost: 408157019, ] *************************** 78. row *************************** stage: 1 node: 76 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 28565, elapsed_compute: 231188573, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7887136, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 92838, elapsed_compute: 22330083, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 39313808160, repartition_time: 17107715, send_time: 2259150804, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 92838, elapsed_compute: 718126089, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 22052992, ] UnorderedScan: region=4569845203022(1064, 78), "partition_count":{"count":91, "mem_ranges":2, "files":22, "file_ranges":89} metrics=[output_rows: 7841647, mem_used: 1419037160, build_parts_cost: 50552642, build_reader_cost: 37850986035, convert_cost: 30952708, elapsed_await: 38547863468, elapsed_poll: 1016442511, scan_cost: 38501105442, yield_cost: 764651127, ] *************************** 79. row *************************** stage: 1 node: 77 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18839, elapsed_compute: 107748600, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5842672, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 42580, elapsed_compute: 4560165, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 9160365384, repartition_time: 15280875, send_time: 8038493121, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 42580, elapsed_compute: 305337158, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 10448480, ] UnorderedScan: region=4569845203008(1064, 64), "partition_count":{"count":43, "mem_ranges":2, "files":8, "file_ranges":41} metrics=[output_rows: 3804928, mem_used: 574049576, build_parts_cost: 17872011, build_reader_cost: 8513764502, convert_cost: 5533905, elapsed_await: 8842616421, elapsed_poll: 448517351, scan_cost: 8826506296, yield_cost: 311781313, ] *************************** 80. row *************************** stage: 1 node: 78 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19222, elapsed_compute: 155988496, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6064696, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 51651, elapsed_compute: 40408884, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10279760530, repartition_time: 13753678, send_time: 529367927, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 51651, elapsed_compute: 384605387, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12095616, ] UnorderedScan: region=4569845203052(1064, 108), "partition_count":{"count":46, "mem_ranges":2, "files":10, "file_ranges":44} metrics=[output_rows: 3916350, mem_used: 681686928, build_parts_cost: 504046265, build_reader_cost: 8862220450, convert_cost: 14423089, elapsed_await: 9854350433, elapsed_poll: 808172016, scan_cost: 9828247715, yield_cost: 408067043, ] *************************** 81. row *************************** stage: 1 node: 79 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19087, elapsed_compute: 86285933, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6451048, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 65939, elapsed_compute: 6007926, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 13329469679, repartition_time: 9835617, send_time: 2017597049, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 65939, elapsed_compute: 336626434, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15550608, ] UnorderedScan: region=4569845202978(1064, 34), "partition_count":{"count":51, "mem_ranges":2, "files":18, "file_ranges":49} metrics=[output_rows: 3957597, mem_used: 982069432, build_parts_cost: 15114813, build_reader_cost: 12683519630, convert_cost: 8316573, elapsed_await: 12974355246, elapsed_poll: 446110445, scan_cost: 12959078679, yield_cost: 343476354, ] *************************** 82. row *************************** stage: 1 node: 80 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 25588, elapsed_compute: 143171855, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7150840, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 79591, elapsed_compute: 5973669, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 29662397014, repartition_time: 10708440, send_time: 1177999248, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 79591, elapsed_compute: 580192045, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18474296, ] UnorderedScan: region=4569845202990(1064, 46), "partition_count":{"count":78, "mem_ranges":2, "files":20, "file_ranges":76} metrics=[output_rows: 6603631, mem_used: 1274039202, build_parts_cost: 24630090, build_reader_cost: 28504157489, convert_cost: 13928658, elapsed_await: 29059287931, elapsed_poll: 768908270, scan_cost: 29026791998, yield_cost: 597969462, ] *************************** 83. row *************************** stage: 1 node: 81 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18989, elapsed_compute: 89730190, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6034056, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 57411, elapsed_compute: 4742757, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10705450584, repartition_time: 9361491, send_time: 2067993227, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 57411, elapsed_compute: 422256222, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13603040, ] UnorderedScan: region=4569845203053(1064, 109), "partition_count":{"count":48, "mem_ranges":2, "files":12, "file_ranges":46} metrics=[output_rows: 4163398, mem_used: 804171282, build_parts_cost: 45321378, build_reader_cost: 9764141644, convert_cost: 7520592, elapsed_await: 10256757042, elapsed_poll: 590437820, scan_cost: 10243052022, yield_cost: 425780668, ] *************************** 84. row *************************** stage: 1 node: 82 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19075, elapsed_compute: 112130910, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6130736, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 60788, elapsed_compute: 10044521, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18223979623, repartition_time: 10392405, send_time: 6496354441, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 60788, elapsed_compute: 364962603, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14509328, ] UnorderedScan: region=4569845203021(1064, 77), "partition_count":{"count":52, "mem_ranges":2, "files":15, "file_ranges":50} metrics=[output_rows: 4200574, mem_used: 878314456, build_parts_cost: 9968246, build_reader_cost: 17540048810, convert_cost: 7727333, elapsed_await: 17842115502, elapsed_poll: 424504322, scan_cost: 17827679238, yield_cost: 378922448, ] *************************** 85. row *************************** stage: 1 node: 83 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18910, elapsed_compute: 81512345, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6137760, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 62656, elapsed_compute: 4934210, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 18818825687, repartition_time: 10164386, send_time: 18936282257, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 62656, elapsed_compute: 379114315, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14762720, ] UnorderedScan: region=4569845203025(1064, 81), "partition_count":{"count":50, "mem_ranges":2, "files":16, "file_ranges":48} metrics=[output_rows: 3792055, mem_used: 898936820, build_parts_cost: 5647816, build_reader_cost: 18081645547, convert_cost: 11894176, elapsed_await: 18408707601, elapsed_poll: 484757600, scan_cost: 18390402578, yield_cost: 387185716, ] *************************** 86. row *************************** stage: 1 node: 84 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19047, elapsed_compute: 98475637, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6150688, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 61402, elapsed_compute: 5030805, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 25155077438, repartition_time: 15303319, send_time: 6769963932, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 61402, elapsed_compute: 303775785, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14238224, ] UnorderedScan: region=4569845202974(1064, 30), "partition_count":{"count":51, "mem_ranges":2, "files":16, "file_ranges":49} metrics=[output_rows: 3779846, mem_used: 874354108, build_parts_cost: 95179352, build_reader_cost: 24465523872, convert_cost: 6799175, elapsed_await: 24834792641, elapsed_poll: 408693385, scan_cost: 24818152158, yield_cost: 317859163, ] *************************** 87. row *************************** stage: 1 node: 85 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18830, elapsed_compute: 82435836, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5944744, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 51297, elapsed_compute: 4384792, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 6554751559, repartition_time: 8884614, send_time: 5390987548, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 51297, elapsed_compute: 282102388, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12324136, ] UnorderedScan: region=4569845203043(1064, 99), "partition_count":{"count":47, "mem_ranges":2, "files":10, "file_ranges":45} metrics=[output_rows: 4021296, mem_used: 688438704, build_parts_cost: 45863617, build_reader_cost: 5904313390, convert_cost: 6524448, elapsed_await: 6254530337, elapsed_poll: 421698104, scan_cost: 6242951560, yield_cost: 295891044, ] *************************** 88. row *************************** stage: 1 node: 86 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24957, elapsed_compute: 112187460, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7072832, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 75674, elapsed_compute: 5242789, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 42454084201, repartition_time: 11580911, send_time: 3107967212, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 75674, elapsed_compute: 497509643, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18038976, ] UnorderedScan: region=4569845202971(1064, 27), "partition_count":{"count":74, "mem_ranges":2, "files":20, "file_ranges":72} metrics=[output_rows: 6133666, mem_used: 1069417857, build_parts_cost: 85445231, build_reader_cost: 41368211061, convert_cost: 14217872, elapsed_await: 41928494931, elapsed_poll: 669622945, scan_cost: 41905617626, yield_cost: 509664792, ] *************************** 89. row *************************** stage: 1 node: 87 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 25583, elapsed_compute: 123935869, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6957664, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 69810, elapsed_compute: 5211469, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 31542339215, repartition_time: 24203404, send_time: 5887822008, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 69810, elapsed_compute: 559797515, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16496080, ] UnorderedScan: region=4569845203011(1064, 67), "partition_count":{"count":74, "mem_ranges":2, "files":16, "file_ranges":72} metrics=[output_rows: 6384195, mem_used: 1037565386, build_parts_cost: 23134326, build_reader_cost: 30429349034, convert_cost: 17920131, elapsed_await: 30945356473, elapsed_poll: 763878918, scan_cost: 30913348753, yield_cost: 590260298, ] *************************** 90. row *************************** stage: 1 node: 88 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19293, elapsed_compute: 131874284, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6063496, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 55171, elapsed_compute: 13491359, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 15690324856, repartition_time: 9508187, send_time: 10372990469, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 55171, elapsed_compute: 314388652, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12824752, ] UnorderedScan: region=4569845202948(1064, 4), "partition_count":{"count":47, "mem_ranges":2, "files":11, "file_ranges":45} metrics=[output_rows: 4052509, mem_used: 774095608, build_parts_cost: 91859972, build_reader_cost: 14904182173, convert_cost: 10468250, elapsed_await: 15356774400, elapsed_poll: 480376254, scan_cost: 15340527717, yield_cost: 324247427, ] *************************** 91. row *************************** stage: 1 node: 89 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19296, elapsed_compute: 85697350, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6728008, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 80873, elapsed_compute: 9249791, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 45567427327, repartition_time: 19499415, send_time: 1759661811, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 80873, elapsed_compute: 683558090, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19160424, ] UnorderedScan: region=4569845203031(1064, 87), "partition_count":{"count":109, "mem_ranges":2, "files":33, "file_ranges":107} metrics=[output_rows: 8966945, mem_used: 1559716797, build_parts_cost: 72138514, build_reader_cost: 44163158619, convert_cost: 27840121, elapsed_await: 44831972926, elapsed_poll: 977747997, scan_cost: 44787291701, yield_cost: 734039102, ] *************************** 92. row *************************** stage: 1 node: 90 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19686, elapsed_compute: 152288451, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6947032, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 97719, elapsed_compute: 7844489, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 52726529415, repartition_time: 16879146, send_time: 1037859699, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 97719, elapsed_compute: 1133954740, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 23420432, ] UnorderedScan: region=4569845202960(1064, 16), "partition_count":{"count":189, "mem_ranges":2, "files":115, "file_ranges":187} metrics=[output_rows: 13000322, mem_used: 3848704542, build_parts_cost: 107628554, build_reader_cost: 50326985773, convert_cost: 41460273, elapsed_await: 51501874503, elapsed_poll: 1499298696, scan_cost: 51431104699, yield_cost: 1228210732, ] *************************** 93. row *************************** stage: 1 node: 91 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18910, elapsed_compute: 126255270, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6366080, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 66620, elapsed_compute: 6549023, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 5295871609, repartition_time: 9700576, send_time: 11673124, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 66620, elapsed_compute: 472588776, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15900432, ] UnorderedScan: region=4569845203056(1064, 112), "partition_count":{"count":63, "mem_ranges":2, "files":18, "file_ranges":61} metrics=[output_rows: 5457447, mem_used: 1098005352, build_parts_cost: 320673670, build_reader_cost: 4085495150, convert_cost: 24230853, elapsed_await: 4800064296, elapsed_poll: 936247880, scan_cost: 4766419513, yield_cost: 497169904, ] *************************** 94. row *************************** stage: 1 node: 92 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19080, elapsed_compute: 110454914, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6350456, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 63647, elapsed_compute: 7291735, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 14643914596, repartition_time: 9443190, send_time: 2510278336, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 63647, elapsed_compute: 417395999, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15057456, ] UnorderedScan: region=4569845203026(1064, 82), "partition_count":{"count":51, "mem_ranges":2, "files":16, "file_ranges":49} metrics=[output_rows: 4046142, mem_used: 953855946, build_parts_cost: 30326123, build_reader_cost: 13819886253, convert_cost: 12645934, elapsed_await: 14207204317, elapsed_poll: 529185660, scan_cost: 14187519289, yield_cost: 432127742, ] *************************** 95. row *************************** stage: 1 node: 93 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19353, elapsed_compute: 89105317, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6175616, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 58586, elapsed_compute: 5388963, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10535672600, repartition_time: 9567220, send_time: 9200780490, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 58586, elapsed_compute: 352707651, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13480624, ] UnorderedScan: region=4569845203037(1064, 93), "partition_count":{"count":47, "mem_ranges":2, "files":14, "file_ranges":45} metrics=[output_rows: 3990488, mem_used: 852640360, build_parts_cost: 15988551, build_reader_cost: 9847105417, convert_cost: 7862409, elapsed_await: 10165726120, elapsed_poll: 428927749, scan_cost: 10150051053, yield_cost: 359558326, ] *************************** 96. row *************************** stage: 1 node: 94 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19167, elapsed_compute: 128088770, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6381304, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 64933, elapsed_compute: 8711658, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10576263332, repartition_time: 16155859, send_time: 1826072682, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 64933, elapsed_compute: 321930781, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15308432, ] UnorderedScan: region=4569845203058(1064, 114), "partition_count":{"count":51, "mem_ranges":2, "files":17, "file_ranges":49} metrics=[output_rows: 4125761, mem_used: 965235295, build_parts_cost: 28028304, build_reader_cost: 9822684501, convert_cost: 12279768, elapsed_await: 10230139768, elapsed_poll: 538110839, scan_cost: 10202556007, yield_cost: 352938979, ] *************************** 97. row *************************** stage: 1 node: 95 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19077, elapsed_compute: 121912304, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5999904, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 56710, elapsed_compute: 10550719, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10920460468, repartition_time: 13885864, send_time: 657041580, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 56710, elapsed_compute: 452750444, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13672416, ] UnorderedScan: region=4569845203050(1064, 106), "partition_count":{"count":47, "mem_ranges":2, "files":14, "file_ranges":45} metrics=[output_rows: 3838198, mem_used: 781323372, build_parts_cost: 250990742, build_reader_cost: 9858338720, convert_cost: 12126987, elapsed_await: 10444772753, elapsed_poll: 553490624, scan_cost: 10426564387, yield_cost: 445034650, ] *************************** 98. row *************************** stage: 1 node: 96 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23409, elapsed_compute: 142689228, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6966408, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 73707, elapsed_compute: 30760374, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 16122947445, repartition_time: 14233005, send_time: 2470521576, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 73707, elapsed_compute: 529587906, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17212128, ] UnorderedScan: region=4569845202993(1064, 49), "partition_count":{"count":67, "mem_ranges":2, "files":17, "file_ranges":65} metrics=[output_rows: 5484305, mem_used: 1038030872, build_parts_cost: 28661555, build_reader_cost: 15069768819, convert_cost: 9571568, elapsed_await: 15572340202, elapsed_poll: 740107218, scan_cost: 15546474433, yield_cost: 525525780, ] *************************** 99. row *************************** stage: 1 node: 97 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18781, elapsed_compute: 93064010, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6093936, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 62048, elapsed_compute: 11303461, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 13902038464, repartition_time: 9279041, send_time: 5621482528, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 62048, elapsed_compute: 341994944, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14688688, ] UnorderedScan: region=4569845202962(1064, 18), "partition_count":{"count":50, "mem_ranges":2, "files":16, "file_ranges":48} metrics=[output_rows: 4134365, mem_used: 925152368, build_parts_cost: 14609848, build_reader_cost: 13103933919, convert_cost: 7840129, elapsed_await: 13543602043, elapsed_poll: 533853044, scan_cost: 13529035684, yield_cost: 352945138, ] *************************** 100. row *************************** stage: 1 node: 98 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23222, elapsed_compute: 190448025, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6988088, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 75491, elapsed_compute: 9053693, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 17809063323, repartition_time: 11159667, send_time: 3757637820, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 75491, elapsed_compute: 472655226, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18117232, ] UnorderedScan: region=4569845203014(1064, 70), "partition_count":{"count":62, "mem_ranges":2, "files":19, "file_ranges":60} metrics=[output_rows: 5183398, mem_used: 1078885440, build_parts_cost: 50311791, build_reader_cost: 16896863065, convert_cost: 11134605, elapsed_await: 17302657312, elapsed_poll: 522223762, scan_cost: 17283266708, yield_cost: 497701898, ] *************************** 101. row *************************** stage: 1 node: 99 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19183, elapsed_compute: 81926038, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5955936, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 54674, elapsed_compute: 5102784, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 5322786538, repartition_time: 8858950, send_time: 1799441246, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 54674, elapsed_compute: 313192744, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13219552, ] UnorderedScan: region=4569845202992(1064, 48), "partition_count":{"count":45, "mem_ranges":2, "files":9, "file_ranges":43} metrics=[output_rows: 3789588, mem_used: 725360400, build_parts_cost: 46618879, build_reader_cost: 4541717541, convert_cost: 6923902, elapsed_await: 4990389515, elapsed_poll: 538545143, scan_cost: 4977934665, yield_cost: 317527975, ] *************************** 102. row *************************** stage: 1 node: 100 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19507, elapsed_compute: 131512550, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6472448, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 66094, elapsed_compute: 5183651, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 17172150678, repartition_time: 16681955, send_time: 3000300883, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 66094, elapsed_compute: 400469123, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15602912, ] UnorderedScan: region=4569845203006(1064, 62), "partition_count":{"count":51, "mem_ranges":2, "files":17, "file_ranges":49} metrics=[output_rows: 3993581, mem_used: 945722154, build_parts_cost: 20695679, build_reader_cost: 16457830592, convert_cost: 9032134, elapsed_await: 16752877135, elapsed_poll: 436711097, scan_cost: 16735901862, yield_cost: 391745756, ] *************************** 103. row *************************** stage: 1 node: 101 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 21329, elapsed_compute: 93176685, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6874896, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 74748, elapsed_compute: 8800425, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 24937887356, repartition_time: 10418930, send_time: 3274228913, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 74748, elapsed_compute: 489180319, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17563248, ] UnorderedScan: region=4569845202981(1064, 37), "partition_count":{"count":65, "mem_ranges":2, "files":18, "file_ranges":63} metrics=[output_rows: 5541741, mem_used: 1157499559, build_parts_cost: 24142443, build_reader_cost: 24003220507, convert_cost: 9666701, elapsed_await: 24410451447, elapsed_poll: 592053007, scan_cost: 24392960226, yield_cost: 499113068, ] *************************** 104. row *************************** stage: 1 node: 102 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19411, elapsed_compute: 85359930, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6190696, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 60123, elapsed_compute: 4361900, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 13577700061, repartition_time: 11247524, send_time: 8145455391, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 60123, elapsed_compute: 332114089, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14055248, ] UnorderedScan: region=4569845203034(1064, 90), "partition_count":{"count":49, "mem_ranges":2, "files":14, "file_ranges":47} metrics=[output_rows: 4111323, mem_used: 849916688, build_parts_cost: 203141497, build_reader_cost: 12706027211, convert_cost: 10752601, elapsed_await: 13229497780, elapsed_poll: 458184744, scan_cost: 13207868041, yield_cost: 339982085, ] *************************** 105. row *************************** stage: 1 node: 103 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19003, elapsed_compute: 123041361, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6531280, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 68280, elapsed_compute: 4856159, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11492554583, repartition_time: 10536200, send_time: 3593448547, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 68280, elapsed_compute: 433786223, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15917696, ] UnorderedScan: region=4569845203029(1064, 85), "partition_count":{"count":60, "mem_ranges":1, "files":23, "file_ranges":59} metrics=[output_rows: 4640763, mem_used: 1093909280, build_parts_cost: 56952764, build_reader_cost: 10621192985, convert_cost: 14873197, elapsed_await: 11035687869, elapsed_poll: 587554137, scan_cost: 11011997430, yield_cost: 445028187, ] *************************** 106. row *************************** stage: 1 node: 104 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19054, elapsed_compute: 115705626, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6049120, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 50712, elapsed_compute: 5007660, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 1894380234, repartition_time: 7034913, send_time: 3024100, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 50712, elapsed_compute: 296518543, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12251008, ] UnorderedScan: region=4569845203049(1064, 105), "partition_count":{"count":47, "mem_ranges":1, "files":12, "file_ranges":46} metrics=[output_rows: 3924704, mem_used: 707243440, build_parts_cost: 82456019, build_reader_cost: 1275018404, convert_cost: 7404915, elapsed_await: 1582048255, elapsed_poll: 431566520, scan_cost: 1569084542, yield_cost: 301414465, ] *************************** 107. row *************************** stage: 1 node: 105 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19045, elapsed_compute: 73601325, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6061992, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 58519, elapsed_compute: 5040570, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 14288560565, repartition_time: 11882274, send_time: 30072667410, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 58519, elapsed_compute: 339318336, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13776640, ] UnorderedScan: region=4569845202961(1064, 17), "partition_count":{"count":46, "mem_ranges":2, "files":11, "file_ranges":44} metrics=[output_rows: 3970231, mem_used: 799970068, build_parts_cost: 5760139, build_reader_cost: 13606112549, convert_cost: 6878953, elapsed_await: 13922785990, elapsed_poll: 430513750, scan_cost: 13910137276, yield_cost: 356998681, ] *************************** 108. row *************************** stage: 1 node: 106 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19002, elapsed_compute: 102710795, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6102272, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 61764, elapsed_compute: 5502110, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11290561240, repartition_time: 9549492, send_time: 2317464311, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 61764, elapsed_compute: 341326446, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14344896, ] UnorderedScan: region=4569845203070(1064, 126), "partition_count":{"count":48, "mem_ranges":2, "files":14, "file_ranges":46} metrics=[output_rows: 3964447, mem_used: 848447094, build_parts_cost: 27377540, build_reader_cost: 10578792199, convert_cost: 7327107, elapsed_await: 10923388757, elapsed_poll: 458493492, scan_cost: 10905987262, yield_cost: 355938872, ] *************************** 109. row *************************** stage: 1 node: 107 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22786, elapsed_compute: 150370093, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7046432, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 83352, elapsed_compute: 14587740, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 15834905368, repartition_time: 15761045, send_time: 1353394197, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 83352, elapsed_compute: 517883850, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19723200, ] UnorderedScan: region=4569845203064(1064, 120), "partition_count":{"count":68, "mem_ranges":2, "files":24, "file_ranges":66} metrics=[output_rows: 5321721, mem_used: 1312355832, build_parts_cost: 831033264, build_reader_cost: 14015914967, convert_cost: 18583951, elapsed_await: 15283502114, elapsed_poll: 686768558, scan_cost: 15255052132, yield_cost: 547336823, ] *************************** 110. row *************************** stage: 1 node: 108 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19146, elapsed_compute: 117417333, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6242072, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 61991, elapsed_compute: 20479855, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 16899730445, repartition_time: 12268501, send_time: 8777618874, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 61991, elapsed_compute: 445430563, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14564032, ] UnorderedScan: region=4569845202977(1064, 33), "partition_count":{"count":51, "mem_ranges":2, "files":15, "file_ranges":49} metrics=[output_rows: 4092616, mem_used: 897838648, build_parts_cost: 47789331, build_reader_cost: 16045268887, convert_cost: 7821777, elapsed_await: 16434211839, elapsed_poll: 562495641, scan_cost: 16416584878, yield_cost: 455962752, ] *************************** 111. row *************************** stage: 1 node: 109 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19269, elapsed_compute: 114000174, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6016528, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 57636, elapsed_compute: 11579536, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 10565703168, repartition_time: 9530535, send_time: 12360714248, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 57636, elapsed_compute: 385762141, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13790640, ] UnorderedScan: region=4569845202952(1064, 8), "partition_count":{"count":48, "mem_ranges":2, "files":15, "file_ranges":46} metrics=[output_rows: 3860760, mem_used: 839690008, build_parts_cost: 15685416, build_reader_cost: 9772826677, convert_cost: 7669153, elapsed_await: 10155563232, elapsed_poll: 487762345, scan_cost: 10141594220, yield_cost: 404921022, ] *************************** 112. row *************************** stage: 1 node: 110 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18948, elapsed_compute: 137724447, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6027608, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 56851, elapsed_compute: 8873393, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 13641285996, repartition_time: 11868628, send_time: 3474817631, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 56851, elapsed_compute: 359657707, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13226816, ] UnorderedScan: region=4569845202951(1064, 7), "partition_count":{"count":47, "mem_ranges":2, "files":10, "file_ranges":45} metrics=[output_rows: 3958030, mem_used: 769408272, build_parts_cost: 8260713, build_reader_cost: 12903231497, convert_cost: 6935335, elapsed_await: 13266464760, elapsed_poll: 463488300, scan_cost: 13253885295, yield_cost: 357700210, ] *************************** 113. row *************************** stage: 1 node: 111 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19036, elapsed_compute: 111151095, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5992280, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 58051, elapsed_compute: 9414598, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 13831842275, repartition_time: 9227760, send_time: 2537784620, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 58051, elapsed_compute: 356779098, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13688736, ] UnorderedScan: region=4569845203045(1064, 101), "partition_count":{"count":47, "mem_ranges":1, "files":13, "file_ranges":46} metrics=[output_rows: 3988859, mem_used: 819507752, build_parts_cost: 17009008, build_reader_cost: 13160009614, convert_cost: 7482424, elapsed_await: 13455846746, elapsed_poll: 403365876, scan_cost: 13442383229, yield_cost: 363058176, ] *************************** 114. row *************************** stage: 1 node: 112 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24995, elapsed_compute: 131557663, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7139112, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 81683, elapsed_compute: 8029620, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 15057336341, repartition_time: 12075498, send_time: 1114916874, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 81683, elapsed_compute: 587784001, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18671568, ] UnorderedScan: region=4569845203060(1064, 116), "partition_count":{"count":73, "mem_ranges":2, "files":18, "file_ranges":71} metrics=[output_rows: 6308040, mem_used: 1218144184, build_parts_cost: 70596092, build_reader_cost: 13845448006, convert_cost: 13273292, elapsed_await: 14431187599, elapsed_poll: 786944363, scan_cost: 14405175884, yield_cost: 619898075, ] *************************** 115. row *************************** stage: 1 node: 113 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 28359, elapsed_compute: 224015504, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7555608, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 77721, elapsed_compute: 5678358, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 3546464260, repartition_time: 14374728, send_time: 3835075, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 77721, elapsed_compute: 584127050, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18518096, ] UnorderedScan: region=4569845203054(1064, 110), "partition_count":{"count":87, "mem_ranges":2, "files":18, "file_ranges":85} metrics=[output_rows: 7455119, mem_used: 1170484983, build_parts_cost: 158752497, build_reader_cost: 2255401355, convert_cost: 13322193, elapsed_await: 2924944768, elapsed_poll: 907420968, scan_cost: 2900872153, yield_cost: 608805704, ] *************************** 116. row *************************** stage: 1 node: 114 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23830, elapsed_compute: 158577291, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6987304, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 73793, elapsed_compute: 20387548, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 20956117144, repartition_time: 15038424, send_time: 703761799, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 73793, elapsed_compute: 520711256, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 17357056, ] UnorderedScan: region=4569845203068(1064, 124), "partition_count":{"count":64, "mem_ranges":2, "files":15, "file_ranges":62} metrics=[output_rows: 5493061, mem_used: 1053847110, build_parts_cost: 102913394, build_reader_cost: 19896292820, convert_cost: 15023415, elapsed_await: 20400765263, elapsed_poll: 659895217, scan_cost: 20375235196, yield_cost: 539309312, ] *************************** 117. row *************************** stage: 1 node: 115 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 28485, elapsed_compute: 199235214, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7698408, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 80479, elapsed_compute: 6299171, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 15127964760, repartition_time: 18108031, send_time: 3392528725, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 80479, elapsed_compute: 769724718, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19085408, ] UnorderedScan: region=4569845203024(1064, 80), "partition_count":{"count":88, "mem_ranges":2, "files":16, "file_ranges":86} metrics=[output_rows: 7979267, mem_used: 1157873544, build_parts_cost: 503916055, build_reader_cost: 13074672173, convert_cost: 16066806, elapsed_await: 14310821862, elapsed_poll: 1181780673, scan_cost: 14284125394, yield_cost: 778693501, ] *************************** 118. row *************************** stage: 1 node: 116 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 18896, elapsed_compute: 117591880, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5992112, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 48630, elapsed_compute: 9077805, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 21224967035, repartition_time: 10618188, send_time: 1857815540, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 48630, elapsed_compute: 364098301, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 11620944, ] UnorderedScan: region=4569845203017(1064, 73), "partition_count":{"count":48, "mem_ranges":1, "files":13, "file_ranges":47} metrics=[output_rows: 4035631, mem_used: 699741720, build_parts_cost: 322387057, build_reader_cost: 20196184800, convert_cost: 13833453, elapsed_await: 20835057369, elapsed_poll: 565700826, scan_cost: 20812196059, yield_cost: 381592040, ] *************************** 119. row *************************** stage: 1 node: 117 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24038, elapsed_compute: 185051089, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6511360, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 62204, elapsed_compute: 4544186, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 19665707293, repartition_time: 9814989, send_time: 5947647812, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 62204, elapsed_compute: 379045377, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 14771232, ] UnorderedScan: region=4569845202944(1064, 0), "partition_count":{"count":62, "mem_ranges":2, "files":8, "file_ranges":60} metrics=[output_rows: 5815203, mem_used: 788735608, build_parts_cost: 29364857, build_reader_cost: 18812490364, convert_cost: 11380467, elapsed_await: 19264880478, elapsed_poll: 558365617, scan_cost: 19247418584, yield_cost: 396911573, ] *************************** 120. row *************************** stage: 1 node: 118 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24954, elapsed_compute: 126964616, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7115224, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 78943, elapsed_compute: 13613081, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 19085943245, repartition_time: 20255218, send_time: 1395315753, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 78943, elapsed_compute: 549029824, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18772736, ] UnorderedScan: region=4569845203028(1064, 84), "partition_count":{"count":67, "mem_ranges":2, "files":15, "file_ranges":65} metrics=[output_rows: 5838991, mem_used: 1106782900, build_parts_cost: 23985014, build_reader_cost: 17961019573, convert_cost: 20856044, elapsed_await: 18512248568, elapsed_poll: 751418690, scan_cost: 18465700773, yield_cost: 580170796, ] *************************** 121. row *************************** stage: 1 node: 119 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19164, elapsed_compute: 101066026, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6044216, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 53535, elapsed_compute: 6433490, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 6022579799, repartition_time: 17803132, send_time: 2942702983, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 53535, elapsed_compute: 387986873, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13012576, ] UnorderedScan: region=4569845203071(1064, 127), "partition_count":{"count":48, "mem_ranges":2, "files":10, "file_ranges":46} metrics=[output_rows: 4115080, mem_used: 713605728, build_parts_cost: 70706029, build_reader_cost: 4925539567, convert_cost: 8672562, elapsed_await: 5604455684, elapsed_poll: 784550712, scan_cost: 5581015417, yield_cost: 396245171, ] *************************** 122. row *************************** stage: 1 node: 120 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22618, elapsed_compute: 136152858, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6980304, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 78142, elapsed_compute: 5239547, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 21219545463, repartition_time: 15625097, send_time: 5446971430, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 78142, elapsed_compute: 529009014, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18897808, ] UnorderedScan: region=4569845202975(1064, 31), "partition_count":{"count":61, "mem_ranges":2, "files":16, "file_ranges":59} metrics=[output_rows: 5422817, mem_used: 1118832672, build_parts_cost: 9714279, build_reader_cost: 20070377740, convert_cost: 13772537, elapsed_await: 20669038304, elapsed_poll: 754310512, scan_cost: 20639820369, yield_cost: 512447256, ] *************************** 123. row *************************** stage: 1 node: 121 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19061, elapsed_compute: 100347367, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5983496, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 54755, elapsed_compute: 4818343, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 15252302834, repartition_time: 13441278, send_time: 2007036267, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 54755, elapsed_compute: 390585590, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 12830624, ] UnorderedScan: region=4569845202995(1064, 51), "partition_count":{"count":54, "mem_ranges":2, "files":15, "file_ranges":52} metrics=[output_rows: 4218191, mem_used: 804265599, build_parts_cost: 25729863, build_reader_cost: 14505187853, convert_cost: 7100325, elapsed_await: 14845891913, elapsed_poll: 473036618, scan_cost: 14832604961, yield_cost: 388667593, ] *************************** 124. row *************************** stage: 1 node: 122 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 24665, elapsed_compute: 138604938, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6922584, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 68885, elapsed_compute: 13009335, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 8422801939, repartition_time: 11760439, send_time: 4710704409, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 68885, elapsed_compute: 486364483, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16343024, ] UnorderedScan: region=4569845203035(1064, 91), "partition_count":{"count":61, "mem_ranges":3, "files":9, "file_ranges":58} metrics=[output_rows: 5653410, mem_used: 868865728, build_parts_cost: 43645645, build_reader_cost: 7494726152, convert_cost: 8776340, elapsed_await: 7917184785, elapsed_poll: 610566924, scan_cost: 7901113396, yield_cost: 474416402, ] *************************** 125. row *************************** stage: 1 node: 123 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 19049, elapsed_compute: 90396346, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 5969312, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 57150, elapsed_compute: 4510496, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 22633556320, repartition_time: 8700478, send_time: 5535240291, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 57150, elapsed_compute: 297559576, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 13486592, ] UnorderedScan: region=4569845202970(1064, 26), "partition_count":{"count":48, "mem_ranges":1, "files":16, "file_ranges":47} metrics=[output_rows: 3901917, mem_used: 811898896, build_parts_cost: 71430532, build_reader_cost: 22019198505, convert_cost: 6574884, elapsed_await: 22320889497, elapsed_poll: 325617884, scan_cost: 22308484707, yield_cost: 304146826, ] *************************** 126. row *************************** stage: 1 node: 124 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 25123, elapsed_compute: 148120597, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7118968, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 78397, elapsed_compute: 6371142, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11614699928, repartition_time: 14645667, send_time: 1191279876, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 78397, elapsed_compute: 586779716, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 18405728, ] UnorderedScan: region=4569845202987(1064, 43), "partition_count":{"count":72, "mem_ranges":1, "files":18, "file_ranges":71} metrics=[output_rows: 6457187, mem_used: 1212662216, build_parts_cost: 64768815, build_reader_cost: 10422546050, convert_cost: 23232784, elapsed_await: 10999366493, elapsed_poll: 788933132, scan_cost: 10965793441, yield_cost: 614632855, ] *************************** 127. row *************************** stage: 1 node: 125 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 22450, elapsed_compute: 115302044, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6801864, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 69133, elapsed_compute: 5304250, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 16672867953, repartition_time: 16256563, send_time: 9366733525, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 69133, elapsed_compute: 438342556, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 16206352, ] UnorderedScan: region=4569845203027(1064, 83), "partition_count":{"count":61, "mem_ranges":2, "files":14, "file_ranges":59} metrics=[output_rows: 5367674, mem_used: 969707060, build_parts_cost: 25803425, build_reader_cost: 15744880327, convert_cost: 18125860, elapsed_await: 16214496175, elapsed_poll: 670569888, scan_cost: 16184064442, yield_cost: 465611890, ] *************************** 128. row *************************** stage: 1 node: 126 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23554, elapsed_compute: 164629739, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 6844632, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 67855, elapsed_compute: 5745214, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 11957968332, repartition_time: 15980572, send_time: 3097175082, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 67855, elapsed_compute: 460310611, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 15769912, ] UnorderedScan: region=4569845203062(1064, 118), "partition_count":{"count":64, "mem_ranges":2, "files":13, "file_ranges":62} metrics=[output_rows: 5493075, mem_used: 940542792, build_parts_cost: 226537381, build_reader_cost: 10820891579, convert_cost: 14110264, elapsed_await: 11474011381, elapsed_poll: 652673569, scan_cost: 11452460791, yield_cost: 472948357, ] *************************** 129. row *************************** stage: 1 node: 127 plan: AggregateExec: mode=FinalPartitioned, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 23073, elapsed_compute: 179051997, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, peak_mem_used: 7070184, ] CoalesceBatchesExec: target_batch_size=8192 metrics=[output_rows: 84599, elapsed_compute: 8230471, ] RepartitionExec: partitioning=Hash([api@0], 32), input_partitions=32 metrics=[fetch_time: 13879606965, repartition_time: 17136033, send_time: 281472401, ] AggregateExec: mode=Partial, gby=[api@0 as api], aggr=[__count_state(tracing_normal.ts)] metrics=[output_rows: 84599, elapsed_compute: 645150449, spill_count: 0, spilled_bytes: 0, spilled_rows: 0, skipped_aggregation_rows: 0, peak_mem_used: 19929440, ] UnorderedScan: region=4569845203048(1064, 104), "partition_count":{"count":74, "mem_ranges":4, "files":27, "file_ranges":70} metrics=[output_rows: 5762804, mem_used: 1427089375, build_parts_cost: 562236751, build_reader_cost: 12128012924, convert_cost: 23713205, elapsed_await: 13187256608, elapsed_poll: 985803521, scan_cost: 13151445299, yield_cost: 681077766, ] *************************** 130. row *************************** stage: NULL node: NULL plan: Total rows: 10 130 rows in set (7.62 sec)