crp-wrkload-determination - Details for Stage 119853 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 20 ms
Locality Level Summary: Process local: 200
Input Size / Records: 3.1 KiB / 0
Shuffle Write Size / Records: 14.1 KiB / 200
Associated Job Ids: 46809

digraph G { subgraph clusterstage_119853 { label="Stage 119853"; subgraph cluster564421 { label="Exchange"; 203189 [labelType="html" label="ShuffledRowRDD [203189] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564417 { label="WholeStageCodegen (1)"; 203190 [labelType="html" label="MapPartitionsRDD [203190] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564416 { label="MapGroups"; 203191 [labelType="html" label="MapPartitionsRDD [203191] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564413 { label="WholeStageCodegen (2)"; 203192 [labelType="html" label="MapPartitionsRDD [203192] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564422 { label="mapPartitionsInternal"; 203193 [labelType="html" label="MapPartitionsRDD [203193] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564423 { label="mapPartitionsInternal"; 203194 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- SerializeFromObject [staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).path, true, false, true) AS path#3302363, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3302364L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3302365, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3302366L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@228fd498, value#3302357.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3302357], [path#3302347, length#3302348L, isDir#3302349, modificationTime#3302350L], obj#3302362: org.apache.spark.sql.delta.SerializableFileStatus\n ... [203194] [Cached] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564431 { label="InMemoryTableScan"; 203195 [labelType="html" label="MapPartitionsRDD [203195] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 203196 [labelType="html" label="MapPartitionsRDD [203196] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 203197 [labelType="html" label="MapPartitionsRDD [203197] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564425 { label="WholeStageCodegen (1)"; 203198 [labelType="html" label="MapPartitionsRDD [203198] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564424 { label="Exchange"; 203199 [labelType="html" label="MapPartitionsRDD [203199] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 203189->203190; 203190->203191; 203191->203192; 203192->203193; 203193->203194; 203194->203195; 203195->203196; 203196->203197; 203197->203198; 203198->203199; }

203188,203189

203194

Event Timeline

Enable zooming