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

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

digraph G { subgraph clusterstage_120514 { label="Stage 120514"; 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 cluster568018 { label="InMemoryTableScan"; 204742 [labelType="html" label="MapPartitionsRDD [204742] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 204743 [labelType="html" label="MapPartitionsRDD [204743] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 204744 [labelType="html" label="MapPartitionsRDD [204744] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568014 { label="WholeStageCodegen (3)"; 204745 [labelType="html" label="MapPartitionsRDD [204745] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568013 { label="DeserializeToObject"; 204746 [labelType="html" label="MapPartitionsRDD [204746] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568012 { label="MapPartitions"; 204747 [labelType="html" label="MapPartitionsRDD [204747] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568008 { label="WholeStageCodegen (4)"; 204748 [labelType="html" label="MapPartitionsRDD [204748] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568007 { label="Exchange"; 204749 [labelType="html" label="MapPartitionsRDD [204749] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 204704->204705; 204705->204706; 204706->204707; 204707->204708; 204708->204709; 204709->204742; 204742->204743; 204743->204744; 204744->204745; 204745->204746; 204746->204747; 204747->204748; 204748->204749; }

204703,204704

204709

Event Timeline

Enable zooming