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

digraph G { subgraph clusterstage_1196 { label="Stage 1196"; 12563 [labelType="html" label="SQLExecutionRDD [12563] run at <unknown>:0"]; 12577 [labelType="html" label="SQLExecutionRDD [12577] toJavaRDD at <unknown>:0"]; 12579 [labelType="html" label="PythonRDD [12579] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28107 { label="MicroBatchScan"; 12559 [labelType="html" label="DataSourceRDD [12559] run at <unknown>:0"]; 12560 [labelType="html" label="MapPartitionsRDD [12560] run at <unknown>:0"]; } subgraph cluster28106 { label="Project"; 12561 [labelType="html" label="MapPartitionsRDD [12561] run at <unknown>:0"]; } subgraph cluster28102 { label="WholeStageCodegen (1)"; 12562 [labelType="html" label="MapPartitionsRDD [12562] run at <unknown>:0"]; } subgraph cluster28124 { label="WholeStageCodegen (1)"; 12570 [labelType="html" label="MapPartitionsRDD [12570] toJavaRDD at <unknown>:0"]; } subgraph cluster28123 { label="Filter"; 12571 [labelType="html" label="MapPartitionsRDD [12571] toJavaRDD at <unknown>:0"]; } subgraph cluster28122 { label="Project"; 12572 [labelType="html" label="MapPartitionsRDD [12572] toJavaRDD at <unknown>:0"]; } subgraph cluster28119 { label="WholeStageCodegen (2)"; 12573 [labelType="html" label="MapPartitionsRDD [12573] toJavaRDD at <unknown>:0"]; } subgraph cluster28118 { label="Project"; 12574 [labelType="html" label="MapPartitionsRDD [12574] toJavaRDD at <unknown>:0"]; } subgraph cluster28117 { label="DeserializeToObject"; 12575 [labelType="html" label="MapPartitionsRDD [12575] toJavaRDD at <unknown>:0"]; } subgraph cluster28116 { label="MapPartitions"; 12576 [labelType="html" label="MapPartitionsRDD [12576] toJavaRDD at <unknown>:0"]; } subgraph cluster28126 { label="mapPartitions"; 12578 [labelType="html" label="MapPartitionsRDD [12578] toJavaRDD at <unknown>:0"]; } } 12559->12560; 12560->12561; 12561->12562; 12562->12563; 12563->12570; 12570->12571; 12571->12572; 12572->12573; 12573->12574; 12574->12575; 12575->12576; 12576->12577; 12577->12578; 12578->12579; }

Event Timeline

Enable zooming