crp-order-qty-opt-service - Details for Query 20

Submitted Time: 2026/02/06 06:54:50
Duration: 1.0 s
Succeeded Jobs: 29 30 31 32 33 34 35 36 37 38

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [labelType="html" label=" AdaptiveSparkPlan "]; subgraph cluster1 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: 6 ms"; 2 [labelType="html" label="HashAggregate time in aggregation build: 6 ms number of output rows: 1"]; } 3 [labelType="html" label="Exchange shuffle records written: 25 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 6 ms (0 ms, 0 ms, 0 ms (stage 60.0: task 516)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 25 local bytes read: 1197.0 B fetch wait time: 0 ms remote bytes read: 675.0 B merged fetch fallback count: 0 local blocks read: 16 remote merged chunks fetched: 0 remote blocks read: 9 data size total (min, med, max (stageId: taskId)) 400.0 B (16.0 B, 16.0 B, 16.0 B (stage 60.0: task 523)) local merged bytes read: 0.0 B number of partitions: 1 remote reqs duration: 4 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 1872.0 B (72.0 B, 75.0 B, 75.0 B (stage 60.0: task 519))"]; subgraph cluster4 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n23 ms (0 ms, 0 ms, 3 ms (stage 60.0: task 519))"; 5 [labelType="html" label="HashAggregate time in aggregation build total (min, med, max (stageId: taskId)) 17 ms (0 ms, 0 ms, 2 ms (stage 60.0: task 519)) number of output rows: 25"]; } 6 [labelType="html" label="InMemoryTableScan number of output rows: 1,196"]; 7 [labelType="html" label=" AdaptiveSparkPlan "]; subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: total (min, med, max (stageId: taskId))\n788 ms (0 ms, 16 ms, 73 ms (stage 57.0: task 497))"; 9 [labelType="html" label=" Project "]; 10 [labelType="html" label="Generate number of output rows: 1,196"]; 11 [labelType="html" label=" Project "]; 12 [labelType="html" label=" Project "]; 13 [labelType="html" label="BroadcastHashJoin number of output rows: 179"]; } 14 [labelType="html" label="Exchange shuffle records written: 179 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 24 ms (0 ms, 1 ms, 1 ms (stage 49.0: task 452)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 179 local bytes read total (min, med, max (stageId: taskId)) 107.8 KiB (993.0 B, 4.9 KiB, 9.6 KiB (stage 57.0: task 511)) fetch wait time total (min, med, max (stageId: taskId)) 6 ms (0 ms, 0 ms, 3 ms (stage 57.0: task 510)) remote bytes read total (min, med, max (stageId: taskId)) 44.5 KiB (494.0 B, 2.2 KiB, 4.5 KiB (stage 57.0: task 506)) merged fetch fallback count: 0 local blocks read: 105 remote merged chunks fetched: 0 remote blocks read: 49 data size total (min, med, max (stageId: taskId)) 304.9 KiB (7.4 KiB, 11.4 KiB, 23.3 KiB (stage 49.0: task 427)) local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration total (min, med, max (stageId: taskId)) 82 ms (3 ms, 4 ms, 7 ms (stage 57.0: task 503)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 152.2 KiB (4.2 KiB, 5.7 KiB, 11.1 KiB (stage 49.0: task 427))"]; 15 [labelType="html" label="Exchange shuffle records written: 179 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 14 ms (1 ms, 2 ms, 3 ms (stage 43.0: task 405)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 179 local bytes read total (min, med, max (stageId: taskId)) 74.1 KiB (1878.0 B, 2.8 KiB, 4.6 KiB (stage 49.0: task 427)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 49.0: task 426)) remote bytes read total (min, med, max (stageId: taskId)) 76.8 KiB (1933.0 B, 2.8 KiB, 5.4 KiB (stage 49.0: task 427)) merged fetch fallback count: 0 local blocks read: 75 remote merged chunks fetched: 0 remote blocks read: 75 data size total (min, med, max (stageId: taskId)) 304.9 KiB (41.7 KiB, 52.0 KiB, 59.3 KiB (stage 43.0: task 405)) local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration total (min, med, max (stageId: taskId)) 90 ms (3 ms, 3 ms, 5 ms (stage 49.0: task 426)) remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 150.9 KiB (21.5 KiB, 25.7 KiB, 28.7 KiB (stage 43.0: task 405))"]; subgraph cluster16 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n595 ms (73 ms, 105 ms, 111 ms (stage 43.0: task 409))"; 17 [labelType="html" label="Filter number of output rows: 179"]; 18 [labelType="html" label="ColumnarToRow number of output rows: 179 number of input batches: 6"]; } 19 [labelType="html" label="Scan parquet number of files read: 6 scan time total (min, med, max (stageId: taskId)) 579 ms (72 ms, 101 ms, 108 ms (stage 43.0: task 410)) metadata time: 0 ms size of files read: 91.0 KiB number of output rows: 179"]; 20 [labelType="html" label="BroadcastExchange time to broadcast: 1 ms time to build: 8 ms time to collect: 63 ms number of output rows: 179 data size: 2.0 MiB"]; 21 [labelType="html" label="AQEShuffleRead number of partitions: 1"]; 22 [labelType="html" label="Exchange shuffle records written: 179 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 30 ms (0 ms, 1 ms, 1 ms (stage 51.0: task 463)) remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 179 local bytes read: 44.4 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 164 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 58.3 KiB (2.3 KiB, 2.3 KiB, 2.6 KiB (stage 51.0: task 469)) local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 44.4 KiB (1536.0 B, 1861.0 B, 2029.0 B (stage 51.0: task 467))"]; subgraph cluster23 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n228 ms (3 ms, 5 ms, 22 ms (stage 51.0: task 464))"; 24 [labelType="html" label=" Project "]; 25 [labelType="html" label="BroadcastHashJoin number of output rows: 179"]; } 26 [labelType="html" label="Exchange shuffle records written: 179 local merged chunks fetched: 0 shuffle write time: 2 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 179 local bytes read total (min, med, max (stageId: taskId)) 15.2 KiB (499.0 B, 621.0 B, 727.0 B (stage 51.0: task 467)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 51.0: task 467)) remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 25 remote merged chunks fetched: 0 remote blocks read: 0 data size: 28.9 KiB local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 15.2 KiB"]; subgraph cluster27 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: 81 ms"; 28 [labelType="html" label="ColumnarToRow number of output rows: 179 number of input batches: 1"]; } 29 [labelType="html" label="Scan parquet number of files read: 1 scan time: 80 ms metadata time: 0 ms size of files read: 3.6 KiB number of output rows: 179"]; 30 [labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 7 ms time to collect: 59 ms number of output rows: 1 data size: 2.0 MiB"]; 31 [labelType="html" label="Exchange shuffle records written: 1 local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1 local bytes read: 155.0 B fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 208.0 B local merged bytes read: 0.0 B number of partitions: 25 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 155.0 B"]; subgraph cluster32 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 88 ms"; 33 [labelType="html" label="Filter number of output rows: 1"]; 34 [labelType="html" label="ColumnarToRow number of output rows: 1 number of input batches: 1"]; } 35 [labelType="html" label="Scan parquet number of files read: 1 scan time: 88 ms metadata time: 0 ms size of files read: 7.0 KiB number of output rows: 1"]; 2->0; 3->2; 5->3; 6->5; 7->6; 9->7; 10->9; 11->10; 12->11; 13->12; 14->13; 15->14; 17->15; 18->17; 19->18; 20->13; 21->20; 22->21; 24->22; 25->24; 26->25; 28->26; 29->28; 30->25; 31->30; 33->31; 34->33; 35->34; }

