crp-demand-service - Details for Query 61

Submitted Time: 2026/01/27 08:08:39
Duration: 0.6 s
Succeeded Jobs: 178 179 180 181 182 183 184

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 (6)\n \nduration: 0 ms"; 2 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 0 ms peak memory: 64.2 MiB number of output rows: 1 number of sort fallback tasks: 0 avg hash probes per key: 1"]; } 3 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 251.0 B number of coalesced partitions: 1"]; 4 [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: 244.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: 240.0 B local merged bytes read: 0.0 B number of partitions: 37 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 244.0 B"]; subgraph cluster5 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: 14 ms"; 6 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 6 ms peak memory: 64.2 MiB number of output rows: 1 number of sort fallback tasks: 0 avg hash probes per key: 1"]; 7 [labelType="html" label=" Project "]; 8 [labelType="html" label="BroadcastHashJoin number of output rows: 1"]; 15 [labelType="html" label=" Project "]; 16 [labelType="html" label="Filter number of output rows: 1"]; 17 [labelType="html" label="Generate number of output rows: 1"]; 18 [labelType="html" label=" Project "]; 19 [labelType="html" label="BroadcastHashJoin number of output rows: 1"]; 26 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 5 ms peak memory: 256.0 KiB number of output rows: 1 number of sort fallback tasks: 0 avg hash probes per key: 0"]; } 9 [labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 6 ms time to collect: 390 ms number of output rows: 10 data size: 64.0 MiB"]; 10 [labelType="html" label=" Project "]; subgraph cluster11 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n1.6 s (194 ms, 217 ms, 257 ms (stage 256.0: task 2025))"; 12 [labelType="html" label="Filter number of output rows: 10"]; 13 [labelType="html" label="ColumnarToRow number of output rows: 10 number of input batches: 7"]; } 14 [labelType="html" label="Scan parquet number of files read: 7 scan time total (min, med, max (stageId: taskId)) 1.5 s (191 ms, 215 ms, 255 ms (stage 256.0: task 2025)) metadata time: 0 ms size of files read: 49.6 KiB number of output rows: 10"]; 20 [labelType="html" label="BroadcastExchange time to broadcast: 0 ms time to build: 6 ms time to collect: 18 ms number of output rows: 10 data size: 64.0 MiB"]; 21 [labelType="html" label="AQEShuffleRead number of partitions: 1"]; 22 [labelType="html" label="Exchange shuffle records written: 10 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 6 ms (0 ms, 0 ms, 1 ms (stage 254.0: task 2022)) 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: 10 local bytes read: 400.0 B fetch wait time: 0 ms remote bytes read: 908.0 B merged fetch fallback count: 0 local blocks read: 3 remote merged chunks fetched: 0 remote blocks read: 7 data size total (min, med, max (stageId: taskId)) 920.0 B (80.0 B, 96.0 B, 104.0 B (stage 254.0: task 2013)) local merged bytes read: 0.0 B number of partitions: 37 remote reqs duration: 2 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 1308.0 B (123.0 B, 132.0 B, 136.0 B (stage 254.0: task 2017))"]; subgraph cluster23 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n1.3 s (111 ms, 120 ms, 177 ms (stage 254.0: task 2018))"; 24 [labelType="html" label="Filter number of output rows: 10"]; 25 [labelType="html" label="Scan ExistingRDD number of output rows: 10"]; } 27 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 2.4 KiB number of coalesced partitions: 1"]; 28 [labelType="html" label="Exchange shuffle records written: 25 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 13 ms (0 ms, 0 ms, 0 ms (stage 259.0: task 2036)) 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: 828.0 B fetch wait time: 0 ms remote bytes read: 1472.0 B merged fetch fallback count: 0 local blocks read: 9 remote merged chunks fetched: 0 remote blocks read: 16 data size total (min, med, max (stageId: taskId)) 800.0 B (32.0 B, 32.0 B, 32.0 B (stage 259.0: task 2032)) local merged bytes read: 0.0 B number of partitions: 37 remote reqs duration: 2 ms remote bytes read to disk: 0.0 B shuffle bytes written total (min, med, max (stageId: taskId)) 2.2 KiB (92.0 B, 92.0 B, 92.0 B (stage 259.0: task 2032))"]; subgraph cluster29 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: total (min, med, max (stageId: taskId))\n2.4 s (72 ms, 98 ms, 110 ms (stage 259.0: task 2040))"; 30 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build total (min, med, max (stageId: taskId)) 2.3 s (69 ms, 91 ms, 103 ms (stage 259.0: task 2036)) peak memory total (min, med, max (stageId: taskId)) 6.3 MiB (256.0 KiB, 256.0 KiB, 256.0 KiB (stage 259.0: task 2032)) number of output rows: 25 number of sort fallback tasks: 0 avg hash probes per key: 0"]; 31 [labelType="html" label=" Project "]; 32 [labelType="html" label="BroadcastHashJoin number of output rows: 1,174"]; 33 [labelType="html" label="ColumnarToRow number of output rows: 1,196 number of input batches: 25"]; } 34 [labelType="html" label="Scan parquet number of files read: 25 scan time total (min, med, max (stageId: taskId)) 2.3 s (69 ms, 91 ms, 103 ms (stage 259.0: task 2036)) metadata time: 0 ms size of files read: 83.2 KiB number of output rows: 1,196"]; 35 [labelType="html" label="BroadcastExchange time to broadcast: 1 ms time to build: 7 ms time to collect: 223 ms number of output rows: 1,174 data size: 64.1 MiB"]; subgraph cluster36 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 197 ms"; 37 [labelType="html" label="Filter number of output rows: 1,174"]; 38 [labelType="html" label="ColumnarToRow number of output rows: 1,196 number of input batches: 1"]; } 39 [labelType="html" label="Scan parquet number of files read: 1 scan time: 196 ms metadata time: 0 ms size of files read: 8.1 KiB number of output rows: 1,196"]; 2->0; 3->2; 4->3; 6->4; 7->6; 8->7; 9->8; 10->9; 12->10; 13->12; 14->13; 15->8; 16->15; 17->16; 18->17; 19->18; 20->19; 21->20; 22->21; 24->22; 25->24; 26->19; 27->26; 28->27; 30->28; 31->30; 32->31; 33->32; 34->33; 35->32; 37->35; 38->37; 39->38; }

