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

digraph G { subgraph clusterstage_1774 { label="Stage 1774"; 18631 [labelType="html" label="SQLExecutionRDD [18631] run at <unknown>:0"]; 18639 [labelType="html" label="SQLExecutionRDD [18639] toJavaRDD at <unknown>:0"]; 18641 [labelType="html" label="PythonRDD [18641] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41694 { label="MicroBatchScan"; 18627 [labelType="html" label="DataSourceRDD [18627] run at <unknown>:0"]; 18628 [labelType="html" label="MapPartitionsRDD [18628] run at <unknown>:0"]; } subgraph cluster41693 { label="Project"; 18629 [labelType="html" label="MapPartitionsRDD [18629] run at <unknown>:0"]; } subgraph cluster41689 { label="WholeStageCodegen (1)"; 18630 [labelType="html" label="MapPartitionsRDD [18630] run at <unknown>:0"]; } subgraph cluster41703 { label="WholeStageCodegen (1)"; 18632 [labelType="html" label="MapPartitionsRDD [18632] toJavaRDD at <unknown>:0"]; } subgraph cluster41702 { label="Filter"; 18633 [labelType="html" label="MapPartitionsRDD [18633] toJavaRDD at <unknown>:0"]; } subgraph cluster41701 { label="Project"; 18634 [labelType="html" label="MapPartitionsRDD [18634] toJavaRDD at <unknown>:0"]; } subgraph cluster41698 { label="WholeStageCodegen (2)"; 18635 [labelType="html" label="MapPartitionsRDD [18635] toJavaRDD at <unknown>:0"]; } subgraph cluster41697 { label="Project"; 18636 [labelType="html" label="MapPartitionsRDD [18636] toJavaRDD at <unknown>:0"]; } subgraph cluster41696 { label="DeserializeToObject"; 18637 [labelType="html" label="MapPartitionsRDD [18637] toJavaRDD at <unknown>:0"]; } subgraph cluster41695 { label="MapPartitions"; 18638 [labelType="html" label="MapPartitionsRDD [18638] toJavaRDD at <unknown>:0"]; } subgraph cluster41705 { label="mapPartitions"; 18640 [labelType="html" label="MapPartitionsRDD [18640] toJavaRDD at <unknown>:0"]; } } 18627->18628; 18628->18629; 18629->18630; 18630->18631; 18631->18632; 18632->18633; 18633->18634; 18634->18635; 18635->18636; 18636->18637; 18637->18638; 18638->18639; 18639->18640; 18640->18641; }

Event Timeline

Enable zooming