processing-stream-kafka-raw-to-minio - Details for Stage 606 (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 / 333
Associated Job Ids: 607

digraph G { subgraph clusterstage_606 { label="Stage 606"; 6374 [labelType="html" label="SQLExecutionRDD [6374] run at <unknown>:0"]; 6382 [labelType="html" label="SQLExecutionRDD [6382] toJavaRDD at <unknown>:0"]; 6384 [labelType="html" label="PythonRDD [6384] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14250 { label="MicroBatchScan"; 6370 [labelType="html" label="DataSourceRDD [6370] run at <unknown>:0"]; 6371 [labelType="html" label="MapPartitionsRDD [6371] run at <unknown>:0"]; } subgraph cluster14249 { label="Project"; 6372 [labelType="html" label="MapPartitionsRDD [6372] run at <unknown>:0"]; } subgraph cluster14245 { label="WholeStageCodegen (1)"; 6373 [labelType="html" label="MapPartitionsRDD [6373] run at <unknown>:0"]; } subgraph cluster14259 { label="WholeStageCodegen (1)"; 6375 [labelType="html" label="MapPartitionsRDD [6375] toJavaRDD at <unknown>:0"]; } subgraph cluster14258 { label="Filter"; 6376 [labelType="html" label="MapPartitionsRDD [6376] toJavaRDD at <unknown>:0"]; } subgraph cluster14257 { label="Project"; 6377 [labelType="html" label="MapPartitionsRDD [6377] toJavaRDD at <unknown>:0"]; } subgraph cluster14254 { label="WholeStageCodegen (2)"; 6378 [labelType="html" label="MapPartitionsRDD [6378] toJavaRDD at <unknown>:0"]; } subgraph cluster14253 { label="Project"; 6379 [labelType="html" label="MapPartitionsRDD [6379] toJavaRDD at <unknown>:0"]; } subgraph cluster14252 { label="DeserializeToObject"; 6380 [labelType="html" label="MapPartitionsRDD [6380] toJavaRDD at <unknown>:0"]; } subgraph cluster14251 { label="MapPartitions"; 6381 [labelType="html" label="MapPartitionsRDD [6381] toJavaRDD at <unknown>:0"]; } subgraph cluster14261 { label="mapPartitions"; 6383 [labelType="html" label="MapPartitionsRDD [6383] toJavaRDD at <unknown>:0"]; } } 6370->6371; 6371->6372; 6372->6373; 6373->6374; 6374->6375; 6375->6376; 6376->6377; 6377->6378; 6378->6379; 6379->6380; 6380->6381; 6381->6382; 6382->6383; 6383->6384; }

Event Timeline

Enable zooming