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

digraph G { subgraph clusterstage_1209 { label="Stage 1209"; 12710 [labelType="html" label="SQLExecutionRDD [12710] run at <unknown>:0"]; 12718 [labelType="html" label="SQLExecutionRDD [12718] toJavaRDD at <unknown>:0"]; 12720 [labelType="html" label="PythonRDD [12720] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28436 { label="MicroBatchScan"; 12706 [labelType="html" label="DataSourceRDD [12706] run at <unknown>:0"]; 12707 [labelType="html" label="MapPartitionsRDD [12707] run at <unknown>:0"]; } subgraph cluster28435 { label="Project"; 12708 [labelType="html" label="MapPartitionsRDD [12708] run at <unknown>:0"]; } subgraph cluster28431 { label="WholeStageCodegen (1)"; 12709 [labelType="html" label="MapPartitionsRDD [12709] run at <unknown>:0"]; } subgraph cluster28445 { label="WholeStageCodegen (1)"; 12711 [labelType="html" label="MapPartitionsRDD [12711] toJavaRDD at <unknown>:0"]; } subgraph cluster28444 { label="Filter"; 12712 [labelType="html" label="MapPartitionsRDD [12712] toJavaRDD at <unknown>:0"]; } subgraph cluster28443 { label="Project"; 12713 [labelType="html" label="MapPartitionsRDD [12713] toJavaRDD at <unknown>:0"]; } subgraph cluster28440 { label="WholeStageCodegen (2)"; 12714 [labelType="html" label="MapPartitionsRDD [12714] toJavaRDD at <unknown>:0"]; } subgraph cluster28439 { label="Project"; 12715 [labelType="html" label="MapPartitionsRDD [12715] toJavaRDD at <unknown>:0"]; } subgraph cluster28438 { label="DeserializeToObject"; 12716 [labelType="html" label="MapPartitionsRDD [12716] toJavaRDD at <unknown>:0"]; } subgraph cluster28437 { label="MapPartitions"; 12717 [labelType="html" label="MapPartitionsRDD [12717] toJavaRDD at <unknown>:0"]; } subgraph cluster28447 { label="mapPartitions"; 12719 [labelType="html" label="MapPartitionsRDD [12719] toJavaRDD at <unknown>:0"]; } } 12706->12707; 12707->12708; 12708->12709; 12709->12710; 12710->12711; 12711->12712; 12712->12713; 12713->12714; 12714->12715; 12715->12716; 12716->12717; 12717->12718; 12718->12719; 12719->12720; }

Event Timeline

Enable zooming