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

digraph G { subgraph clusterstage_1653 { label="Stage 1653"; 17372 [labelType="html" label="SQLExecutionRDD [17372] run at <unknown>:0"]; 17380 [labelType="html" label="SQLExecutionRDD [17380] toJavaRDD at <unknown>:0"]; 17382 [labelType="html" label="PythonRDD [17382] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38870 { label="MicroBatchScan"; 17368 [labelType="html" label="DataSourceRDD [17368] run at <unknown>:0"]; 17369 [labelType="html" label="MapPartitionsRDD [17369] run at <unknown>:0"]; } subgraph cluster38869 { label="Project"; 17370 [labelType="html" label="MapPartitionsRDD [17370] run at <unknown>:0"]; } subgraph cluster38865 { label="WholeStageCodegen (1)"; 17371 [labelType="html" label="MapPartitionsRDD [17371] run at <unknown>:0"]; } subgraph cluster38879 { label="WholeStageCodegen (1)"; 17373 [labelType="html" label="MapPartitionsRDD [17373] toJavaRDD at <unknown>:0"]; } subgraph cluster38878 { label="Filter"; 17374 [labelType="html" label="MapPartitionsRDD [17374] toJavaRDD at <unknown>:0"]; } subgraph cluster38877 { label="Project"; 17375 [labelType="html" label="MapPartitionsRDD [17375] toJavaRDD at <unknown>:0"]; } subgraph cluster38874 { label="WholeStageCodegen (2)"; 17376 [labelType="html" label="MapPartitionsRDD [17376] toJavaRDD at <unknown>:0"]; } subgraph cluster38873 { label="Project"; 17377 [labelType="html" label="MapPartitionsRDD [17377] toJavaRDD at <unknown>:0"]; } subgraph cluster38872 { label="DeserializeToObject"; 17378 [labelType="html" label="MapPartitionsRDD [17378] toJavaRDD at <unknown>:0"]; } subgraph cluster38871 { label="MapPartitions"; 17379 [labelType="html" label="MapPartitionsRDD [17379] toJavaRDD at <unknown>:0"]; } subgraph cluster38881 { label="mapPartitions"; 17381 [labelType="html" label="MapPartitionsRDD [17381] toJavaRDD at <unknown>:0"]; } } 17368->17369; 17369->17370; 17370->17371; 17371->17372; 17372->17373; 17373->17374; 17374->17375; 17375->17376; 17376->17377; 17377->17378; 17378->17379; 17379->17380; 17380->17381; 17381->17382; }

Event Timeline

Enable zooming