processing-stream-kafka-raw-to-minio - Details for Stage 51 (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 / 552
Associated Job Ids: 51

digraph G { subgraph clusterstage_51 { label="Stage 51"; 529 [labelType="html" label="SQLExecutionRDD [529] run at <unknown>:0"]; 543 [labelType="html" label="SQLExecutionRDD [543] toJavaRDD at <unknown>:0"]; 545 [labelType="html" label="PythonRDD [545] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1180 { label="MicroBatchScan"; 525 [labelType="html" label="DataSourceRDD [525] run at <unknown>:0"]; 526 [labelType="html" label="MapPartitionsRDD [526] run at <unknown>:0"]; } subgraph cluster1179 { label="Project"; 527 [labelType="html" label="MapPartitionsRDD [527] run at <unknown>:0"]; } subgraph cluster1175 { label="WholeStageCodegen (1)"; 528 [labelType="html" label="MapPartitionsRDD [528] run at <unknown>:0"]; } subgraph cluster1197 { label="WholeStageCodegen (1)"; 536 [labelType="html" label="MapPartitionsRDD [536] toJavaRDD at <unknown>:0"]; } subgraph cluster1196 { label="Filter"; 537 [labelType="html" label="MapPartitionsRDD [537] toJavaRDD at <unknown>:0"]; } subgraph cluster1195 { label="Project"; 538 [labelType="html" label="MapPartitionsRDD [538] toJavaRDD at <unknown>:0"]; } subgraph cluster1192 { label="WholeStageCodegen (2)"; 539 [labelType="html" label="MapPartitionsRDD [539] toJavaRDD at <unknown>:0"]; } subgraph cluster1191 { label="Project"; 540 [labelType="html" label="MapPartitionsRDD [540] toJavaRDD at <unknown>:0"]; } subgraph cluster1190 { label="DeserializeToObject"; 541 [labelType="html" label="MapPartitionsRDD [541] toJavaRDD at <unknown>:0"]; } subgraph cluster1189 { label="MapPartitions"; 542 [labelType="html" label="MapPartitionsRDD [542] toJavaRDD at <unknown>:0"]; } subgraph cluster1199 { label="mapPartitions"; 544 [labelType="html" label="MapPartitionsRDD [544] toJavaRDD at <unknown>:0"]; } } 525->526; 526->527; 527->528; 528->529; 529->536; 536->537; 537->538; 538->539; 539->540; 540->541; 541->542; 542->543; 543->544; 544->545; }

Event Timeline

Enable zooming