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

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

digraph G { subgraph clusterstage_120498 { label="Stage 120498"; 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 cluster567926 { label="InMemoryTableScan"; 204710 [labelType="html" label="MapPartitionsRDD [204710] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 204711 [labelType="html" label="MapPartitionsRDD [204711] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; 204712 [labelType="html" label="MapPartitionsRDD [204712] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567920 { label="WholeStageCodegen (1)"; 204713 [labelType="html" label="MapPartitionsRDD [204713] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } subgraph cluster567919 { label="Exchange"; 204714 [labelType="html" label="MapPartitionsRDD [204714] [Unordered] $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128"]; } } 204704->204705; 204705->204706; 204706->204707; 204707->204708; 204708->204709; 204709->204710; 204710->204711; 204711->204712; 204712->204713; 204713->204714; }

204703,204704

204709

Event Timeline

Enable zooming