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

digraph G { subgraph clusterstage_1199 { label="Stage 1199"; 12605 [labelType="html" label="SQLExecutionRDD [12605] run at <unknown>:0"]; 12613 [labelType="html" label="SQLExecutionRDD [12613] toJavaRDD at <unknown>:0"]; 12615 [labelType="html" label="PythonRDD [12615] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28201 { label="MicroBatchScan"; 12601 [labelType="html" label="DataSourceRDD [12601] run at <unknown>:0"]; 12602 [labelType="html" label="MapPartitionsRDD [12602] run at <unknown>:0"]; } subgraph cluster28200 { label="Project"; 12603 [labelType="html" label="MapPartitionsRDD [12603] run at <unknown>:0"]; } subgraph cluster28196 { label="WholeStageCodegen (1)"; 12604 [labelType="html" label="MapPartitionsRDD [12604] run at <unknown>:0"]; } subgraph cluster28210 { label="WholeStageCodegen (1)"; 12606 [labelType="html" label="MapPartitionsRDD [12606] toJavaRDD at <unknown>:0"]; } subgraph cluster28209 { label="Filter"; 12607 [labelType="html" label="MapPartitionsRDD [12607] toJavaRDD at <unknown>:0"]; } subgraph cluster28208 { label="Project"; 12608 [labelType="html" label="MapPartitionsRDD [12608] toJavaRDD at <unknown>:0"]; } subgraph cluster28205 { label="WholeStageCodegen (2)"; 12609 [labelType="html" label="MapPartitionsRDD [12609] toJavaRDD at <unknown>:0"]; } subgraph cluster28204 { label="Project"; 12610 [labelType="html" label="MapPartitionsRDD [12610] toJavaRDD at <unknown>:0"]; } subgraph cluster28203 { label="DeserializeToObject"; 12611 [labelType="html" label="MapPartitionsRDD [12611] toJavaRDD at <unknown>:0"]; } subgraph cluster28202 { label="MapPartitions"; 12612 [labelType="html" label="MapPartitionsRDD [12612] toJavaRDD at <unknown>:0"]; } subgraph cluster28212 { label="mapPartitions"; 12614 [labelType="html" label="MapPartitionsRDD [12614] toJavaRDD at <unknown>:0"]; } } 12601->12602; 12602->12603; 12603->12604; 12604->12605; 12605->12606; 12606->12607; 12607->12608; 12608->12609; 12609->12610; 12610->12611; 12611->12612; 12612->12613; 12613->12614; 12614->12615; }

Event Timeline

Enable zooming