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

digraph G { subgraph clusterstage_1749 { label="Stage 1749"; 18358 [labelType="html" label="SQLExecutionRDD [18358] run at <unknown>:0"]; 18372 [labelType="html" label="SQLExecutionRDD [18372] toJavaRDD at <unknown>:0"]; 18374 [labelType="html" label="PythonRDD [18374] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41083 { label="MicroBatchScan"; 18354 [labelType="html" label="DataSourceRDD [18354] run at <unknown>:0"]; 18355 [labelType="html" label="MapPartitionsRDD [18355] run at <unknown>:0"]; } subgraph cluster41082 { label="Project"; 18356 [labelType="html" label="MapPartitionsRDD [18356] run at <unknown>:0"]; } subgraph cluster41078 { label="WholeStageCodegen (1)"; 18357 [labelType="html" label="MapPartitionsRDD [18357] run at <unknown>:0"]; } subgraph cluster41100 { label="WholeStageCodegen (1)"; 18365 [labelType="html" label="MapPartitionsRDD [18365] toJavaRDD at <unknown>:0"]; } subgraph cluster41099 { label="Filter"; 18366 [labelType="html" label="MapPartitionsRDD [18366] toJavaRDD at <unknown>:0"]; } subgraph cluster41098 { label="Project"; 18367 [labelType="html" label="MapPartitionsRDD [18367] toJavaRDD at <unknown>:0"]; } subgraph cluster41093 { label="WholeStageCodegen (2)"; 18368 [labelType="html" label="MapPartitionsRDD [18368] toJavaRDD at <unknown>:0"]; } subgraph cluster41092 { label="Project"; 18369 [labelType="html" label="MapPartitionsRDD [18369] toJavaRDD at <unknown>:0"]; } subgraph cluster41091 { label="DeserializeToObject"; 18370 [labelType="html" label="MapPartitionsRDD [18370] toJavaRDD at <unknown>:0"]; } subgraph cluster41090 { label="MapPartitions"; 18371 [labelType="html" label="MapPartitionsRDD [18371] toJavaRDD at <unknown>:0"]; } subgraph cluster41102 { label="mapPartitions"; 18373 [labelType="html" label="MapPartitionsRDD [18373] toJavaRDD at <unknown>:0"]; } } 18354->18355; 18355->18356; 18356->18357; 18357->18358; 18358->18365; 18365->18366; 18366->18367; 18367->18368; 18368->18369; 18369->18370; 18370->18371; 18371->18372; 18372->18373; 18373->18374; }

Event Timeline

Enable zooming