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

digraph G { subgraph clusterstage_1727 { label="Stage 1727"; 18127 [labelType="html" label="SQLExecutionRDD [18127] run at <unknown>:0"]; 18141 [labelType="html" label="SQLExecutionRDD [18141] toJavaRDD at <unknown>:0"]; 18143 [labelType="html" label="PythonRDD [18143] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40566 { label="MicroBatchScan"; 18123 [labelType="html" label="DataSourceRDD [18123] run at <unknown>:0"]; 18124 [labelType="html" label="MapPartitionsRDD [18124] run at <unknown>:0"]; } subgraph cluster40565 { label="Project"; 18125 [labelType="html" label="MapPartitionsRDD [18125] run at <unknown>:0"]; } subgraph cluster40561 { label="WholeStageCodegen (1)"; 18126 [labelType="html" label="MapPartitionsRDD [18126] run at <unknown>:0"]; } subgraph cluster40583 { label="WholeStageCodegen (1)"; 18134 [labelType="html" label="MapPartitionsRDD [18134] toJavaRDD at <unknown>:0"]; } subgraph cluster40582 { label="Filter"; 18135 [labelType="html" label="MapPartitionsRDD [18135] toJavaRDD at <unknown>:0"]; } subgraph cluster40581 { label="Project"; 18136 [labelType="html" label="MapPartitionsRDD [18136] toJavaRDD at <unknown>:0"]; } subgraph cluster40578 { label="WholeStageCodegen (2)"; 18137 [labelType="html" label="MapPartitionsRDD [18137] toJavaRDD at <unknown>:0"]; } subgraph cluster40577 { label="Project"; 18138 [labelType="html" label="MapPartitionsRDD [18138] toJavaRDD at <unknown>:0"]; } subgraph cluster40576 { label="DeserializeToObject"; 18139 [labelType="html" label="MapPartitionsRDD [18139] toJavaRDD at <unknown>:0"]; } subgraph cluster40575 { label="MapPartitions"; 18140 [labelType="html" label="MapPartitionsRDD [18140] toJavaRDD at <unknown>:0"]; } subgraph cluster40585 { label="mapPartitions"; 18142 [labelType="html" label="MapPartitionsRDD [18142] toJavaRDD at <unknown>:0"]; } } 18123->18124; 18124->18125; 18125->18126; 18126->18127; 18127->18134; 18134->18135; 18135->18136; 18136->18137; 18137->18138; 18138->18139; 18139->18140; 18140->18141; 18141->18142; 18142->18143; }

Event Timeline

Enable zooming