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

digraph G { subgraph clusterstage_1770 { label="Stage 1770"; 18589 [labelType="html" label="SQLExecutionRDD [18589] run at <unknown>:0"]; 18597 [labelType="html" label="SQLExecutionRDD [18597] toJavaRDD at <unknown>:0"]; 18599 [labelType="html" label="PythonRDD [18599] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41600 { label="MicroBatchScan"; 18585 [labelType="html" label="DataSourceRDD [18585] run at <unknown>:0"]; 18586 [labelType="html" label="MapPartitionsRDD [18586] run at <unknown>:0"]; } subgraph cluster41599 { label="Project"; 18587 [labelType="html" label="MapPartitionsRDD [18587] run at <unknown>:0"]; } subgraph cluster41595 { label="WholeStageCodegen (1)"; 18588 [labelType="html" label="MapPartitionsRDD [18588] run at <unknown>:0"]; } subgraph cluster41609 { label="WholeStageCodegen (1)"; 18590 [labelType="html" label="MapPartitionsRDD [18590] toJavaRDD at <unknown>:0"]; } subgraph cluster41608 { label="Filter"; 18591 [labelType="html" label="MapPartitionsRDD [18591] toJavaRDD at <unknown>:0"]; } subgraph cluster41607 { label="Project"; 18592 [labelType="html" label="MapPartitionsRDD [18592] toJavaRDD at <unknown>:0"]; } subgraph cluster41604 { label="WholeStageCodegen (2)"; 18593 [labelType="html" label="MapPartitionsRDD [18593] toJavaRDD at <unknown>:0"]; } subgraph cluster41603 { label="Project"; 18594 [labelType="html" label="MapPartitionsRDD [18594] toJavaRDD at <unknown>:0"]; } subgraph cluster41602 { label="DeserializeToObject"; 18595 [labelType="html" label="MapPartitionsRDD [18595] toJavaRDD at <unknown>:0"]; } subgraph cluster41601 { label="MapPartitions"; 18596 [labelType="html" label="MapPartitionsRDD [18596] toJavaRDD at <unknown>:0"]; } subgraph cluster41611 { label="mapPartitions"; 18598 [labelType="html" label="MapPartitionsRDD [18598] toJavaRDD at <unknown>:0"]; } } 18585->18586; 18586->18587; 18587->18588; 18588->18589; 18589->18590; 18590->18591; 18591->18592; 18592->18593; 18593->18594; 18594->18595; 18595->18596; 18596->18597; 18597->18598; 18598->18599; }

Event Timeline

Enable zooming