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

digraph G { subgraph clusterstage_1345 { label="Stage 1345"; 14116 [labelType="html" label="SQLExecutionRDD [14116] run at <unknown>:0"]; 14130 [labelType="html" label="SQLExecutionRDD [14130] toJavaRDD at <unknown>:0"]; 14132 [labelType="html" label="PythonRDD [14132] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31589 { label="MicroBatchScan"; 14112 [labelType="html" label="DataSourceRDD [14112] run at <unknown>:0"]; 14113 [labelType="html" label="MapPartitionsRDD [14113] run at <unknown>:0"]; } subgraph cluster31588 { label="Project"; 14114 [labelType="html" label="MapPartitionsRDD [14114] run at <unknown>:0"]; } subgraph cluster31584 { label="WholeStageCodegen (1)"; 14115 [labelType="html" label="MapPartitionsRDD [14115] run at <unknown>:0"]; } subgraph cluster31606 { label="WholeStageCodegen (1)"; 14123 [labelType="html" label="MapPartitionsRDD [14123] toJavaRDD at <unknown>:0"]; } subgraph cluster31605 { label="Filter"; 14124 [labelType="html" label="MapPartitionsRDD [14124] toJavaRDD at <unknown>:0"]; } subgraph cluster31604 { label="Project"; 14125 [labelType="html" label="MapPartitionsRDD [14125] toJavaRDD at <unknown>:0"]; } subgraph cluster31601 { label="WholeStageCodegen (2)"; 14126 [labelType="html" label="MapPartitionsRDD [14126] toJavaRDD at <unknown>:0"]; } subgraph cluster31600 { label="Project"; 14127 [labelType="html" label="MapPartitionsRDD [14127] toJavaRDD at <unknown>:0"]; } subgraph cluster31599 { label="DeserializeToObject"; 14128 [labelType="html" label="MapPartitionsRDD [14128] toJavaRDD at <unknown>:0"]; } subgraph cluster31598 { label="MapPartitions"; 14129 [labelType="html" label="MapPartitionsRDD [14129] toJavaRDD at <unknown>:0"]; } subgraph cluster31608 { label="mapPartitions"; 14131 [labelType="html" label="MapPartitionsRDD [14131] toJavaRDD at <unknown>:0"]; } } 14112->14113; 14113->14114; 14114->14115; 14115->14116; 14116->14123; 14123->14124; 14124->14125; 14125->14126; 14126->14127; 14127->14128; 14128->14129; 14129->14130; 14130->14131; 14131->14132; }

Event Timeline

Enable zooming