processing-stream-kafka-raw-to-minio - Details for Stage 65 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 3
Input Size / Records: 0.0 B / 426
Associated Job Ids: 65

digraph G { subgraph clusterstage_65 { label="Stage 65"; 676 [labelType="html" label="SQLExecutionRDD [676] run at <unknown>:0"]; 690 [labelType="html" label="SQLExecutionRDD [690] toJavaRDD at <unknown>:0"]; 692 [labelType="html" label="PythonRDD [692] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1509 { label="MicroBatchScan"; 672 [labelType="html" label="DataSourceRDD [672] run at <unknown>:0"]; 673 [labelType="html" label="MapPartitionsRDD [673] run at <unknown>:0"]; } subgraph cluster1508 { label="Project"; 674 [labelType="html" label="MapPartitionsRDD [674] run at <unknown>:0"]; } subgraph cluster1504 { label="WholeStageCodegen (1)"; 675 [labelType="html" label="MapPartitionsRDD [675] run at <unknown>:0"]; } subgraph cluster1526 { label="WholeStageCodegen (1)"; 683 [labelType="html" label="MapPartitionsRDD [683] toJavaRDD at <unknown>:0"]; } subgraph cluster1525 { label="Filter"; 684 [labelType="html" label="MapPartitionsRDD [684] toJavaRDD at <unknown>:0"]; } subgraph cluster1524 { label="Project"; 685 [labelType="html" label="MapPartitionsRDD [685] toJavaRDD at <unknown>:0"]; } subgraph cluster1521 { label="WholeStageCodegen (2)"; 686 [labelType="html" label="MapPartitionsRDD [686] toJavaRDD at <unknown>:0"]; } subgraph cluster1520 { label="Project"; 687 [labelType="html" label="MapPartitionsRDD [687] toJavaRDD at <unknown>:0"]; } subgraph cluster1519 { label="DeserializeToObject"; 688 [labelType="html" label="MapPartitionsRDD [688] toJavaRDD at <unknown>:0"]; } subgraph cluster1518 { label="MapPartitions"; 689 [labelType="html" label="MapPartitionsRDD [689] toJavaRDD at <unknown>:0"]; } subgraph cluster1528 { label="mapPartitions"; 691 [labelType="html" label="MapPartitionsRDD [691] toJavaRDD at <unknown>:0"]; } } 672->673; 673->674; 674->675; 675->676; 676->683; 683->684; 684->685; 685->686; 686->687; 687->688; 688->689; 689->690; 690->691; 691->692; }

Event Timeline

Enable zooming