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

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

digraph G { subgraph clusterstage_119939 { label="Stage 119939"; subgraph cluster564887 { label="Exchange"; 203391 [labelType="html" label="ShuffledRowRDD [203391] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564883 { label="WholeStageCodegen (1)"; 203392 [labelType="html" label="MapPartitionsRDD [203392] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564882 { label="MapGroups"; 203393 [labelType="html" label="MapPartitionsRDD [203393] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564879 { label="WholeStageCodegen (2)"; 203394 [labelType="html" label="MapPartitionsRDD [203394] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564888 { label="mapPartitionsInternal"; 203395 [labelType="html" label="MapPartitionsRDD [203395] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564889 { label="mapPartitionsInternal"; 203396 [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#3305739, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3305740L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3305741, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3305742L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@1f2a012d, value#3305733.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3305733], [path#3305723, length#3305724L, isDir#3305725, modificationTime#3305726L], obj#3305738: org.apache.spark.sql.delta.SerializableFileStatus\n ... [203396] [Cached] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564897 { label="InMemoryTableScan"; 203397 [labelType="html" label="MapPartitionsRDD [203397] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 203398 [labelType="html" label="MapPartitionsRDD [203398] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 203399 [labelType="html" label="MapPartitionsRDD [203399] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564891 { label="WholeStageCodegen (1)"; 203400 [labelType="html" label="MapPartitionsRDD [203400] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster564890 { label="Exchange"; 203401 [labelType="html" label="MapPartitionsRDD [203401] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 203391->203392; 203392->203393; 203393->203394; 203394->203395; 203395->203396; 203396->203397; 203397->203398; 203398->203399; 203399->203400; 203400->203401; }

203390,203391

203396

Event Timeline

Enable zooming