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

digraph G { subgraph clusterstage_120507 { label="Stage 120507"; subgraph cluster567916 { label="Exchange"; 204704 [labelType="html" label="ShuffledRowRDD [204704] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567912 { label="WholeStageCodegen (1)"; 204705 [labelType="html" label="MapPartitionsRDD [204705] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567911 { label="MapGroups"; 204706 [labelType="html" label="MapPartitionsRDD [204706] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567908 { label="WholeStageCodegen (2)"; 204707 [labelType="html" label="MapPartitionsRDD [204707] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567917 { label="mapPartitionsInternal"; 204708 [labelType="html" label="MapPartitionsRDD [204708] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567918 { label="mapPartitionsInternal"; 204709 [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#3327683, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).length AS length#3327684L, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).isDir AS isDir#3327685, knownnotnull(assertnotnull(input[0, org.apache.spark.sql.delta.SerializableFileStatus, true])).modificationTime AS modificationTime#3327686L]\n +- MapGroups org.apache.spark.sql.KeyValueGroupedDataset$$Lambda$6934/0x0000000801d21280@273e3083, value#3327677.toString, newInstance(class org.apache.spark.sql.delta.SerializableFileStatus), [value#3327677], [path#3327667, length#3327668L, isDir#3327669, modificationTime#3327670L], obj#3327682: org.apache.spark.sql.delta.SerializableFileStatus\n ... [204709] [Cached] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567979 { label="InMemoryTableScan"; 204723 [labelType="html" label="MapPartitionsRDD [204723] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 204724 [labelType="html" label="MapPartitionsRDD [204724] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 204725 [labelType="html" label="MapPartitionsRDD [204725] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567975 { label="WholeStageCodegen (3)"; 204726 [labelType="html" label="MapPartitionsRDD [204726] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567974 { label="DeserializeToObject"; 204727 [labelType="html" label="MapPartitionsRDD [204727] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567973 { label="MapPartitions"; 204728 [labelType="html" label="MapPartitionsRDD [204728] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567969 { label="WholeStageCodegen (4)"; 204729 [labelType="html" label="MapPartitionsRDD [204729] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567968 { label="Exchange"; 204730 [labelType="html" label="MapPartitionsRDD [204730] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 204704->204705; 204705->204706; 204706->204707; 204707->204708; 204708->204709; 204709->204723; 204723->204724; 204724->204725; 204725->204726; 204726->204727; 204727->204728; 204728->204729; 204729->204730; }

204703,204704

204709

Event Timeline

Enable zooming