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

digraph G { subgraph clusterstage_1827 { label="Stage 1827"; 19199 [labelType="html" label="SQLExecutionRDD [19199] run at <unknown>:0"]; 19207 [labelType="html" label="SQLExecutionRDD [19207] toJavaRDD at <unknown>:0"]; 19209 [labelType="html" label="PythonRDD [19209] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42959 { label="MicroBatchScan"; 19195 [labelType="html" label="DataSourceRDD [19195] run at <unknown>:0"]; 19196 [labelType="html" label="MapPartitionsRDD [19196] run at <unknown>:0"]; } subgraph cluster42958 { label="Project"; 19197 [labelType="html" label="MapPartitionsRDD [19197] run at <unknown>:0"]; } subgraph cluster42954 { label="WholeStageCodegen (1)"; 19198 [labelType="html" label="MapPartitionsRDD [19198] run at <unknown>:0"]; } subgraph cluster42968 { label="WholeStageCodegen (1)"; 19200 [labelType="html" label="MapPartitionsRDD [19200] toJavaRDD at <unknown>:0"]; } subgraph cluster42967 { label="Filter"; 19201 [labelType="html" label="MapPartitionsRDD [19201] toJavaRDD at <unknown>:0"]; } subgraph cluster42966 { label="Project"; 19202 [labelType="html" label="MapPartitionsRDD [19202] toJavaRDD at <unknown>:0"]; } subgraph cluster42963 { label="WholeStageCodegen (2)"; 19203 [labelType="html" label="MapPartitionsRDD [19203] toJavaRDD at <unknown>:0"]; } subgraph cluster42962 { label="Project"; 19204 [labelType="html" label="MapPartitionsRDD [19204] toJavaRDD at <unknown>:0"]; } subgraph cluster42961 { label="DeserializeToObject"; 19205 [labelType="html" label="MapPartitionsRDD [19205] toJavaRDD at <unknown>:0"]; } subgraph cluster42960 { label="MapPartitions"; 19206 [labelType="html" label="MapPartitionsRDD [19206] toJavaRDD at <unknown>:0"]; } subgraph cluster42970 { label="mapPartitions"; 19208 [labelType="html" label="MapPartitionsRDD [19208] toJavaRDD at <unknown>:0"]; } } 19195->19196; 19196->19197; 19197->19198; 19198->19199; 19199->19200; 19200->19201; 19201->19202; 19202->19203; 19203->19204; 19204->19205; 19205->19206; 19206->19207; 19207->19208; 19208->19209; }

Event Timeline

Enable zooming