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

digraph G { subgraph clusterstage_1203 { label="Stage 1203"; 12647 [labelType="html" label="SQLExecutionRDD [12647] run at <unknown>:0"]; 12655 [labelType="html" label="SQLExecutionRDD [12655] toJavaRDD at <unknown>:0"]; 12657 [labelType="html" label="PythonRDD [12657] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28295 { label="MicroBatchScan"; 12643 [labelType="html" label="DataSourceRDD [12643] run at <unknown>:0"]; 12644 [labelType="html" label="MapPartitionsRDD [12644] run at <unknown>:0"]; } subgraph cluster28294 { label="Project"; 12645 [labelType="html" label="MapPartitionsRDD [12645] run at <unknown>:0"]; } subgraph cluster28290 { label="WholeStageCodegen (1)"; 12646 [labelType="html" label="MapPartitionsRDD [12646] run at <unknown>:0"]; } subgraph cluster28304 { label="WholeStageCodegen (1)"; 12648 [labelType="html" label="MapPartitionsRDD [12648] toJavaRDD at <unknown>:0"]; } subgraph cluster28303 { label="Filter"; 12649 [labelType="html" label="MapPartitionsRDD [12649] toJavaRDD at <unknown>:0"]; } subgraph cluster28302 { label="Project"; 12650 [labelType="html" label="MapPartitionsRDD [12650] toJavaRDD at <unknown>:0"]; } subgraph cluster28299 { label="WholeStageCodegen (2)"; 12651 [labelType="html" label="MapPartitionsRDD [12651] toJavaRDD at <unknown>:0"]; } subgraph cluster28298 { label="Project"; 12652 [labelType="html" label="MapPartitionsRDD [12652] toJavaRDD at <unknown>:0"]; } subgraph cluster28297 { label="DeserializeToObject"; 12653 [labelType="html" label="MapPartitionsRDD [12653] toJavaRDD at <unknown>:0"]; } subgraph cluster28296 { label="MapPartitions"; 12654 [labelType="html" label="MapPartitionsRDD [12654] toJavaRDD at <unknown>:0"]; } subgraph cluster28306 { label="mapPartitions"; 12656 [labelType="html" label="MapPartitionsRDD [12656] toJavaRDD at <unknown>:0"]; } } 12643->12644; 12644->12645; 12645->12646; 12646->12647; 12647->12648; 12648->12649; 12649->12650; 12650->12651; 12651->12652; 12652->12653; 12653->12654; 12654->12655; 12655->12656; 12656->12657; }

Event Timeline

Enable zooming