crp-wrkload-determination - Details for Stage 121711 (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: 47672

digraph G { subgraph clusterstage_121711 { label="Stage 121711"; subgraph cluster574440 { label="Exchange"; 207532 [labelType="html" label="ShuffledRowRDD [207532] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574436 { label="WholeStageCodegen (1)"; 207533 [labelType="html" label="MapPartitionsRDD [207533] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574435 { label="MapGroups"; 207534 [labelType="html" label="MapPartitionsRDD [207534] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574432 { label="WholeStageCodegen (2)"; 207535 [labelType="html" label="MapPartitionsRDD [207535] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574441 { label="mapPartitionsInternal"; 207536 [labelType="html" label="MapPartitionsRDD [207536] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574442 { label="mapPartitionsInternal"; 207537 [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#3374947, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3374948L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3374949, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3374950L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@1d32138d, value#3374941.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3374941], [path#3374931, length#3374932L, isDir#3374933, modificationTime#3374934L], obj#3374946: org.apache.spark.sql.delta.SerializableFileStatus\n ... [207537] [Cached] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574503 { label="InMemoryTableScan"; 207551 [labelType="html" label="MapPartitionsRDD [207551] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 207552 [labelType="html" label="MapPartitionsRDD [207552] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 207553 [labelType="html" label="MapPartitionsRDD [207553] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574499 { label="WholeStageCodegen (3)"; 207554 [labelType="html" label="MapPartitionsRDD [207554] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574498 { label="DeserializeToObject"; 207555 [labelType="html" label="MapPartitionsRDD [207555] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574497 { label="MapPartitions"; 207556 [labelType="html" label="MapPartitionsRDD [207556] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574493 { label="WholeStageCodegen (4)"; 207557 [labelType="html" label="MapPartitionsRDD [207557] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574492 { label="Exchange"; 207558 [labelType="html" label="MapPartitionsRDD [207558] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 207532->207533; 207533->207534; 207534->207535; 207535->207536; 207536->207537; 207537->207551; 207551->207552; 207552->207553; 207553->207554; 207554->207555; 207555->207556; 207556->207557; 207557->207558; }

207531,207532

207537

Event Timeline

Enable zooming