processing-stream-kafka-raw-to-minio - Details for Stage 797 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 347
Associated Job Ids: 797

digraph G { subgraph clusterstage_797 { label="Stage 797"; 8368 [labelType="html" label="SQLExecutionRDD [8368] run at <unknown>:0"]; 8376 [labelType="html" label="SQLExecutionRDD [8376] toJavaRDD at <unknown>:0"]; 8378 [labelType="html" label="PythonRDD [8378] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18719 { label="MicroBatchScan"; 8364 [labelType="html" label="DataSourceRDD [8364] run at <unknown>:0"]; 8365 [labelType="html" label="MapPartitionsRDD [8365] run at <unknown>:0"]; } subgraph cluster18718 { label="Project"; 8366 [labelType="html" label="MapPartitionsRDD [8366] run at <unknown>:0"]; } subgraph cluster18712 { label="WholeStageCodegen (1)"; 8367 [labelType="html" label="MapPartitionsRDD [8367] run at <unknown>:0"]; } subgraph cluster18728 { label="WholeStageCodegen (1)"; 8369 [labelType="html" label="MapPartitionsRDD [8369] toJavaRDD at <unknown>:0"]; } subgraph cluster18727 { label="Filter"; 8370 [labelType="html" label="MapPartitionsRDD [8370] toJavaRDD at <unknown>:0"]; } subgraph cluster18726 { label="Project"; 8371 [labelType="html" label="MapPartitionsRDD [8371] toJavaRDD at <unknown>:0"]; } subgraph cluster18723 { label="WholeStageCodegen (2)"; 8372 [labelType="html" label="MapPartitionsRDD [8372] toJavaRDD at <unknown>:0"]; } subgraph cluster18722 { label="Project"; 8373 [labelType="html" label="MapPartitionsRDD [8373] toJavaRDD at <unknown>:0"]; } subgraph cluster18721 { label="DeserializeToObject"; 8374 [labelType="html" label="MapPartitionsRDD [8374] toJavaRDD at <unknown>:0"]; } subgraph cluster18720 { label="MapPartitions"; 8375 [labelType="html" label="MapPartitionsRDD [8375] toJavaRDD at <unknown>:0"]; } subgraph cluster18730 { label="mapPartitions"; 8377 [labelType="html" label="MapPartitionsRDD [8377] toJavaRDD at <unknown>:0"]; } } 8364->8365; 8365->8366; 8366->8367; 8367->8368; 8368->8369; 8369->8370; 8370->8371; 8371->8372; 8372->8373; 8373->8374; 8374->8375; 8375->8376; 8376->8377; 8377->8378; }

Event Timeline

Enable zooming