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

digraph G { subgraph clusterstage_1633 { label="Stage 1633"; 17162 [labelType="html" label="SQLExecutionRDD [17162] run at <unknown>:0"]; 17170 [labelType="html" label="SQLExecutionRDD [17170] toJavaRDD at <unknown>:0"]; 17178 [labelType="html" label="PythonRDD [17178] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38400 { label="MicroBatchScan"; 17158 [labelType="html" label="DataSourceRDD [17158] run at <unknown>:0"]; 17159 [labelType="html" label="MapPartitionsRDD [17159] run at <unknown>:0"]; } subgraph cluster38399 { label="Project"; 17160 [labelType="html" label="MapPartitionsRDD [17160] run at <unknown>:0"]; } subgraph cluster38395 { label="WholeStageCodegen (1)"; 17161 [labelType="html" label="MapPartitionsRDD [17161] run at <unknown>:0"]; } subgraph cluster38409 { label="WholeStageCodegen (1)"; 17163 [labelType="html" label="MapPartitionsRDD [17163] toJavaRDD at <unknown>:0"]; } subgraph cluster38408 { label="Filter"; 17164 [labelType="html" label="MapPartitionsRDD [17164] toJavaRDD at <unknown>:0"]; } subgraph cluster38407 { label="Project"; 17165 [labelType="html" label="MapPartitionsRDD [17165] toJavaRDD at <unknown>:0"]; } subgraph cluster38404 { label="WholeStageCodegen (2)"; 17166 [labelType="html" label="MapPartitionsRDD [17166] toJavaRDD at <unknown>:0"]; } subgraph cluster38403 { label="Project"; 17167 [labelType="html" label="MapPartitionsRDD [17167] toJavaRDD at <unknown>:0"]; } subgraph cluster38402 { label="DeserializeToObject"; 17168 [labelType="html" label="MapPartitionsRDD [17168] toJavaRDD at <unknown>:0"]; } subgraph cluster38401 { label="MapPartitions"; 17169 [labelType="html" label="MapPartitionsRDD [17169] toJavaRDD at <unknown>:0"]; } subgraph cluster38411 { label="mapPartitions"; 17171 [labelType="html" label="MapPartitionsRDD [17171] toJavaRDD at <unknown>:0"]; } } 17158->17159; 17159->17160; 17160->17161; 17161->17162; 17162->17163; 17163->17164; 17164->17165; 17165->17166; 17166->17167; 17167->17168; 17168->17169; 17169->17170; 17170->17171; 17171->17178; }

Event Timeline

Enable zooming