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

digraph G { subgraph clusterstage_1882 { label="Stage 1882"; 19765 [labelType="html" label="SQLExecutionRDD [19765] run at <unknown>:0"]; 19773 [labelType="html" label="SQLExecutionRDD [19773] toJavaRDD at <unknown>:0"]; 19775 [labelType="html" label="PythonRDD [19775] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44232 { label="MicroBatchScan"; 19761 [labelType="html" label="DataSourceRDD [19761] run at <unknown>:0"]; 19762 [labelType="html" label="MapPartitionsRDD [19762] run at <unknown>:0"]; } subgraph cluster44231 { label="Project"; 19763 [labelType="html" label="MapPartitionsRDD [19763] run at <unknown>:0"]; } subgraph cluster44227 { label="WholeStageCodegen (1)"; 19764 [labelType="html" label="MapPartitionsRDD [19764] run at <unknown>:0"]; } subgraph cluster44241 { label="WholeStageCodegen (1)"; 19766 [labelType="html" label="MapPartitionsRDD [19766] toJavaRDD at <unknown>:0"]; } subgraph cluster44240 { label="Filter"; 19767 [labelType="html" label="MapPartitionsRDD [19767] toJavaRDD at <unknown>:0"]; } subgraph cluster44239 { label="Project"; 19768 [labelType="html" label="MapPartitionsRDD [19768] toJavaRDD at <unknown>:0"]; } subgraph cluster44236 { label="WholeStageCodegen (2)"; 19769 [labelType="html" label="MapPartitionsRDD [19769] toJavaRDD at <unknown>:0"]; } subgraph cluster44235 { label="Project"; 19770 [labelType="html" label="MapPartitionsRDD [19770] toJavaRDD at <unknown>:0"]; } subgraph cluster44234 { label="DeserializeToObject"; 19771 [labelType="html" label="MapPartitionsRDD [19771] toJavaRDD at <unknown>:0"]; } subgraph cluster44233 { label="MapPartitions"; 19772 [labelType="html" label="MapPartitionsRDD [19772] toJavaRDD at <unknown>:0"]; } subgraph cluster44243 { label="mapPartitions"; 19774 [labelType="html" label="MapPartitionsRDD [19774] toJavaRDD at <unknown>:0"]; } } 19761->19762; 19762->19763; 19763->19764; 19764->19765; 19765->19766; 19766->19767; 19767->19768; 19768->19769; 19769->19770; 19770->19771; 19771->19772; 19772->19773; 19773->19774; 19774->19775; }

Event Timeline

Enable zooming