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

Resource Profile Id: 0
Total Time Across All Tasks: 0.2 s
Locality Level Summary: Process local: 200
Input Size / Records: 3.1 KiB / 0
Associated Job Ids: 47475

digraph G { subgraph clusterstage_121288 { label="Stage 121288"; subgraph cluster572110 { label="Exchange"; 206522 [labelType="html" label="ShuffledRowRDD [206522] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572106 { label="WholeStageCodegen (1)"; 206523 [labelType="html" label="MapPartitionsRDD [206523] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572105 { label="MapGroups"; 206524 [labelType="html" label="MapPartitionsRDD [206524] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572102 { label="WholeStageCodegen (2)"; 206525 [labelType="html" label="MapPartitionsRDD [206525] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572111 { label="mapPartitionsInternal"; 206526 [labelType="html" label="MapPartitionsRDD [206526] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572112 { label="mapPartitionsInternal"; 206527 [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#3358067, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3358068L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3358069, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3358070L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@5b9b60f5, value#3358061.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3358061], [path#3358051, length#3358052L, isDir#3358053, modificationTime#3358054L], obj#3358066: org.apache.spark.sql.delta.SerializableFileStatus\n ... [206527] [Cached] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572212 { label="InMemoryTableScan"; 206560 [labelType="html" label="MapPartitionsRDD [206560] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 206561 [labelType="html" label="MapPartitionsRDD [206561] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 206562 [labelType="html" label="MapPartitionsRDD [206562] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572208 { label="WholeStageCodegen (3)"; 206563 [labelType="html" label="MapPartitionsRDD [206563] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572207 { label="DeserializeToObject"; 206564 [labelType="html" label="MapPartitionsRDD [206564] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572206 { label="MapPartitions"; 206565 [labelType="html" label="MapPartitionsRDD [206565] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572202 { label="WholeStageCodegen (4)"; 206566 [labelType="html" label="MapPartitionsRDD [206566] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster572201 { label="Exchange"; 206567 [labelType="html" label="MapPartitionsRDD [206567] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 206522->206523; 206523->206524; 206524->206525; 206525->206526; 206526->206527; 206527->206560; 206560->206561; 206561->206562; 206562->206563; 206563->206564; 206564->206565; 206565->206566; 206566->206567; }

206521,206522

206527

Event Timeline

Enable zooming