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

digraph G { subgraph clusterstage_1527 { label="Stage 1527"; 16033 [labelType="html" label="SQLExecutionRDD [16033] run at <unknown>:0"]; 16041 [labelType="html" label="SQLExecutionRDD [16041] toJavaRDD at <unknown>:0"]; 16043 [labelType="html" label="PythonRDD [16043] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35874 { label="MicroBatchScan"; 16024 [labelType="html" label="DataSourceRDD [16024] run at <unknown>:0"]; 16027 [labelType="html" label="MapPartitionsRDD [16027] run at <unknown>:0"]; } subgraph cluster35873 { label="Project"; 16031 [labelType="html" label="MapPartitionsRDD [16031] run at <unknown>:0"]; } subgraph cluster35867 { label="WholeStageCodegen (1)"; 16032 [labelType="html" label="MapPartitionsRDD [16032] run at <unknown>:0"]; } subgraph cluster35883 { label="WholeStageCodegen (1)"; 16034 [labelType="html" label="MapPartitionsRDD [16034] toJavaRDD at <unknown>:0"]; } subgraph cluster35882 { label="Filter"; 16035 [labelType="html" label="MapPartitionsRDD [16035] toJavaRDD at <unknown>:0"]; } subgraph cluster35881 { label="Project"; 16036 [labelType="html" label="MapPartitionsRDD [16036] toJavaRDD at <unknown>:0"]; } subgraph cluster35878 { label="WholeStageCodegen (2)"; 16037 [labelType="html" label="MapPartitionsRDD [16037] toJavaRDD at <unknown>:0"]; } subgraph cluster35877 { label="Project"; 16038 [labelType="html" label="MapPartitionsRDD [16038] toJavaRDD at <unknown>:0"]; } subgraph cluster35876 { label="DeserializeToObject"; 16039 [labelType="html" label="MapPartitionsRDD [16039] toJavaRDD at <unknown>:0"]; } subgraph cluster35875 { label="MapPartitions"; 16040 [labelType="html" label="MapPartitionsRDD [16040] toJavaRDD at <unknown>:0"]; } subgraph cluster35885 { label="mapPartitions"; 16042 [labelType="html" label="MapPartitionsRDD [16042] toJavaRDD at <unknown>:0"]; } } 16024->16027; 16027->16031; 16031->16032; 16032->16033; 16033->16034; 16034->16035; 16035->16036; 16036->16037; 16037->16038; 16038->16039; 16039->16040; 16040->16041; 16041->16042; 16042->16043; }

Event Timeline

Enable zooming