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

digraph G { subgraph clusterstage_1267 { label="Stage 1267"; 13303 [labelType="html" label="SQLExecutionRDD [13303] run at <unknown>:0"]; 13311 [labelType="html" label="SQLExecutionRDD [13311] toJavaRDD at <unknown>:0"]; 13313 [labelType="html" label="PythonRDD [13313] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29764 { label="MicroBatchScan"; 13299 [labelType="html" label="DataSourceRDD [13299] run at <unknown>:0"]; 13300 [labelType="html" label="MapPartitionsRDD [13300] run at <unknown>:0"]; } subgraph cluster29763 { label="Project"; 13301 [labelType="html" label="MapPartitionsRDD [13301] run at <unknown>:0"]; } subgraph cluster29759 { label="WholeStageCodegen (1)"; 13302 [labelType="html" label="MapPartitionsRDD [13302] run at <unknown>:0"]; } subgraph cluster29773 { label="WholeStageCodegen (1)"; 13304 [labelType="html" label="MapPartitionsRDD [13304] toJavaRDD at <unknown>:0"]; } subgraph cluster29772 { label="Filter"; 13305 [labelType="html" label="MapPartitionsRDD [13305] toJavaRDD at <unknown>:0"]; } subgraph cluster29771 { label="Project"; 13306 [labelType="html" label="MapPartitionsRDD [13306] toJavaRDD at <unknown>:0"]; } subgraph cluster29768 { label="WholeStageCodegen (2)"; 13307 [labelType="html" label="MapPartitionsRDD [13307] toJavaRDD at <unknown>:0"]; } subgraph cluster29767 { label="Project"; 13308 [labelType="html" label="MapPartitionsRDD [13308] toJavaRDD at <unknown>:0"]; } subgraph cluster29766 { label="DeserializeToObject"; 13309 [labelType="html" label="MapPartitionsRDD [13309] toJavaRDD at <unknown>:0"]; } subgraph cluster29765 { label="MapPartitions"; 13310 [labelType="html" label="MapPartitionsRDD [13310] toJavaRDD at <unknown>:0"]; } subgraph cluster29775 { label="mapPartitions"; 13312 [labelType="html" label="MapPartitionsRDD [13312] toJavaRDD at <unknown>:0"]; } } 13299->13300; 13300->13301; 13301->13302; 13302->13303; 13303->13304; 13304->13305; 13305->13306; 13306->13307; 13307->13308; 13308->13309; 13309->13310; 13310->13311; 13311->13312; 13312->13313; }

Event Timeline

Enable zooming