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

digraph G { subgraph clusterstage_1977 { label="Stage 1977"; 20774 [labelType="html" label="SQLExecutionRDD [20774] run at <unknown>:0"]; 20782 [labelType="html" label="SQLExecutionRDD [20782] toJavaRDD at <unknown>:0"]; 20784 [labelType="html" label="PythonRDD [20784] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46484 { label="MicroBatchScan"; 20770 [labelType="html" label="DataSourceRDD [20770] run at <unknown>:0"]; 20771 [labelType="html" label="MapPartitionsRDD [20771] run at <unknown>:0"]; } subgraph cluster46483 { label="Project"; 20772 [labelType="html" label="MapPartitionsRDD [20772] run at <unknown>:0"]; } subgraph cluster46479 { label="WholeStageCodegen (1)"; 20773 [labelType="html" label="MapPartitionsRDD [20773] run at <unknown>:0"]; } subgraph cluster46493 { label="WholeStageCodegen (1)"; 20775 [labelType="html" label="MapPartitionsRDD [20775] toJavaRDD at <unknown>:0"]; } subgraph cluster46492 { label="Filter"; 20776 [labelType="html" label="MapPartitionsRDD [20776] toJavaRDD at <unknown>:0"]; } subgraph cluster46491 { label="Project"; 20777 [labelType="html" label="MapPartitionsRDD [20777] toJavaRDD at <unknown>:0"]; } subgraph cluster46488 { label="WholeStageCodegen (2)"; 20778 [labelType="html" label="MapPartitionsRDD [20778] toJavaRDD at <unknown>:0"]; } subgraph cluster46487 { label="Project"; 20779 [labelType="html" label="MapPartitionsRDD [20779] toJavaRDD at <unknown>:0"]; } subgraph cluster46486 { label="DeserializeToObject"; 20780 [labelType="html" label="MapPartitionsRDD [20780] toJavaRDD at <unknown>:0"]; } subgraph cluster46485 { label="MapPartitions"; 20781 [labelType="html" label="MapPartitionsRDD [20781] toJavaRDD at <unknown>:0"]; } subgraph cluster46495 { label="mapPartitions"; 20783 [labelType="html" label="MapPartitionsRDD [20783] toJavaRDD at <unknown>:0"]; } } 20770->20771; 20771->20772; 20772->20773; 20773->20774; 20774->20775; 20775->20776; 20776->20777; 20777->20778; 20778->20779; 20779->20780; 20780->20781; 20781->20782; 20782->20783; 20783->20784; }

Event Timeline

Enable zooming