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

digraph G { subgraph clusterstage_1744 { label="Stage 1744"; 18316 [labelType="html" label="SQLExecutionRDD [18316] run at <unknown>:0"]; 18324 [labelType="html" label="SQLExecutionRDD [18324] toJavaRDD at <unknown>:0"]; 18326 [labelType="html" label="PythonRDD [18326] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40989 { label="MicroBatchScan"; 18312 [labelType="html" label="DataSourceRDD [18312] run at <unknown>:0"]; 18313 [labelType="html" label="MapPartitionsRDD [18313] run at <unknown>:0"]; } subgraph cluster40988 { label="Project"; 18314 [labelType="html" label="MapPartitionsRDD [18314] run at <unknown>:0"]; } subgraph cluster40984 { label="WholeStageCodegen (1)"; 18315 [labelType="html" label="MapPartitionsRDD [18315] run at <unknown>:0"]; } subgraph cluster40998 { label="WholeStageCodegen (1)"; 18317 [labelType="html" label="MapPartitionsRDD [18317] toJavaRDD at <unknown>:0"]; } subgraph cluster40997 { label="Filter"; 18318 [labelType="html" label="MapPartitionsRDD [18318] toJavaRDD at <unknown>:0"]; } subgraph cluster40996 { label="Project"; 18319 [labelType="html" label="MapPartitionsRDD [18319] toJavaRDD at <unknown>:0"]; } subgraph cluster40993 { label="WholeStageCodegen (2)"; 18320 [labelType="html" label="MapPartitionsRDD [18320] toJavaRDD at <unknown>:0"]; } subgraph cluster40992 { label="Project"; 18321 [labelType="html" label="MapPartitionsRDD [18321] toJavaRDD at <unknown>:0"]; } subgraph cluster40991 { label="DeserializeToObject"; 18322 [labelType="html" label="MapPartitionsRDD [18322] toJavaRDD at <unknown>:0"]; } subgraph cluster40990 { label="MapPartitions"; 18323 [labelType="html" label="MapPartitionsRDD [18323] toJavaRDD at <unknown>:0"]; } subgraph cluster41000 { label="mapPartitions"; 18325 [labelType="html" label="MapPartitionsRDD [18325] toJavaRDD at <unknown>:0"]; } } 18312->18313; 18313->18314; 18314->18315; 18315->18316; 18316->18317; 18317->18318; 18318->18319; 18319->18320; 18320->18321; 18321->18322; 18322->18323; 18323->18324; 18324->18325; 18325->18326; }

Event Timeline

Enable zooming