AdaptiveSparkPlan isFinalPlan=true

HashAggregate(keys=[], functions=[count(1)])

WholeStageCodegen (2)

Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=2074]

HashAggregate(keys=[], functions=[partial_count(1)])

WholeStageCodegen (1)

InMemoryTableScan

AdaptiveSparkPlan isFinalPlan=true

Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderScheduleExploded#3301.product AS product#3315, productOrderScheduleExploded#3301.orderDateTime AS orderDateTime#3316, productOrderScheduleExploded#3301.availabilityDateTime AS availabilityDateTime#3317, productOrderScheduleExploded#3301.nextAvailabilityDateTime AS nextAvailabilityDateTime#3318, productOrderScheduleExploded#3301.mrpController AS mrpController#3319, productOrderScheduleExploded#3301.sourceOfSupplyUuid AS sourceOfSupplyUuid#3320, productOrderScheduleExploded#3301.purchasingOrg AS purchasingOrg#3321, productOrderScheduleExploded#3301.purchasingGroup AS purchasingGroup#3322, xxhash64(CASE WHEN (_extract_supplier#4175 <=> true) THEN supplierOrGroup#3208 END, CASE WHEN (_extract_deliveryDate#4176 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_orderDate#4177 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_supplierSubrange#4178 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_purchasingOrg#4179 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_mrpController#4180 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4181 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, locationOrGroup#3220, ((((((((CASE WHEN (isnull(supplierOrGroup#3208) AND (_extract_supplier#4175 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4176 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4177 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4178 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4179 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4180 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4181 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#3220) THEN 256 ELSE 0 END), 10000000095, 42) AS orderProposalId#3715L, 0 AS orderProposalHorizonGroupingId#3736L, xxhash64(CASE WHEN (_extract_purchasingOrg#4182 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_deliveryDate#4183 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_supplier#4184 <=> true) THEN supplier#3000 END, CASE WHEN (_extract_supplierSubrange#4185 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_orderDate#4186 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_mrpController#4187 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4188 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, plant#3001, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4182 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4183 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#3000) AND (_extract_supplier#4184 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4185 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4186 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4187 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4188 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#3001) THEN 256 ELSE 0 END), 10000000095, 42) AS splitIndicator#4136L]

Generate explode(productOrderSchedule#3004), [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220], false, [productOrderScheduleExploded#3301]

Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, orderGroupCriteria#3265.supplier AS _extract_supplier#4175, orderGroupCriteria#3265.deliveryDate AS _extract_deliveryDate#4176, orderGroupCriteria#3265.orderDate AS _extract_orderDate#4177, orderGroupCriteria#3265.supplierSubrange AS _extract_supplierSubrange#4178, orderGroupCriteria#3265.purchasingOrg AS _extract_purchasingOrg#4179, orderGroupCriteria#3265.mrpController AS _extract_mrpController#4180, orderGroupCriteria#3265.purchasingGroup AS _extract_purchasingGroup#4181, orderSplitCriteria#3287.purchasingOrg AS _extract_purchasingOrg#4182, orderSplitCriteria#3287.deliveryDate AS _extract_deliveryDate#4183, orderSplitCriteria#3287.supplier AS _extract_supplier#4184, orderSplitCriteria#3287.supplierSubrange AS _extract_supplierSubrange#4185, orderSplitCriteria#3287.orderDate AS _extract_orderDate#4186, orderSplitCriteria#3287.mrpController AS _extract_mrpController#4187, orderSplitCriteria#3287.purchasingGroup AS _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]

Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, CASE WHEN isnull(orderGroupCriteria#3111) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#3111 END AS orderGroupCriteria#3265, CASE WHEN isnull(orderSplitCriteria#3112) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#3112 END AS orderSplitCriteria#3287, orderGroupingProfile#3015, coalesce(supplierGroup#2999, supplier#3000) AS supplierOrGroup#3208, coalesce(locationGroup#3017, plant#3001) AS locationOrGroup#3220]

BroadcastHashJoin [coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002)], [coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014)], LeftOuter, BuildRight, false

WholeStageCodegen (5)

Exchange hashpartitioning(coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002), 25), ENSURE_REQUIREMENTS, [plan_id=1716]

Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1708]

