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

Resource Profile Id: 0
Total Time Across All Tasks: 16 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: 46829

digraph G { subgraph clusterstage_119896 { label="Stage 119896"; subgraph cluster564654 { label="Exchange"; 203290 [labelType="html" label="ShuffledRowRDD [203290] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564650 { label="WholeStageCodegen (1)"; 203291 [labelType="html" label="MapPartitionsRDD [203291] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564649 { label="MapGroups"; 203292 [labelType="html" label="MapPartitionsRDD [203292] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564646 { label="WholeStageCodegen (2)"; 203293 [labelType="html" label="MapPartitionsRDD [203293] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564655 { label="mapPartitionsInternal"; 203294 [labelType="html" label="MapPartitionsRDD [203294] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564656 { label="mapPartitionsInternal"; 203295 [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#3304051, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3304052L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3304053, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3304054L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@17d1857, value#3304045.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3304045], [path#3304035, length#3304036L, isDir#3304037, modificationTime#3304038L], obj#3304050: org.apache.spark.sql.delta.SerializableFileStatus\n ... [203295] [Cached] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564664 { label="InMemoryTableScan"; 203296 [labelType="html" label="MapPartitionsRDD [203296] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 203297 [labelType="html" label="MapPartitionsRDD [203297] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 203298 [labelType="html" label="MapPartitionsRDD [203298] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564658 { label="WholeStageCodegen (1)"; 203299 [labelType="html" label="MapPartitionsRDD [203299] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564657 { label="Exchange"; 203300 [labelType="html" label="MapPartitionsRDD [203300] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 203290->203291; 203291->203292; 203292->203293; 203293->203294; 203294->203295; 203295->203296; 203296->203297; 203297->203298; 203298->203299; 203299->203300; }

203289,203290

203295

Event Timeline

Enable zooming