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

digraph G { subgraph clusterstage_1968 { label="Stage 1968"; 20675 [labelType="html" label="SQLExecutionRDD [20675] run at <unknown>:0"]; 20683 [labelType="html" label="SQLExecutionRDD [20683] toJavaRDD at <unknown>:0"]; 20685 [labelType="html" label="PythonRDD [20685] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46257 { label="MicroBatchScan"; 20671 [labelType="html" label="DataSourceRDD [20671] run at <unknown>:0"]; 20672 [labelType="html" label="MapPartitionsRDD [20672] run at <unknown>:0"]; } subgraph cluster46256 { label="Project"; 20673 [labelType="html" label="MapPartitionsRDD [20673] run at <unknown>:0"]; } subgraph cluster46252 { label="WholeStageCodegen (1)"; 20674 [labelType="html" label="MapPartitionsRDD [20674] run at <unknown>:0"]; } subgraph cluster46266 { label="WholeStageCodegen (1)"; 20676 [labelType="html" label="MapPartitionsRDD [20676] toJavaRDD at <unknown>:0"]; } subgraph cluster46265 { label="Filter"; 20677 [labelType="html" label="MapPartitionsRDD [20677] toJavaRDD at <unknown>:0"]; } subgraph cluster46264 { label="Project"; 20678 [labelType="html" label="MapPartitionsRDD [20678] toJavaRDD at <unknown>:0"]; } subgraph cluster46261 { label="WholeStageCodegen (2)"; 20679 [labelType="html" label="MapPartitionsRDD [20679] toJavaRDD at <unknown>:0"]; } subgraph cluster46260 { label="Project"; 20680 [labelType="html" label="MapPartitionsRDD [20680] toJavaRDD at <unknown>:0"]; } subgraph cluster46259 { label="DeserializeToObject"; 20681 [labelType="html" label="MapPartitionsRDD [20681] toJavaRDD at <unknown>:0"]; } subgraph cluster46258 { label="MapPartitions"; 20682 [labelType="html" label="MapPartitionsRDD [20682] toJavaRDD at <unknown>:0"]; } subgraph cluster46268 { label="mapPartitions"; 20684 [labelType="html" label="MapPartitionsRDD [20684] toJavaRDD at <unknown>:0"]; } } 20671->20672; 20672->20673; 20673->20674; 20674->20675; 20675->20676; 20676->20677; 20677->20678; 20678->20679; 20679->20680; 20680->20681; 20681->20682; 20682->20683; 20683->20684; 20684->20685; }

Event Timeline

Enable zooming