AdaptiveSparkPlan isFinalPlan=true

HashAggregate(keys=[name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939], functions=[])

WholeStageCodegen (6)

AQEShuffleRead coalesced

Exchange hashpartitioning(name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939, 37), ENSURE_REQUIREMENTS, [plan_id=10266]

HashAggregate(keys=[name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939], functions=[])

Project [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946]

BroadcastHashJoin [name#6937], [name#6931], Inner, BuildLeft, false

Project [explodedDemandChannels#6925.name AS name#6931]

Filter isnotnull(explodedDemandChannels#6925.name)

Generate explode(demandChannels#6913), false, [explodedDemandChannels#6925]

Project [demandChannels#6913]

BroadcastHashJoin [demandProfile#6912], [demandProfile#6761], Inner, BuildLeft, false

HashAggregate(keys=[demandProfile#6761], functions=[])

WholeStageCodegen (5)

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

Project [name#6937, demandStream#6939, forecastCode#6940, transform(distributionChains#6942, lambdafunction(named_struct(internalUUID, lambda chain#6958.internalUUID, salesOrganizationUUID, lambda chain#6958.salesOrganization.internalRefUUID, distributionChannelUUID, lambda chain#6958.distributionChannel.internalRefUUID), lambda chain#6958, false)) AS distributionChains#6957, transform(customerOrderTypes#6943, lambdafunction(named_struct(internalUUID, lambda documentType#6971.internalRefUUID), lambda documentType#6971, false)) AS customerOrderTypes#6970, transform(customerOrderItemTypeCodes#6944, lambdafunction(named_struct(customerOrderItemTypeCodeUUID, lambda itemType#6983.internalRefUUID), lambda itemType#6983, false)) AS customerOrderItemTypeCodes#6982, considerVariance#6946]

Filter isnotnull(name#6937)

ColumnarToRow

WholeStageCodegen (1)

FileScan parquet [name#6937,demandStream#6939,forecastCode#6940,distributionChains#6942,customerOrderTypes#6943,customerOrderItemTypeCodes#6944,considerVariance#6946] Batched: true, DataFilters: [isnotnull(name#6937)], Format: Parquet, Location: PreparedDeltaFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20...., PartitionFilters: [], PushedFilters: [IsNotNull(name)], ReadSchema: struct<name:string,demandStream:int,forecastCode:string,distributionChains:array<struct<internalU...

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

AQEShuffleRead local

Exchange hashpartitioning(demandProfile#6912, 37), ENSURE_REQUIREMENTS, [plan_id=9842]

Filter (isnotnull(demandProfile#6912) AND ((size(demandChannels#6913, true) > 0) AND isnotnull(demandChannels#6913)))

Scan ExistingRDD[demandProfile#6912,demandChannels#6913]

WholeStageCodegen (2)

AQEShuffleRead coalesced

Exchange hashpartitioning(demandProfile#6761, 37), ENSURE_REQUIREMENTS, [plan_id=10131]

HashAggregate(keys=[demandProfile#6761], functions=[])

Project [demandProfile#6761]

BroadcastHashJoin [coalesce(plant#6751, ), isnull(plant#6751), coalesce(product#6750, ), isnull(product#6750)], [coalesce(plant#6759, ), isnull(plant#6759), coalesce(product#6758, ), isnull(product#6758)], Inner, BuildRight, false

ColumnarToRow

WholeStageCodegen (4)

FileScan parquet [product#6750,plant#6751] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<product:string,plant:string>

BroadcastExchange HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=9855]

Filter isnotnull(demandProfile#6761)

ColumnarToRow

WholeStageCodegen (3)

FileScan parquet [product#6758,plant#6759,demandprofile#6761] Batched: true, DataFilters: [isnotnull(demandprofile#6761)], Format: Parquet, Location: InMemoryFileIndex(1 paths)[hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanac..., PartitionFilters: [], PushedFilters: [IsNotNull(demandprofile)], ReadSchema: struct<product:string,plant:string,demandprofile:string>

Details

== Physical Plan ==
AdaptiveSparkPlan (64)
+- == Final Plan ==
   * HashAggregate (39)
   +- AQEShuffleRead (38)
      +- ShuffleQueryStage (37), Statistics(sizeInBytes=240.0 B, rowCount=1)
         +- Exchange (36)
            +- * HashAggregate (35)
               +- * Project (34)
                  +- * BroadcastHashJoin Inner BuildLeft (33)
                     :- BroadcastQueryStage (6), Statistics(sizeInBytes=64.0 MiB, rowCount=10)
                     :  +- BroadcastExchange (5)
                     :     +- Project (4)
                     :        +- * Filter (3)
                     :           +- * ColumnarToRow (2)
                     :              +- Scan parquet  (1)
                     +- * Project (32)
                        +- * Filter (31)
                           +- * Generate (30)
                              +- * Project (29)
                                 +- * BroadcastHashJoin Inner BuildLeft (28)
                                    :- BroadcastQueryStage (13), Statistics(sizeInBytes=64.0 MiB, rowCount=10)
                                    :  +- BroadcastExchange (12)
                                    :     +- AQEShuffleRead (11)
                                    :        +- ShuffleQueryStage (10), Statistics(sizeInBytes=920.0 B, rowCount=10)
                                    :           +- Exchange (9)
                                    :              +- * Filter (8)
                                    :                 +- * Scan ExistingRDD (7)
                                    +- * HashAggregate (27)
                                       +- AQEShuffleRead (26)
                                          +- ShuffleQueryStage (25), Statistics(sizeInBytes=800.0 B, rowCount=25)
                                             +- Exchange (24)
                                                +- * HashAggregate (23)
                                                   +- * Project (22)
                                                      +- * BroadcastHashJoin Inner BuildRight (21)
                                                         :- * ColumnarToRow (15)
                                                         :  +- Scan parquet  (14)
                                                         +- BroadcastQueryStage (20), Statistics(sizeInBytes=64.1 MiB, rowCount=1.17E+3)
                                                            +- BroadcastExchange (19)
                                                               +- * Filter (18)
                                                                  +- * ColumnarToRow (17)
                                                                     +- Scan parquet  (16)
+- == Initial Plan ==
   HashAggregate (63)
   +- Exchange (62)
      +- HashAggregate (61)
         +- Project (60)
            +- BroadcastHashJoin Inner BuildLeft (59)
               :- BroadcastExchange (42)
               :  +- Project (41)
               :     +- Filter (40)
               :        +- Scan parquet  (1)
               +- Project (58)
                  +- Filter (57)
                     +- Generate (56)
                        +- Project (55)
                           +- SortMergeJoin Inner (54)
                              :- Sort (44)
                              :  +- Exchange (43)
                              :     +- Filter (8)
                              :        +- Scan ExistingRDD (7)
                              +- Sort (53)
                                 +- HashAggregate (52)
                                    +- Exchange (51)
                                       +- HashAggregate (50)
                                          +- Project (49)
                                             +- BroadcastHashJoin Inner BuildRight (48)
                                                :- Scan parquet  (45)
                                                +- BroadcastExchange (47)
                                                   +- Filter (46)
                                                      +- Scan parquet  (16)


(1) Scan parquet 
Output [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6942, customerOrderTypes#6943, customerOrderItemTypeCodes#6944, considerVariance#6946]
Batched: true
Location: PreparedDeltaFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-dl-stream-service/prp/demand-channel]
PushedFilters: [IsNotNull(name)]
ReadSchema: struct<name:string,demandStream:int,forecastCode:string,distributionChains:array<struct<internalUUID:string,salesOrganization:struct<internalRefUUID:string,id:string>,distributionChannel:struct<internalRefUUID:string,id:string>>>,customerOrderTypes:array<struct<id:string,internalRefUUID:string>>,customerOrderItemTypeCodes:array<struct<id:string,internalRefUUID:string>>,considerVariance:boolean>

(2) ColumnarToRow [codegen id : 1]
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6942, customerOrderTypes#6943, customerOrderItemTypeCodes#6944, considerVariance#6946]

(3) Filter [codegen id : 1]
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6942, customerOrderTypes#6943, customerOrderItemTypeCodes#6944, considerVariance#6946]
Condition : isnotnull(name#6937)

(4) Project
Output [7]: [name#6937, demandStream#6939, forecastCode#6940, transform(distributionChains#6942, lambdafunction(named_struct(internalUUID, lambda chain#6958.internalUUID, salesOrganizationUUID, lambda chain#6958.salesOrganization.internalRefUUID, distributionChannelUUID, lambda chain#6958.distributionChannel.internalRefUUID), lambda chain#6958, false)) AS distributionChains#6957, transform(customerOrderTypes#6943, lambdafunction(named_struct(internalUUID, lambda documentType#6971.internalRefUUID), lambda documentType#6971, false)) AS customerOrderTypes#6970, transform(customerOrderItemTypeCodes#6944, lambdafunction(named_struct(customerOrderItemTypeCodeUUID, lambda itemType#6983.internalRefUUID), lambda itemType#6983, false)) AS customerOrderItemTypeCodes#6982, considerVariance#6946]
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6942, customerOrderTypes#6943, customerOrderItemTypeCodes#6944, considerVariance#6946]

(5) BroadcastExchange
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946]
Arguments: HashedRelationBroadcastMode(List(input[0, string, true]),false), [plan_id=9831]

(6) BroadcastQueryStage
Output [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946]
Arguments: 0

(7) Scan ExistingRDD [codegen id : 2]
Output [2]: [demandProfile#6912, demandChannels#6913]
Arguments: [demandProfile#6912, demandChannels#6913], MapPartitionsRDD[654] at createDataFrame at DemandProfileDataReaderImpl.java:60, ExistingRDD, UnknownPartitioning(0)

(8) Filter [codegen id : 2]
Input [2]: [demandProfile#6912, demandChannels#6913]
Condition : (isnotnull(demandProfile#6912) AND ((size(demandChannels#6913, true) > 0) AND isnotnull(demandChannels#6913)))

(9) Exchange
Input [2]: [demandProfile#6912, demandChannels#6913]
Arguments: hashpartitioning(demandProfile#6912, 37), ENSURE_REQUIREMENTS, [plan_id=9842]

(10) ShuffleQueryStage
Output [2]: [demandProfile#6912, demandChannels#6913]
Arguments: 1

(11) AQEShuffleRead
Input [2]: [demandProfile#6912, demandChannels#6913]
Arguments: local

(12) BroadcastExchange
Input [2]: [demandProfile#6912, demandChannels#6913]
Arguments: HashedRelationBroadcastMode(List(input[0, string, false]),false), [plan_id=9971]

(13) BroadcastQueryStage
Output [2]: [demandProfile#6912, demandChannels#6913]
Arguments: 3

(14) Scan parquet 
Output [2]: [product#6750, plant#6751]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/product-plant-list/10000000092/shardId=0_1_10000000092]
ReadSchema: struct<product:string,plant:string>

(15) ColumnarToRow [codegen id : 4]
Input [2]: [product#6750, plant#6751]

(16) Scan parquet 
Output [3]: [product#6758, plant#6759, demandprofile#6761]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-param-determination-service/out/10000000092/0_1_10000000092/demandprofile]
PushedFilters: [IsNotNull(demandprofile)]
ReadSchema: struct<product:string,plant:string,demandprofile:string>

(17) ColumnarToRow [codegen id : 3]
Input [3]: [product#6758, plant#6759, demandprofile#6761]

(18) Filter [codegen id : 3]
Input [3]: [product#6758, plant#6759, demandprofile#6761]
Condition : isnotnull(demandProfile#6761)

(19) BroadcastExchange
Input [3]: [product#6758, plant#6759, demandprofile#6761]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=9855]

(20) BroadcastQueryStage
Output [3]: [product#6758, plant#6759, demandprofile#6761]
Arguments: 2

(21) BroadcastHashJoin [codegen id : 4]
Left keys [4]: [coalesce(plant#6751, ), isnull(plant#6751), coalesce(product#6750, ), isnull(product#6750)]
Right keys [4]: [coalesce(plant#6759, ), isnull(plant#6759), coalesce(product#6758, ), isnull(product#6758)]
Join type: Inner
Join condition: None

(22) Project [codegen id : 4]
Output [1]: [demandProfile#6761]
Input [5]: [product#6750, plant#6751, product#6758, plant#6759, demandprofile#6761]

(23) HashAggregate [codegen id : 4]
Input [1]: [demandProfile#6761]
Keys [1]: [demandProfile#6761]
Functions: []
Aggregate Attributes: []
Results [1]: [demandProfile#6761]

(24) Exchange
Input [1]: [demandProfile#6761]
Arguments: hashpartitioning(demandProfile#6761, 37), ENSURE_REQUIREMENTS, [plan_id=10131]

(25) ShuffleQueryStage
Output [1]: [demandProfile#6761]
Arguments: 4

(26) AQEShuffleRead
Input [1]: [demandProfile#6761]
Arguments: coalesced

(27) HashAggregate
Input [1]: [demandProfile#6761]
Keys [1]: [demandProfile#6761]
Functions: []
Aggregate Attributes: []
Results [1]: [demandProfile#6761]

(28) BroadcastHashJoin
Left keys [1]: [demandProfile#6912]
Right keys [1]: [demandProfile#6761]
Join type: Inner
Join condition: None

(29) Project
Output [1]: [demandChannels#6913]
Input [3]: [demandProfile#6912, demandChannels#6913, demandProfile#6761]

(30) Generate
Input [1]: [demandChannels#6913]
Arguments: explode(demandChannels#6913), false, [explodedDemandChannels#6925]

(31) Filter
Input [1]: [explodedDemandChannels#6925]
Condition : isnotnull(explodedDemandChannels#6925.name)

(32) Project
Output [1]: [explodedDemandChannels#6925.name AS name#6931]
Input [1]: [explodedDemandChannels#6925]

(33) BroadcastHashJoin [codegen id : 5]
Left keys [1]: [name#6937]
Right keys [1]: [name#6931]
Join type: Inner
Join condition: None

(34) Project [codegen id : 5]
Output [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946]
Input [8]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946, name#6931]

(35) HashAggregate [codegen id : 5]
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946]
Keys [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Functions: []
Aggregate Attributes: []
Results [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]

(36) Exchange
Input [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Arguments: hashpartitioning(name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939, 37), ENSURE_REQUIREMENTS, [plan_id=10266]

(37) ShuffleQueryStage
Output [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Arguments: 5

(38) AQEShuffleRead
Input [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Arguments: coalesced

(39) HashAggregate [codegen id : 6]
Input [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Keys [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Functions: []
Aggregate Attributes: []
Results: []

(40) Filter
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6942, customerOrderTypes#6943, customerOrderItemTypeCodes#6944, considerVariance#6946]
Condition : isnotnull(name#6937)

(41) Project
Output [7]: [name#6937, demandStream#6939, forecastCode#6940, transform(distributionChains#6942, lambdafunction(named_struct(internalUUID, lambda chain#6958.internalUUID, salesOrganizationUUID, lambda chain#6958.salesOrganization.internalRefUUID, distributionChannelUUID, lambda chain#6958.distributionChannel.internalRefUUID), lambda chain#6958, false)) AS distributionChains#6957, transform(customerOrderTypes#6943, lambdafunction(named_struct(internalUUID, lambda documentType#6971.internalRefUUID), lambda documentType#6971, false)) AS customerOrderTypes#6970, transform(customerOrderItemTypeCodes#6944, lambdafunction(named_struct(customerOrderItemTypeCodeUUID, lambda itemType#6983.internalRefUUID), lambda itemType#6983, false)) AS customerOrderItemTypeCodes#6982, considerVariance#6946]
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6942, customerOrderTypes#6943, customerOrderItemTypeCodes#6944, considerVariance#6946]

(42) BroadcastExchange
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946]
Arguments: HashedRelationBroadcastMode(List(input[0, string, true]),false), [plan_id=9767]

(43) Exchange
Input [2]: [demandProfile#6912, demandChannels#6913]
Arguments: hashpartitioning(demandProfile#6912, 37), ENSURE_REQUIREMENTS, [plan_id=9758]

(44) Sort
Input [2]: [demandProfile#6912, demandChannels#6913]
Arguments: [demandProfile#6912 ASC NULLS FIRST], false, 0

(45) Scan parquet 
Output [2]: [product#6750, plant#6751]
Batched: true
Location: InMemoryFileIndex [hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/product-plant-list/10000000092/shardId=0_1_10000000092]
ReadSchema: struct<product:string,plant:string>

(46) Filter
Input [3]: [product#6758, plant#6759, demandprofile#6761]
Condition : isnotnull(demandProfile#6761)

(47) BroadcastExchange
Input [3]: [product#6758, plant#6759, demandprofile#6761]
Arguments: HashedRelationBroadcastMode(List(coalesce(input[1, string, true], ), isnull(input[1, string, true]), coalesce(input[0, string, true], ), isnull(input[0, string, true])),false), [plan_id=9749]

(48) BroadcastHashJoin
Left keys [4]: [coalesce(plant#6751, ), isnull(plant#6751), coalesce(product#6750, ), isnull(product#6750)]
Right keys [4]: [coalesce(plant#6759, ), isnull(plant#6759), coalesce(product#6758, ), isnull(product#6758)]
Join type: Inner
Join condition: None

(49) Project
Output [1]: [demandProfile#6761]
Input [5]: [product#6750, plant#6751, product#6758, plant#6759, demandprofile#6761]

(50) HashAggregate
Input [1]: [demandProfile#6761]
Keys [1]: [demandProfile#6761]
Functions: []
Aggregate Attributes: []
Results [1]: [demandProfile#6761]

(51) Exchange
Input [1]: [demandProfile#6761]
Arguments: hashpartitioning(demandProfile#6761, 37), ENSURE_REQUIREMENTS, [plan_id=9754]

(52) HashAggregate
Input [1]: [demandProfile#6761]
Keys [1]: [demandProfile#6761]
Functions: []
Aggregate Attributes: []
Results [1]: [demandProfile#6761]

(53) Sort
Input [1]: [demandProfile#6761]
Arguments: [demandProfile#6761 ASC NULLS FIRST], false, 0

(54) SortMergeJoin
Left keys [1]: [demandProfile#6912]
Right keys [1]: [demandProfile#6761]
Join type: Inner
Join condition: None

(55) Project
Output [1]: [demandChannels#6913]
Input [3]: [demandProfile#6912, demandChannels#6913, demandProfile#6761]

(56) Generate
Input [1]: [demandChannels#6913]
Arguments: explode(demandChannels#6913), false, [explodedDemandChannels#6925]

(57) Filter
Input [1]: [explodedDemandChannels#6925]
Condition : isnotnull(explodedDemandChannels#6925.name)

(58) Project
Output [1]: [explodedDemandChannels#6925.name AS name#6931]
Input [1]: [explodedDemandChannels#6925]

(59) BroadcastHashJoin
Left keys [1]: [name#6937]
Right keys [1]: [name#6931]
Join type: Inner
Join condition: None

(60) Project
Output [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946]
Input [8]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946, name#6931]

(61) HashAggregate
Input [7]: [name#6937, demandStream#6939, forecastCode#6940, distributionChains#6957, customerOrderTypes#6970, customerOrderItemTypeCodes#6982, considerVariance#6946]
Keys [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Functions: []
Aggregate Attributes: []
Results [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]

(62) Exchange
Input [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Arguments: hashpartitioning(name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939, 37), ENSURE_REQUIREMENTS, [plan_id=9772]

(63) HashAggregate
Input [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Keys [7]: [name#6937, considerVariance#6946, customerOrderItemTypeCodes#6982, customerOrderTypes#6970, distributionChains#6957, forecastCode#6940, demandStream#6939]
Functions: []
Aggregate Attributes: []
Results: []

(64) AdaptiveSparkPlan
Output: []
Arguments: isFinalPlan=true

SQL / DataFrame Properties

Name	Value
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true