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

digraph G { subgraph clusterstage_358 { label="Stage 358"; 3763 [labelType="html" label="SQLExecutionRDD [3763] run at <unknown>:0"]; 3771 [labelType="html" label="SQLExecutionRDD [3771] toJavaRDD at <unknown>:0"]; 3773 [labelType="html" label="PythonRDD [3773] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8418 { label="MicroBatchScan"; 3759 [labelType="html" label="DataSourceRDD [3759] run at <unknown>:0"]; 3760 [labelType="html" label="MapPartitionsRDD [3760] run at <unknown>:0"]; } subgraph cluster8417 { label="Project"; 3761 [labelType="html" label="MapPartitionsRDD [3761] run at <unknown>:0"]; } subgraph cluster8413 { label="WholeStageCodegen (1)"; 3762 [labelType="html" label="MapPartitionsRDD [3762] run at <unknown>:0"]; } subgraph cluster8427 { label="WholeStageCodegen (1)"; 3764 [labelType="html" label="MapPartitionsRDD [3764] toJavaRDD at <unknown>:0"]; } subgraph cluster8426 { label="Filter"; 3765 [labelType="html" label="MapPartitionsRDD [3765] toJavaRDD at <unknown>:0"]; } subgraph cluster8425 { label="Project"; 3766 [labelType="html" label="MapPartitionsRDD [3766] toJavaRDD at <unknown>:0"]; } subgraph cluster8422 { label="WholeStageCodegen (2)"; 3767 [labelType="html" label="MapPartitionsRDD [3767] toJavaRDD at <unknown>:0"]; } subgraph cluster8421 { label="Project"; 3768 [labelType="html" label="MapPartitionsRDD [3768] toJavaRDD at <unknown>:0"]; } subgraph cluster8420 { label="DeserializeToObject"; 3769 [labelType="html" label="MapPartitionsRDD [3769] toJavaRDD at <unknown>:0"]; } subgraph cluster8419 { label="MapPartitions"; 3770 [labelType="html" label="MapPartitionsRDD [3770] toJavaRDD at <unknown>:0"]; } subgraph cluster8429 { label="mapPartitions"; 3772 [labelType="html" label="MapPartitionsRDD [3772] toJavaRDD at <unknown>:0"]; } } 3759->3760; 3760->3761; 3761->3762; 3762->3763; 3763->3764; 3764->3765; 3765->3766; 3766->3767; 3767->3768; 3768->3769; 3769->3770; 3770->3771; 3771->3772; 3772->3773; }

Event Timeline

Enable zooming