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

digraph G { subgraph clusterstage_1178 { label="Stage 1178"; 12374 [labelType="html" label="SQLExecutionRDD [12374] run at <unknown>:0"]; 12388 [labelType="html" label="SQLExecutionRDD [12388] toJavaRDD at <unknown>:0"]; 12390 [labelType="html" label="PythonRDD [12390] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster27684 { label="MicroBatchScan"; 12370 [labelType="html" label="DataSourceRDD [12370] run at <unknown>:0"]; 12371 [labelType="html" label="MapPartitionsRDD [12371] run at <unknown>:0"]; } subgraph cluster27683 { label="Project"; 12372 [labelType="html" label="MapPartitionsRDD [12372] run at <unknown>:0"]; } subgraph cluster27679 { label="WholeStageCodegen (1)"; 12373 [labelType="html" label="MapPartitionsRDD [12373] run at <unknown>:0"]; } subgraph cluster27701 { label="WholeStageCodegen (1)"; 12381 [labelType="html" label="MapPartitionsRDD [12381] toJavaRDD at <unknown>:0"]; } subgraph cluster27700 { label="Filter"; 12382 [labelType="html" label="MapPartitionsRDD [12382] toJavaRDD at <unknown>:0"]; } subgraph cluster27699 { label="Project"; 12383 [labelType="html" label="MapPartitionsRDD [12383] toJavaRDD at <unknown>:0"]; } subgraph cluster27696 { label="WholeStageCodegen (2)"; 12384 [labelType="html" label="MapPartitionsRDD [12384] toJavaRDD at <unknown>:0"]; } subgraph cluster27695 { label="Project"; 12385 [labelType="html" label="MapPartitionsRDD [12385] toJavaRDD at <unknown>:0"]; } subgraph cluster27694 { label="DeserializeToObject"; 12386 [labelType="html" label="MapPartitionsRDD [12386] toJavaRDD at <unknown>:0"]; } subgraph cluster27693 { label="MapPartitions"; 12387 [labelType="html" label="MapPartitionsRDD [12387] toJavaRDD at <unknown>:0"]; } subgraph cluster27703 { label="mapPartitions"; 12389 [labelType="html" label="MapPartitionsRDD [12389] toJavaRDD at <unknown>:0"]; } } 12370->12371; 12371->12372; 12372->12373; 12373->12374; 12374->12381; 12381->12382; 12382->12383; 12383->12384; 12384->12385; 12385->12386; 12386->12387; 12387->12388; 12388->12389; 12389->12390; }

Event Timeline

Enable zooming