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

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

digraph G { subgraph clusterstage_121702 { label="Stage 121702"; 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 cluster574450 { label="InMemoryTableScan"; 207538 [labelType="html" label="MapPartitionsRDD [207538] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 207539 [labelType="html" label="MapPartitionsRDD [207539] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 207540 [labelType="html" label="MapPartitionsRDD [207540] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574444 { label="WholeStageCodegen (1)"; 207541 [labelType="html" label="MapPartitionsRDD [207541] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster574443 { label="Exchange"; 207542 [labelType="html" label="MapPartitionsRDD [207542] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 207532->207533; 207533->207534; 207534->207535; 207535->207536; 207536->207537; 207537->207538; 207538->207539; 207539->207540; 207540->207541; 207541->207542; }

207531,207532

207537

Event Timeline

Enable zooming