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

digraph G { subgraph clusterstage_1405 { label="Stage 1405"; 14768 [labelType="html" label="SQLExecutionRDD [14768] run at <unknown>:0"]; 14776 [labelType="html" label="SQLExecutionRDD [14776] toJavaRDD at <unknown>:0"]; 14778 [labelType="html" label="PythonRDD [14778] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33042 { label="MicroBatchScan"; 14764 [labelType="html" label="DataSourceRDD [14764] run at <unknown>:0"]; 14765 [labelType="html" label="MapPartitionsRDD [14765] run at <unknown>:0"]; } subgraph cluster33041 { label="Project"; 14766 [labelType="html" label="MapPartitionsRDD [14766] run at <unknown>:0"]; } subgraph cluster33037 { label="WholeStageCodegen (1)"; 14767 [labelType="html" label="MapPartitionsRDD [14767] run at <unknown>:0"]; } subgraph cluster33051 { label="WholeStageCodegen (1)"; 14769 [labelType="html" label="MapPartitionsRDD [14769] toJavaRDD at <unknown>:0"]; } subgraph cluster33050 { label="Filter"; 14770 [labelType="html" label="MapPartitionsRDD [14770] toJavaRDD at <unknown>:0"]; } subgraph cluster33049 { label="Project"; 14771 [labelType="html" label="MapPartitionsRDD [14771] toJavaRDD at <unknown>:0"]; } subgraph cluster33046 { label="WholeStageCodegen (2)"; 14772 [labelType="html" label="MapPartitionsRDD [14772] toJavaRDD at <unknown>:0"]; } subgraph cluster33045 { label="Project"; 14773 [labelType="html" label="MapPartitionsRDD [14773] toJavaRDD at <unknown>:0"]; } subgraph cluster33044 { label="DeserializeToObject"; 14774 [labelType="html" label="MapPartitionsRDD [14774] toJavaRDD at <unknown>:0"]; } subgraph cluster33043 { label="MapPartitions"; 14775 [labelType="html" label="MapPartitionsRDD [14775] toJavaRDD at <unknown>:0"]; } subgraph cluster33053 { label="mapPartitions"; 14777 [labelType="html" label="MapPartitionsRDD [14777] toJavaRDD at <unknown>:0"]; } } 14764->14765; 14765->14766; 14766->14767; 14767->14768; 14768->14769; 14769->14770; 14770->14771; 14771->14772; 14772->14773; 14773->14774; 14774->14775; 14775->14776; 14776->14777; 14777->14778; }

Event Timeline

Enable zooming