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

digraph G { subgraph clusterstage_120521 { label="Stage 120521"; 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 cluster568061 { label="InMemoryTableScan"; 204761 [labelType="html" label="MapPartitionsRDD [204761] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 204762 [labelType="html" label="MapPartitionsRDD [204762] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 204763 [labelType="html" label="MapPartitionsRDD [204763] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568057 { label="WholeStageCodegen (3)"; 204764 [labelType="html" label="MapPartitionsRDD [204764] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568056 { label="DeserializeToObject"; 204765 [labelType="html" label="MapPartitionsRDD [204765] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568055 { label="MapPartitions"; 204766 [labelType="html" label="MapPartitionsRDD [204766] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568051 { label="WholeStageCodegen (4)"; 204767 [labelType="html" label="MapPartitionsRDD [204767] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster568050 { label="Exchange"; 204768 [labelType="html" label="MapPartitionsRDD [204768] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 204704->204705; 204705->204706; 204706->204707; 204707->204708; 204708->204709; 204709->204761; 204761->204762; 204762->204763; 204763->204764; 204764->204765; 204765->204766; 204766->204767; 204767->204768; }

204703,204704

204709

Event Timeline

Enable zooming