processing-stream-kafka-raw-to-minio - Details for Stage 669 (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 / 418
Associated Job Ids: 670

digraph G { subgraph clusterstage_669 { label="Stage 669"; 7040 [labelType="html" label="SQLExecutionRDD [7040] run at <unknown>:0"]; 7048 [labelType="html" label="SQLExecutionRDD [7048] toJavaRDD at <unknown>:0"]; 7050 [labelType="html" label="PythonRDD [7050] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster15746 { label="MicroBatchScan"; 7036 [labelType="html" label="DataSourceRDD [7036] run at <unknown>:0"]; 7037 [labelType="html" label="MapPartitionsRDD [7037] run at <unknown>:0"]; } subgraph cluster15745 { label="Project"; 7038 [labelType="html" label="MapPartitionsRDD [7038] run at <unknown>:0"]; } subgraph cluster15741 { label="WholeStageCodegen (1)"; 7039 [labelType="html" label="MapPartitionsRDD [7039] run at <unknown>:0"]; } subgraph cluster15755 { label="WholeStageCodegen (1)"; 7041 [labelType="html" label="MapPartitionsRDD [7041] toJavaRDD at <unknown>:0"]; } subgraph cluster15754 { label="Filter"; 7042 [labelType="html" label="MapPartitionsRDD [7042] toJavaRDD at <unknown>:0"]; } subgraph cluster15753 { label="Project"; 7043 [labelType="html" label="MapPartitionsRDD [7043] toJavaRDD at <unknown>:0"]; } subgraph cluster15750 { label="WholeStageCodegen (2)"; 7044 [labelType="html" label="MapPartitionsRDD [7044] toJavaRDD at <unknown>:0"]; } subgraph cluster15749 { label="Project"; 7045 [labelType="html" label="MapPartitionsRDD [7045] toJavaRDD at <unknown>:0"]; } subgraph cluster15748 { label="DeserializeToObject"; 7046 [labelType="html" label="MapPartitionsRDD [7046] toJavaRDD at <unknown>:0"]; } subgraph cluster15747 { label="MapPartitions"; 7047 [labelType="html" label="MapPartitionsRDD [7047] toJavaRDD at <unknown>:0"]; } subgraph cluster15757 { label="mapPartitions"; 7049 [labelType="html" label="MapPartitionsRDD [7049] toJavaRDD at <unknown>:0"]; } } 7036->7037; 7037->7038; 7038->7039; 7039->7040; 7040->7041; 7041->7042; 7042->7043; 7043->7044; 7044->7045; 7045->7046; 7046->7047; 7047->7048; 7048->7049; 7049->7050; }

Event Timeline

Enable zooming