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

digraph G { subgraph clusterstage_987 { label="Stage 987"; 10379 [labelType="html" label="SQLExecutionRDD [10379] run at <unknown>:0"]; 10387 [labelType="html" label="SQLExecutionRDD [10387] toJavaRDD at <unknown>:0"]; 10389 [labelType="html" label="PythonRDD [10389] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23219 { label="MicroBatchScan"; 10375 [labelType="html" label="DataSourceRDD [10375] run at <unknown>:0"]; 10376 [labelType="html" label="MapPartitionsRDD [10376] run at <unknown>:0"]; } subgraph cluster23218 { label="Project"; 10377 [labelType="html" label="MapPartitionsRDD [10377] run at <unknown>:0"]; } subgraph cluster23214 { label="WholeStageCodegen (1)"; 10378 [labelType="html" label="MapPartitionsRDD [10378] run at <unknown>:0"]; } subgraph cluster23228 { label="WholeStageCodegen (1)"; 10380 [labelType="html" label="MapPartitionsRDD [10380] toJavaRDD at <unknown>:0"]; } subgraph cluster23227 { label="Filter"; 10381 [labelType="html" label="MapPartitionsRDD [10381] toJavaRDD at <unknown>:0"]; } subgraph cluster23226 { label="Project"; 10382 [labelType="html" label="MapPartitionsRDD [10382] toJavaRDD at <unknown>:0"]; } subgraph cluster23223 { label="WholeStageCodegen (2)"; 10383 [labelType="html" label="MapPartitionsRDD [10383] toJavaRDD at <unknown>:0"]; } subgraph cluster23222 { label="Project"; 10384 [labelType="html" label="MapPartitionsRDD [10384] toJavaRDD at <unknown>:0"]; } subgraph cluster23221 { label="DeserializeToObject"; 10385 [labelType="html" label="MapPartitionsRDD [10385] toJavaRDD at <unknown>:0"]; } subgraph cluster23220 { label="MapPartitions"; 10386 [labelType="html" label="MapPartitionsRDD [10386] toJavaRDD at <unknown>:0"]; } subgraph cluster23230 { label="mapPartitions"; 10388 [labelType="html" label="MapPartitionsRDD [10388] toJavaRDD at <unknown>:0"]; } } 10375->10376; 10376->10377; 10377->10378; 10378->10379; 10379->10380; 10380->10381; 10381->10382; 10382->10383; 10383->10384; 10384->10385; 10385->10386; 10386->10387; 10387->10388; 10388->10389; }

Event Timeline

Enable zooming