Filter ((size(productOrderSchedule#3004, true) > 0) AND isnotnull(productOrderSchedule#3004))

ColumnarToRow

WholeStageCodegen (1)

FileScan parquet [supplierGroup#2999,supplier#3000,plant#3001,deliveryDateTime#3002,subrange#3003,productOrderSchedule#3004] Batched: true, DataFilters: [(size(productOrderSchedule#3004, true) > 0), isnotnull(productOrderSchedule#3004)], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [IsNotNull(productOrderSchedule)], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...

BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[5, string, true], ), isnull(input[5, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=2025]

AQEShuffleRead local

Exchange hashpartitioning(coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014), 25), ENSURE_REQUIREMENTS, [plan_id=1955]

Project [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]

BroadcastHashJoin [orderGroupingProfile#3015], [orderGroupingProfile#3109], LeftOuter, BuildRight, false

WholeStageCodegen (4)

Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1736]

ColumnarToRow

WholeStageCodegen (2)

FileScan parquet [supplier#3011,subrange#3012,plant#3013,deliverydatetime#3014,ordergroupingprofile#3015,supplierGroup#3016,locationGroup#3017] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,ordergroupingprofi...

BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=1757]

Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1749]

Filter isnotnull(orderGroupingProfile#3109)

ColumnarToRow

WholeStageCodegen (3)

FileScan parquet [orderGroupingProfile#3109,orderGroupCriteria#3111,orderSplitCriteria#3112] Batched: true, DataFilters: [isnotnull(orderGroupingProfile#3109)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(orderGroupingProfile)], ReadSchema: struct<orderGroupingProfile:string,orderGroupCriteria:struct<supplier:boolean,supplierSubrange:bo...

Details

== Physical Plan ==
AdaptiveSparkPlan (59)
+- == Final Plan ==
   * HashAggregate (55)
   +- ShuffleQueryStage (54), Statistics(sizeInBytes=400.0 B, rowCount=25)
      +- Exchange (53)
         +- * HashAggregate (52)
            +- TableCacheQueryStage (51), Statistics(sizeInBytes=379.1 KiB, rowCount=1.20E+3)
               +- InMemoryTableScan (1)
                     +- InMemoryRelation (2)
                           +- AdaptiveSparkPlan (50)
                           +- == Final Plan ==
                              * Project (32)
                              +- * Generate (31)
                                 +- * Project (30)
                                    +- * Project (29)
                                       +- * BroadcastHashJoin LeftOuter BuildRight (28)
                                          :- ShuffleQueryStage (9), Statistics(sizeInBytes=304.9 KiB, rowCount=179)
                                          :  +- Exchange (8)
                                          :     +- ShuffleQueryStage (7), Statistics(sizeInBytes=304.9 KiB, rowCount=179)
                                          :        +- Exchange (6)
                                          :           +- * Filter (5)
                                          :              +- * ColumnarToRow (4)
                                          :                 +- Scan parquet  (3)
                                          +- BroadcastQueryStage (27), Statistics(sizeInBytes=2.0 MiB, rowCount=179)
                                             +- BroadcastExchange (26)
                                                +- AQEShuffleRead (25)
                                                   +- ShuffleQueryStage (24), Statistics(sizeInBytes=58.3 KiB, rowCount=179)
                                                      +- Exchange (23)
                                                         +- * Project (22)
                                                            +- * BroadcastHashJoin LeftOuter BuildRight (21)
                                                               :- ShuffleQueryStage (13), Statistics(sizeInBytes=28.9 KiB, rowCount=179)
                                                               :  +- Exchange (12)
                                                               :     +- * ColumnarToRow (11)
                                                               :        +- Scan parquet  (10)
                                                               +- BroadcastQueryStage (20), Statistics(sizeInBytes=2.0 MiB, rowCount=1)
                                                                  +- BroadcastExchange (19)
                                                                     +- ShuffleQueryStage (18), Statistics(sizeInBytes=208.0 B, rowCount=1)
                                                                        +- Exchange (17)
                                                                           +- * Filter (16)
                                                                              +- * ColumnarToRow (15)
                                                                                 +- Scan parquet  (14)
                           +- == Initial Plan ==
                              Project (49)
                              +- Generate (48)
                                 +- Project (47)
                                    +- Project (46)
                                       +- SortMergeJoin LeftOuter (45)
                                          :- Sort (36)
                                          :  +- Exchange (35)
                                          :     +- Exchange (34)
                                          :        +- Filter (33)
                                          :           +- Scan parquet  (3)
                                          +- Sort (44)
                                             +- Exchange (43)
                                                +- Project (42)
                                                   +- BroadcastHashJoin LeftOuter BuildRight (41)
                                                      :- Exchange (37)
                                                      :  +- Scan parquet  (10)
                                                      +- BroadcastExchange (40)
                                                         +- Exchange (39)
                                                            +- Filter (38)
                                                               +- Scan parquet  (14)
+- == Initial Plan ==
   HashAggregate (58)
   +- Exchange (57)
      +- HashAggregate (56)
         +- InMemoryTableScan (1)
               +- InMemoryRelation (2)
                     +- AdaptiveSparkPlan (50)
                     +- == Final Plan ==
                        * Project (32)
                        +- * Generate (31)
                           +- * Project (30)
                              +- * Project (29)
                                 +- * BroadcastHashJoin LeftOuter BuildRight (28)
                                    :- ShuffleQueryStage (9), Statistics(sizeInBytes=304.9 KiB, rowCount=179)
                                    :  +- Exchange (8)
                                    :     +- ShuffleQueryStage (7), Statistics(sizeInBytes=304.9 KiB, rowCount=179)
                                    :        +- Exchange (6)
                                    :           +- * Filter (5)
                                    :              +- * ColumnarToRow (4)
                                    :                 +- Scan parquet  (3)
                                    +- BroadcastQueryStage (27), Statistics(sizeInBytes=2.0 MiB, rowCount=179)
                                       +- BroadcastExchange (26)
                                          +- AQEShuffleRead (25)
                                             +- ShuffleQueryStage (24), Statistics(sizeInBytes=58.3 KiB, rowCount=179)
                                                +- Exchange (23)
                                                   +- * Project (22)
                                                      +- * BroadcastHashJoin LeftOuter BuildRight (21)
                                                         :- ShuffleQueryStage (13), Statistics(sizeInBytes=28.9 KiB, rowCount=179)
                                                         :  +- Exchange (12)
                                                         :     +- * ColumnarToRow (11)
                                                         :        +- Scan parquet  (10)
                                                         +- BroadcastQueryStage (20), Statistics(sizeInBytes=2.0 MiB, rowCount=1)
                                                            +- BroadcastExchange (19)
                                                               +- ShuffleQueryStage (18), Statistics(sizeInBytes=208.0 B, rowCount=1)
                                                                  +- Exchange (17)
                                                                     +- * Filter (16)
                                                                        +- * ColumnarToRow (15)
                                                                           +- Scan parquet  (14)
                     +- == Initial Plan ==
                        Project (49)
                        +- Generate (48)
                           +- Project (47)
                              +- Project (46)
                                 +- SortMergeJoin LeftOuter (45)
                                    :- Sort (36)
                                    :  +- Exchange (35)
                                    :     +- Exchange (34)
                                    :        +- Filter (33)
                                    :           +- Scan parquet  (3)
                                    +- Sort (44)
                                       +- Exchange (43)
                                          +- Project (42)
                                             +- BroadcastHashJoin LeftOuter BuildRight (41)
                                                :- Exchange (37)
                                                :  +- Scan parquet  (10)
                                                +- BroadcastExchange (40)
                                                   +- Exchange (39)
                                                      +- Filter (38)
                                                         +- Scan parquet  (14)


(1) InMemoryTableScan
Output: []

(2) InMemoryRelation
Arguments: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, product#3315, orderDateTime#3316, availabilityDateTime#3317, nextAvailabilityDateTime#3318, mrpController#3319, sourceOfSupplyUuid#3320, purchasingOrg#3321, purchasingGroup#3322, orderProposalId#3715L, orderProposalHorizonGroupingId#3736L, splitIndicator#4136L], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@763c116,StorageLevel(disk, memory, 2 replicas),AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
   *(5) Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderScheduleExploded#3301.product AS product#3315, productOrderScheduleExploded#3301.orderDateTime AS orderDateTime#3316, productOrderScheduleExploded#3301.availabilityDateTime AS availabilityDateTime#3317, productOrderScheduleExploded#3301.nextAvailabilityDateTime AS nextAvailabilityDateTime#3318, productOrderScheduleExploded#3301.mrpController AS mrpController#3319, productOrderScheduleExploded#3301.sourceOfSupplyUuid AS sourceOfSupplyUuid#3320, productOrderScheduleExploded#3301.purchasingOrg AS purchasingOrg#3321, productOrderScheduleExploded#3301.purchasingGroup AS purchasingGroup#3322, xxhash64(CASE WHEN (_extract_supplier#4175 <=> true) THEN supplierOrGroup#3208 END, CASE WHEN (_extract_deliveryDate#4176 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_orderDate#4177 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_supplierSubrange#4178 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_purchasingOrg#4179 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_mrpController#4180 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4181 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, locationOrGroup#3220, ((((((((CASE WHEN (isnull(supplierOrGroup#3208) AND (_extract_supplier#4175 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4176 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4177 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4178 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4179 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4180 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4181 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#3220) THEN 256 ELSE 0 END), 10000000095, 42) AS orderProposalId#3715L, 0 AS orderProposalHorizonGroupingId#3736L, xxhash64(CASE WHEN (_extract_purchasingOrg#4182 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_deliveryDate#4183 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_supplier#4184 <=> true) THEN supplier#3000 END, CASE WHEN (_extract_supplierSubrange#4185 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_orderDate#4186 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_mrpController#4187 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4188 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, plant#3001, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4182 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4183 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#3000) AND (_extract_supplier#4184 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4185 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4186 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4187 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4188 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#3001) THEN 256 ELSE 0 END), 10000000095, 42) AS splitIndicator#4136L]
   +- *(5) Generate explode(productOrderSchedule#3004), [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220], false, [productOrderScheduleExploded#3301]
      +- *(5) Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, orderGroupCriteria#3265.supplier AS _extract_supplier#4175, orderGroupCriteria#3265.deliveryDate AS _extract_deliveryDate#4176, orderGroupCriteria#3265.orderDate AS _extract_orderDate#4177, orderGroupCriteria#3265.supplierSubrange AS _extract_supplierSubrange#4178, orderGroupCriteria#3265.purchasingOrg AS _extract_purchasingOrg#4179, orderGroupCriteria#3265.mrpController AS _extract_mrpController#4180, orderGroupCriteria#3265.purchasingGroup AS _extract_purchasingGroup#4181, orderSplitCriteria#3287.purchasingOrg AS _extract_purchasingOrg#4182, orderSplitCriteria#3287.deliveryDate AS _extract_deliveryDate#4183, orderSplitCriteria#3287.supplier AS _extract_supplier#4184, orderSplitCriteria#3287.supplierSubrange AS _extract_supplierSubrange#4185, orderSplitCriteria#3287.orderDate AS _extract_orderDate#4186, orderSplitCriteria#3287.mrpController AS _extract_mrpController#4187, orderSplitCriteria#3287.purchasingGroup AS _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]
         +- *(5) Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, CASE WHEN isnull(orderGroupCriteria#3111) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#3111 END AS orderGroupCriteria#3265, CASE WHEN isnull(orderSplitCriteria#3112) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#3112 END AS orderSplitCriteria#3287, orderGroupingProfile#3015, coalesce(supplierGroup#2999, supplier#3000) AS supplierOrGroup#3208, coalesce(locationGroup#3017, plant#3001) AS locationOrGroup#3220]
            +- *(5) BroadcastHashJoin [coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002)], [coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014)], LeftOuter, BuildRight, false
               :- ShuffleQueryStage 4
               :  +- Exchange hashpartitioning(coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002), 25), ENSURE_REQUIREMENTS, [plan_id=1716]
               :     +- ShuffleQueryStage 0
               :        +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1708]
               :           +- *(1) Filter ((size(productOrderSchedule#3004, true) > 0) AND isnotnull(productOrderSchedule#3004))
               :              +- *(1) ColumnarToRow
               :                 +- FileScan parquet [supplierGroup#2999,supplier#3000,plant#3001,deliveryDateTime#3002,subrange#3003,productOrderSchedule#3004] Batched: true, DataFilters: [(size(productOrderSchedule#3004, true) > 0), isnotnull(productOrderSchedule#3004)], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [IsNotNull(productOrderSchedule)], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...
               +- BroadcastQueryStage 6
                  +- BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[5, string, true], ), isnull(input[5, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=2025]
                     +- AQEShuffleRead local
                        +- ShuffleQueryStage 5
                           +- Exchange hashpartitioning(coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014), 25), ENSURE_REQUIREMENTS, [plan_id=1955]
                              +- *(4) Project [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
                                 +- *(4) BroadcastHashJoin [orderGroupingProfile#3015], [orderGroupingProfile#3109], LeftOuter, BuildRight, false
                                    :- ShuffleQueryStage 1
                                    :  +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1736]
                                    :     +- *(2) ColumnarToRow
                                    :        +- FileScan parquet [supplier#3011,subrange#3012,plant#3013,deliverydatetime#3014,ordergroupingprofile#3015,supplierGroup#3016,locationGroup#3017] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,ordergroupingprofi...
                                    +- BroadcastQueryStage 3
                                       +- BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=1757]
                                          +- ShuffleQueryStage 2
                                             +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1749]
                                                +- *(3) Filter isnotnull(orderGroupingProfile#3109)
                                                   +- *(3) ColumnarToRow
                                                      +- FileScan parquet [orderGroupingProfile#3109,orderGroupCriteria#3111,orderSplitCriteria#3112] Batched: true, DataFilters: [isnotnull(orderGroupingProfile#3109)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(orderGroupingProfile)], ReadSchema: struct<orderGroupingProfile:string,orderGroupCriteria:struct<supplier:boolean,supplierSubrange:bo...
+- == Initial Plan ==
   Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderScheduleExploded#3301.product AS product#3315, productOrderScheduleExploded#3301.orderDateTime AS orderDateTime#3316, productOrderScheduleExploded#3301.availabilityDateTime AS availabilityDateTime#3317, productOrderScheduleExploded#3301.nextAvailabilityDateTime AS nextAvailabilityDateTime#3318, productOrderScheduleExploded#3301.mrpController AS mrpController#3319, productOrderScheduleExploded#3301.sourceOfSupplyUuid AS sourceOfSupplyUuid#3320, productOrderScheduleExploded#3301.purchasingOrg AS purchasingOrg#3321, productOrderScheduleExploded#3301.purchasingGroup AS purchasingGroup#3322, xxhash64(CASE WHEN (_extract_supplier#4175 <=> true) THEN supplierOrGroup#3208 END, CASE WHEN (_extract_deliveryDate#4176 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_orderDate#4177 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_supplierSubrange#4178 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_purchasingOrg#4179 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_mrpController#4180 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4181 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, locationOrGroup#3220, ((((((((CASE WHEN (isnull(supplierOrGroup#3208) AND (_extract_supplier#4175 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4176 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4177 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4178 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4179 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4180 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4181 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#3220) THEN 256 ELSE 0 END), 10000000095, 42) AS orderProposalId#3715L, 0 AS orderProposalHorizonGroupingId#3736L, xxhash64(CASE WHEN (_extract_purchasingOrg#4182 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_deliveryDate#4183 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_supplier#4184 <=> true) THEN supplier#3000 END, CASE WHEN (_extract_supplierSubrange#4185 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_orderDate#4186 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_mrpController#4187 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4188 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, plant#3001, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4182 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4183 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#3000) AND (_extract_supplier#4184 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4185 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4186 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4187 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4188 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#3001) THEN 256 ELSE 0 END), 10000000095, 42) AS splitIndicator#4136L]
   +- Generate explode(productOrderSchedule#3004), [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220], false, [productOrderScheduleExploded#3301]
      +- Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, orderGroupCriteria#3265.supplier AS _extract_supplier#4175, orderGroupCriteria#3265.deliveryDate AS _extract_deliveryDate#4176, orderGroupCriteria#3265.orderDate AS _extract_orderDate#4177, orderGroupCriteria#3265.supplierSubrange AS _extract_supplierSubrange#4178, orderGroupCriteria#3265.purchasingOrg AS _extract_purchasingOrg#4179, orderGroupCriteria#3265.mrpController AS _extract_mrpController#4180, orderGroupCriteria#3265.purchasingGroup AS _extract_purchasingGroup#4181, orderSplitCriteria#3287.purchasingOrg AS _extract_purchasingOrg#4182, orderSplitCriteria#3287.deliveryDate AS _extract_deliveryDate#4183, orderSplitCriteria#3287.supplier AS _extract_supplier#4184, orderSplitCriteria#3287.supplierSubrange AS _extract_supplierSubrange#4185, orderSplitCriteria#3287.orderDate AS _extract_orderDate#4186, orderSplitCriteria#3287.mrpController AS _extract_mrpController#4187, orderSplitCriteria#3287.purchasingGroup AS _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]
         +- Project [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, CASE WHEN isnull(orderGroupCriteria#3111) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#3111 END AS orderGroupCriteria#3265, CASE WHEN isnull(orderSplitCriteria#3112) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#3112 END AS orderSplitCriteria#3287, orderGroupingProfile#3015, coalesce(supplierGroup#2999, supplier#3000) AS supplierOrGroup#3208, coalesce(locationGroup#3017, plant#3001) AS locationOrGroup#3220]
            +- SortMergeJoin [coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002)], [coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014)], LeftOuter
               :- Sort [coalesce(supplierGroup#2999, ) ASC NULLS FIRST, isnull(supplierGroup#2999) ASC NULLS FIRST, coalesce(supplier#3000, ) ASC NULLS FIRST, isnull(supplier#3000) ASC NULLS FIRST, coalesce(subrange#3003, ) ASC NULLS FIRST, isnull(subrange#3003) ASC NULLS FIRST, coalesce(plant#3001, ) ASC NULLS FIRST, isnull(plant#3001) ASC NULLS FIRST, coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00) ASC NULLS FIRST, isnull(deliveryDateTime#3002) ASC NULLS FIRST], false, 0
               :  +- Exchange hashpartitioning(coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002), 25), ENSURE_REQUIREMENTS, [plan_id=1665]
               :     +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1651]
               :        +- Filter ((size(productOrderSchedule#3004, true) > 0) AND isnotnull(productOrderSchedule#3004))
               :           +- FileScan parquet [supplierGroup#2999,supplier#3000,plant#3001,deliveryDateTime#3002,subrange#3003,productOrderSchedule#3004] Batched: true, DataFilters: [(size(productOrderSchedule#3004, true) > 0), isnotnull(productOrderSchedule#3004)], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [IsNotNull(productOrderSchedule)], ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:stri...
               +- Sort [coalesce(supplierGroup#3016, ) ASC NULLS FIRST, isnull(supplierGroup#3016) ASC NULLS FIRST, coalesce(supplier#3011, ) ASC NULLS FIRST, isnull(supplier#3011) ASC NULLS FIRST, coalesce(subrange#3012, ) ASC NULLS FIRST, isnull(subrange#3012) ASC NULLS FIRST, coalesce(plant#3013, ) ASC NULLS FIRST, isnull(plant#3013) ASC NULLS FIRST, coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00) ASC NULLS FIRST, isnull(deliveryDateTime#3014) ASC NULLS FIRST], false, 0
                  +- Exchange hashpartitioning(coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014), 25), ENSURE_REQUIREMENTS, [plan_id=1666]
                     +- Project [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
                        +- BroadcastHashJoin [orderGroupingProfile#3015], [orderGroupingProfile#3109], LeftOuter, BuildRight, false
                           :- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1638]
                           :  +- FileScan parquet [supplier#3011,subrange#3012,plant#3013,deliverydatetime#3014,ordergroupingprofile#3015,supplierGroup#3016,locationGroup#3017] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,ordergroupingprofi...
                           +- BroadcastExchange HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=1660]
                              +- Exchange RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1652]
                                 +- Filter isnotnull(orderGroupingProfile#3109)
                                    +- FileScan parquet [orderGroupingProfile#3109,orderGroupCriteria#3111,orderSplitCriteria#3112] Batched: true, DataFilters: [isnotnull(orderGroupingProfile#3109)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(orderGroupingProfile)], ReadSchema: struct<orderGroupingProfile:string,orderGroupCriteria:struct<supplier:boolean,supplierSubrange:bo...
,None)

(3) Scan parquet 
Output [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/grouping-worklist/10000000095]
PushedFilters: [IsNotNull(productOrderSchedule)]
ReadSchema: struct<supplierGroup:string,supplier:string,plant:string,deliveryDateTime:timestamp,subrange:string,productOrderSchedule:array<struct<product:string,orderDateTime:timestamp,availabilityDateTime:timestamp,nextAvailabilityDateTime:timestamp,mrpController:string,sourceOfSupplyUuid:string,purchasingOrg:string,purchasingGroup:string>>>

(4) ColumnarToRow [codegen id : 1]
Input [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]

(5) Filter [codegen id : 1]
Input [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Condition : ((size(productOrderSchedule#3004, true) > 0) AND isnotnull(productOrderSchedule#3004))

(6) Exchange
Input [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1708]

(7) ShuffleQueryStage
Output [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Arguments: 0

(8) Exchange
Input [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Arguments: hashpartitioning(coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002), 25), ENSURE_REQUIREMENTS, [plan_id=1716]

(9) ShuffleQueryStage
Output [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Arguments: 4

(10) Scan parquet 
Output [7]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000000095]
ReadSchema: struct<supplier:string,subrange:string,plant:string,deliverydatetime:timestamp,ordergroupingprofile:string,supplierGroup:string,locationGroup:string>

(11) ColumnarToRow [codegen id : 2]
Input [7]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017]

(12) Exchange
Input [7]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1736]

(13) ShuffleQueryStage
Output [7]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017]
Arguments: 1

(14) Scan parquet 
Output [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/order-grouping-profile]
PushedFilters: [IsNotNull(orderGroupingProfile)]
ReadSchema: struct<orderGroupingProfile:string,orderGroupCriteria:struct<supplier:boolean,supplierSubrange:boolean,receivingLocation:boolean,deliveryDate:boolean,orderDate:boolean,purchasingOrg:boolean,purchasingGroup:boolean,mrpController:boolean>,orderSplitCriteria:struct<supplier:boolean,supplierSubrange:boolean,receivingLocation:boolean,deliveryDate:boolean,multiplesOrderQuantity:boolean,orderDate:boolean,purchasingOrg:boolean,purchasingGroup:boolean,mrpController:boolean>>

(15) ColumnarToRow [codegen id : 3]
Input [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]

(16) Filter [codegen id : 3]
Input [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Condition : isnotnull(orderGroupingProfile#3109)

(17) Exchange
Input [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1749]

(18) ShuffleQueryStage
Output [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: 2

(19) BroadcastExchange
Input [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=1757]

(20) BroadcastQueryStage
Output [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: 3

(21) BroadcastHashJoin [codegen id : 4]
Left keys [1]: [orderGroupingProfile#3015]
Right keys [1]: [orderGroupingProfile#3109]
Join type: LeftOuter
Join condition: None

(22) Project [codegen id : 4]
Output [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Input [10]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]

(23) Exchange
Input [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: hashpartitioning(coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014), 25), ENSURE_REQUIREMENTS, [plan_id=1955]

(24) ShuffleQueryStage
Output [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: 5

(25) AQEShuffleRead
Input [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: local

(26) BroadcastExchange
Input [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[5, string, true], ), isnull(input[5, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true]), coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[2, string, true], ), isnull(input[2, string, true]), coalesce(input[3, timestamp, true], 1970-01-01 00:00:00), isnull(input[3, timestamp, true])),false), [plan_id=2025]

(27) BroadcastQueryStage
Output [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: 6

(28) BroadcastHashJoin [codegen id : 5]
Left keys [10]: [coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002)]
Right keys [10]: [coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014)]
Join type: LeftOuter
Join condition: None

(29) Project [codegen id : 5]
Output [11]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, CASE WHEN isnull(orderGroupCriteria#3111) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#3111 END AS orderGroupCriteria#3265, CASE WHEN isnull(orderSplitCriteria#3112) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#3112 END AS orderSplitCriteria#3287, orderGroupingProfile#3015, coalesce(supplierGroup#2999, supplier#3000) AS supplierOrGroup#3208, coalesce(locationGroup#3017, plant#3001) AS locationOrGroup#3220]
Input [15]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]

(30) Project [codegen id : 5]
Output [23]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, orderGroupCriteria#3265.supplier AS _extract_supplier#4175, orderGroupCriteria#3265.deliveryDate AS _extract_deliveryDate#4176, orderGroupCriteria#3265.orderDate AS _extract_orderDate#4177, orderGroupCriteria#3265.supplierSubrange AS _extract_supplierSubrange#4178, orderGroupCriteria#3265.purchasingOrg AS _extract_purchasingOrg#4179, orderGroupCriteria#3265.mrpController AS _extract_mrpController#4180, orderGroupCriteria#3265.purchasingGroup AS _extract_purchasingGroup#4181, orderSplitCriteria#3287.purchasingOrg AS _extract_purchasingOrg#4182, orderSplitCriteria#3287.deliveryDate AS _extract_deliveryDate#4183, orderSplitCriteria#3287.supplier AS _extract_supplier#4184, orderSplitCriteria#3287.supplierSubrange AS _extract_supplierSubrange#4185, orderSplitCriteria#3287.orderDate AS _extract_orderDate#4186, orderSplitCriteria#3287.mrpController AS _extract_mrpController#4187, orderSplitCriteria#3287.purchasingGroup AS _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]
Input [11]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, orderGroupCriteria#3265, orderSplitCriteria#3287, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]

(31) Generate [codegen id : 5]
Input [23]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]
Arguments: explode(productOrderSchedule#3004), [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220], false, [productOrderScheduleExploded#3301]

(32) Project [codegen id : 5]
Output [16]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderScheduleExploded#3301.product AS product#3315, productOrderScheduleExploded#3301.orderDateTime AS orderDateTime#3316, productOrderScheduleExploded#3301.availabilityDateTime AS availabilityDateTime#3317, productOrderScheduleExploded#3301.nextAvailabilityDateTime AS nextAvailabilityDateTime#3318, productOrderScheduleExploded#3301.mrpController AS mrpController#3319, productOrderScheduleExploded#3301.sourceOfSupplyUuid AS sourceOfSupplyUuid#3320, productOrderScheduleExploded#3301.purchasingOrg AS purchasingOrg#3321, productOrderScheduleExploded#3301.purchasingGroup AS purchasingGroup#3322, xxhash64(CASE WHEN (_extract_supplier#4175 <=> true) THEN supplierOrGroup#3208 END, CASE WHEN (_extract_deliveryDate#4176 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_orderDate#4177 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_supplierSubrange#4178 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_purchasingOrg#4179 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_mrpController#4180 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4181 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, locationOrGroup#3220, ((((((((CASE WHEN (isnull(supplierOrGroup#3208) AND (_extract_supplier#4175 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4176 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4177 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4178 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4179 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4180 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4181 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#3220) THEN 256 ELSE 0 END), 10000000095, 42) AS orderProposalId#3715L, 0 AS orderProposalHorizonGroupingId#3736L, xxhash64(CASE WHEN (_extract_purchasingOrg#4182 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_deliveryDate#4183 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_supplier#4184 <=> true) THEN supplier#3000 END, CASE WHEN (_extract_supplierSubrange#4185 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_orderDate#4186 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_mrpController#4187 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4188 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, plant#3001, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4182 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4183 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#3000) AND (_extract_supplier#4184 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4185 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4186 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4187 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4188 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#3001) THEN 256 ELSE 0 END), 10000000095, 42) AS splitIndicator#4136L]
Input [23]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220, productOrderScheduleExploded#3301]

(33) Filter
Input [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Condition : ((size(productOrderSchedule#3004, true) > 0) AND isnotnull(productOrderSchedule#3004))

(34) Exchange
Input [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1651]

(35) Exchange
Input [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Arguments: hashpartitioning(coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002), 25), ENSURE_REQUIREMENTS, [plan_id=1665]

(36) Sort
Input [6]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004]
Arguments: [coalesce(supplierGroup#2999, ) ASC NULLS FIRST, isnull(supplierGroup#2999) ASC NULLS FIRST, coalesce(supplier#3000, ) ASC NULLS FIRST, isnull(supplier#3000) ASC NULLS FIRST, coalesce(subrange#3003, ) ASC NULLS FIRST, isnull(subrange#3003) ASC NULLS FIRST, coalesce(plant#3001, ) ASC NULLS FIRST, isnull(plant#3001) ASC NULLS FIRST, coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00) ASC NULLS FIRST, isnull(deliveryDateTime#3002) ASC NULLS FIRST], false, 0

(37) Exchange
Input [7]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1638]

(38) Filter
Input [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Condition : isnotnull(orderGroupingProfile#3109)

(39) Exchange
Input [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: RoundRobinPartitioning(25), REPARTITION_BY_NUM, [plan_id=1652]

(40) BroadcastExchange
Input [3]: [orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=1660]

(41) BroadcastHashJoin
Left keys [1]: [orderGroupingProfile#3015]
Right keys [1]: [orderGroupingProfile#3109]
Join type: LeftOuter
Join condition: None

(42) Project
Output [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Input [10]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupingProfile#3109, orderGroupCriteria#3111, orderSplitCriteria#3112]

(43) Exchange
Input [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: hashpartitioning(coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014), 25), ENSURE_REQUIREMENTS, [plan_id=1666]

(44) Sort
Input [9]: [supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]
Arguments: [coalesce(supplierGroup#3016, ) ASC NULLS FIRST, isnull(supplierGroup#3016) ASC NULLS FIRST, coalesce(supplier#3011, ) ASC NULLS FIRST, isnull(supplier#3011) ASC NULLS FIRST, coalesce(subrange#3012, ) ASC NULLS FIRST, isnull(subrange#3012) ASC NULLS FIRST, coalesce(plant#3013, ) ASC NULLS FIRST, isnull(plant#3013) ASC NULLS FIRST, coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00) ASC NULLS FIRST, isnull(deliveryDateTime#3014) ASC NULLS FIRST], false, 0

(45) SortMergeJoin
Left keys [10]: [coalesce(supplierGroup#2999, ), isnull(supplierGroup#2999), coalesce(supplier#3000, ), isnull(supplier#3000), coalesce(subrange#3003, ), isnull(subrange#3003), coalesce(plant#3001, ), isnull(plant#3001), coalesce(deliveryDateTime#3002, 1970-01-01 00:00:00), isnull(deliveryDateTime#3002)]
Right keys [10]: [coalesce(supplierGroup#3016, ), isnull(supplierGroup#3016), coalesce(supplier#3011, ), isnull(supplier#3011), coalesce(subrange#3012, ), isnull(subrange#3012), coalesce(plant#3013, ), isnull(plant#3013), coalesce(deliveryDateTime#3014, 1970-01-01 00:00:00), isnull(deliveryDateTime#3014)]
Join type: LeftOuter
Join condition: None

(46) Project
Output [11]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, CASE WHEN isnull(orderGroupCriteria#3111) THEN [true,false,false,false,true,false,false,false] ELSE orderGroupCriteria#3111 END AS orderGroupCriteria#3265, CASE WHEN isnull(orderSplitCriteria#3112) THEN [true,false,false,false,false,true,false,false,false] ELSE orderSplitCriteria#3112 END AS orderSplitCriteria#3287, orderGroupingProfile#3015, coalesce(supplierGroup#2999, supplier#3000) AS supplierOrGroup#3208, coalesce(locationGroup#3017, plant#3001) AS locationOrGroup#3220]
Input [15]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, supplier#3011, subrange#3012, plant#3013, deliverydatetime#3014, ordergroupingprofile#3015, supplierGroup#3016, locationGroup#3017, orderGroupCriteria#3111, orderSplitCriteria#3112]

(47) Project
Output [23]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, orderGroupCriteria#3265.supplier AS _extract_supplier#4175, orderGroupCriteria#3265.deliveryDate AS _extract_deliveryDate#4176, orderGroupCriteria#3265.orderDate AS _extract_orderDate#4177, orderGroupCriteria#3265.supplierSubrange AS _extract_supplierSubrange#4178, orderGroupCriteria#3265.purchasingOrg AS _extract_purchasingOrg#4179, orderGroupCriteria#3265.mrpController AS _extract_mrpController#4180, orderGroupCriteria#3265.purchasingGroup AS _extract_purchasingGroup#4181, orderSplitCriteria#3287.purchasingOrg AS _extract_purchasingOrg#4182, orderSplitCriteria#3287.deliveryDate AS _extract_deliveryDate#4183, orderSplitCriteria#3287.supplier AS _extract_supplier#4184, orderSplitCriteria#3287.supplierSubrange AS _extract_supplierSubrange#4185, orderSplitCriteria#3287.orderDate AS _extract_orderDate#4186, orderSplitCriteria#3287.mrpController AS _extract_mrpController#4187, orderSplitCriteria#3287.purchasingGroup AS _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]
Input [11]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, orderGroupCriteria#3265, orderSplitCriteria#3287, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]

(48) Generate
Input [23]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderSchedule#3004, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220]
Arguments: explode(productOrderSchedule#3004), [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220], false, [productOrderScheduleExploded#3301]

(49) Project
Output [16]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, productOrderScheduleExploded#3301.product AS product#3315, productOrderScheduleExploded#3301.orderDateTime AS orderDateTime#3316, productOrderScheduleExploded#3301.availabilityDateTime AS availabilityDateTime#3317, productOrderScheduleExploded#3301.nextAvailabilityDateTime AS nextAvailabilityDateTime#3318, productOrderScheduleExploded#3301.mrpController AS mrpController#3319, productOrderScheduleExploded#3301.sourceOfSupplyUuid AS sourceOfSupplyUuid#3320, productOrderScheduleExploded#3301.purchasingOrg AS purchasingOrg#3321, productOrderScheduleExploded#3301.purchasingGroup AS purchasingGroup#3322, xxhash64(CASE WHEN (_extract_supplier#4175 <=> true) THEN supplierOrGroup#3208 END, CASE WHEN (_extract_deliveryDate#4176 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_orderDate#4177 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_supplierSubrange#4178 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_purchasingOrg#4179 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_mrpController#4180 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4181 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, locationOrGroup#3220, ((((((((CASE WHEN (isnull(supplierOrGroup#3208) AND (_extract_supplier#4175 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4176 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4177 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4178 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4179 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4180 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4181 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(locationOrGroup#3220) THEN 256 ELSE 0 END), 10000000095, 42) AS orderProposalId#3715L, 0 AS orderProposalHorizonGroupingId#3736L, xxhash64(CASE WHEN (_extract_purchasingOrg#4182 <=> true) THEN productOrderScheduleExploded#3301.purchasingOrg END, CASE WHEN (_extract_deliveryDate#4183 <=> true) THEN deliveryDateTime#3002 END, CASE WHEN (_extract_supplier#4184 <=> true) THEN supplier#3000 END, CASE WHEN (_extract_supplierSubrange#4185 <=> true) THEN subrange#3003 END, CASE WHEN (_extract_orderDate#4186 <=> true) THEN productOrderScheduleExploded#3301.orderDateTime END, CASE WHEN (_extract_mrpController#4187 <=> true) THEN productOrderScheduleExploded#3301.mrpController END, orderGroupingProfile#3015, CASE WHEN (_extract_purchasingGroup#4188 <=> true) THEN productOrderScheduleExploded#3301.purchasingGroup END, plant#3001, ((((((((CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingOrg) AND (_extract_purchasingOrg#4182 <=> true)) THEN 1 ELSE 0 END + CASE WHEN (isnull(deliveryDateTime#3002) AND (_extract_deliveryDate#4183 <=> true)) THEN 2 ELSE 0 END) + CASE WHEN (isnull(supplier#3000) AND (_extract_supplier#4184 <=> true)) THEN 4 ELSE 0 END) + CASE WHEN (isnull(subrange#3003) AND (_extract_supplierSubrange#4185 <=> true)) THEN 8 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.orderDateTime) AND (_extract_orderDate#4186 <=> true)) THEN 16 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.mrpController) AND (_extract_mrpController#4187 <=> true)) THEN 32 ELSE 0 END) + CASE WHEN isnull(orderGroupingProfile#3015) THEN 64 ELSE 0 END) + CASE WHEN (isnull(productOrderScheduleExploded#3301.purchasingGroup) AND (_extract_purchasingGroup#4188 <=> true)) THEN 128 ELSE 0 END) + CASE WHEN isnull(plant#3001) THEN 256 ELSE 0 END), 10000000095, 42) AS splitIndicator#4136L]
Input [23]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, _extract_supplier#4175, _extract_deliveryDate#4176, _extract_orderDate#4177, _extract_supplierSubrange#4178, _extract_purchasingOrg#4179, _extract_mrpController#4180, _extract_purchasingGroup#4181, _extract_purchasingOrg#4182, _extract_deliveryDate#4183, _extract_supplier#4184, _extract_supplierSubrange#4185, _extract_orderDate#4186, _extract_mrpController#4187, _extract_purchasingGroup#4188, orderGroupingProfile#3015, supplierOrGroup#3208, locationOrGroup#3220, productOrderScheduleExploded#3301]

(50) AdaptiveSparkPlan
Output [16]: [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, product#3315, orderDateTime#3316, availabilityDateTime#3317, nextAvailabilityDateTime#3318, mrpController#3319, sourceOfSupplyUuid#3320, purchasingOrg#3321, purchasingGroup#3322, orderProposalId#3715L, orderProposalHorizonGroupingId#3736L, splitIndicator#4136L]
Arguments: isFinalPlan=true

(51) TableCacheQueryStage
Output: []
Arguments: 0

(52) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#4936L]
Results [1]: [count#4937L]

(53) Exchange
Input [1]: [count#4937L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=2074]

(54) ShuffleQueryStage
Output [1]: [count#4937L]
Arguments: 1

(55) HashAggregate [codegen id : 2]
Input [1]: [count#4937L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#4693L]
Results [1]: [count(1)#4693L AS count#4694L]

(56) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#4936L]
Results [1]: [count#4937L]

(57) Exchange
Input [1]: [count#4937L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1685]

(58) HashAggregate
Input [1]: [count#4937L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#4693L]
Results [1]: [count(1)#4693L AS count#4694L]

(59) AdaptiveSparkPlan
Output [1]: [count#4694L]
Arguments: isFinalPlan=true

SQL / DataFrame Properties

Name	Value
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
temporal.activity.id	26269996-b72a-3f7e-9814-66d8981041bd
temporal.activity.type	CreateOrderProposalShards