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

digraph G { subgraph clusterstage_1866 { label="Stage 1866"; 19597 [labelType="html" label="SQLExecutionRDD [19597] run at <unknown>:0"]; 19605 [labelType="html" label="SQLExecutionRDD [19605] toJavaRDD at <unknown>:0"]; 19607 [labelType="html" label="PythonRDD [19607] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43856 { label="MicroBatchScan"; 19593 [labelType="html" label="DataSourceRDD [19593] run at <unknown>:0"]; 19594 [labelType="html" label="MapPartitionsRDD [19594] run at <unknown>:0"]; } subgraph cluster43855 { label="Project"; 19595 [labelType="html" label="MapPartitionsRDD [19595] run at <unknown>:0"]; } subgraph cluster43851 { label="WholeStageCodegen (1)"; 19596 [labelType="html" label="MapPartitionsRDD [19596] run at <unknown>:0"]; } subgraph cluster43865 { label="WholeStageCodegen (1)"; 19598 [labelType="html" label="MapPartitionsRDD [19598] toJavaRDD at <unknown>:0"]; } subgraph cluster43864 { label="Filter"; 19599 [labelType="html" label="MapPartitionsRDD [19599] toJavaRDD at <unknown>:0"]; } subgraph cluster43863 { label="Project"; 19600 [labelType="html" label="MapPartitionsRDD [19600] toJavaRDD at <unknown>:0"]; } subgraph cluster43860 { label="WholeStageCodegen (2)"; 19601 [labelType="html" label="MapPartitionsRDD [19601] toJavaRDD at <unknown>:0"]; } subgraph cluster43859 { label="Project"; 19602 [labelType="html" label="MapPartitionsRDD [19602] toJavaRDD at <unknown>:0"]; } subgraph cluster43858 { label="DeserializeToObject"; 19603 [labelType="html" label="MapPartitionsRDD [19603] toJavaRDD at <unknown>:0"]; } subgraph cluster43857 { label="MapPartitions"; 19604 [labelType="html" label="MapPartitionsRDD [19604] toJavaRDD at <unknown>:0"]; } subgraph cluster43867 { label="mapPartitions"; 19606 [labelType="html" label="MapPartitionsRDD [19606] toJavaRDD at <unknown>:0"]; } } 19593->19594; 19594->19595; 19595->19596; 19596->19597; 19597->19598; 19598->19599; 19599->19600; 19600->19601; 19601->19602; 19602->19603; 19603->19604; 19604->19605; 19605->19606; 19606->19607; }

Event Timeline

Enable zooming