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

digraph G { subgraph clusterstage_1656 { label="Stage 1656"; 17393 [labelType="html" label="SQLExecutionRDD [17393] run at <unknown>:0"]; 17407 [labelType="html" label="SQLExecutionRDD [17407] toJavaRDD at <unknown>:0"]; 17409 [labelType="html" label="PythonRDD [17409] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38917 { label="MicroBatchScan"; 17389 [labelType="html" label="DataSourceRDD [17389] run at <unknown>:0"]; 17390 [labelType="html" label="MapPartitionsRDD [17390] run at <unknown>:0"]; } subgraph cluster38916 { label="Project"; 17391 [labelType="html" label="MapPartitionsRDD [17391] run at <unknown>:0"]; } subgraph cluster38912 { label="WholeStageCodegen (1)"; 17392 [labelType="html" label="MapPartitionsRDD [17392] run at <unknown>:0"]; } subgraph cluster38934 { label="WholeStageCodegen (1)"; 17400 [labelType="html" label="MapPartitionsRDD [17400] toJavaRDD at <unknown>:0"]; } subgraph cluster38933 { label="Filter"; 17401 [labelType="html" label="MapPartitionsRDD [17401] toJavaRDD at <unknown>:0"]; } subgraph cluster38932 { label="Project"; 17402 [labelType="html" label="MapPartitionsRDD [17402] toJavaRDD at <unknown>:0"]; } subgraph cluster38929 { label="WholeStageCodegen (2)"; 17403 [labelType="html" label="MapPartitionsRDD [17403] toJavaRDD at <unknown>:0"]; } subgraph cluster38928 { label="Project"; 17404 [labelType="html" label="MapPartitionsRDD [17404] toJavaRDD at <unknown>:0"]; } subgraph cluster38927 { label="DeserializeToObject"; 17405 [labelType="html" label="MapPartitionsRDD [17405] toJavaRDD at <unknown>:0"]; } subgraph cluster38926 { label="MapPartitions"; 17406 [labelType="html" label="MapPartitionsRDD [17406] toJavaRDD at <unknown>:0"]; } subgraph cluster38936 { label="mapPartitions"; 17408 [labelType="html" label="MapPartitionsRDD [17408] toJavaRDD at <unknown>:0"]; } } 17389->17390; 17390->17391; 17391->17392; 17392->17393; 17393->17400; 17400->17401; 17401->17402; 17402->17403; 17403->17404; 17404->17405; 17405->17406; 17406->17407; 17407->17408; 17408->17409; }

Event Timeline

Enable zooming