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

digraph G { subgraph clusterstage_1239 { label="Stage 1239"; 13025 [labelType="html" label="SQLExecutionRDD [13025] run at <unknown>:0"]; 13033 [labelType="html" label="SQLExecutionRDD [13033] toJavaRDD at <unknown>:0"]; 13035 [labelType="html" label="PythonRDD [13035] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29141 { label="MicroBatchScan"; 13021 [labelType="html" label="DataSourceRDD [13021] run at <unknown>:0"]; 13022 [labelType="html" label="MapPartitionsRDD [13022] run at <unknown>:0"]; } subgraph cluster29140 { label="Project"; 13023 [labelType="html" label="MapPartitionsRDD [13023] run at <unknown>:0"]; } subgraph cluster29136 { label="WholeStageCodegen (1)"; 13024 [labelType="html" label="MapPartitionsRDD [13024] run at <unknown>:0"]; } subgraph cluster29150 { label="WholeStageCodegen (1)"; 13026 [labelType="html" label="MapPartitionsRDD [13026] toJavaRDD at <unknown>:0"]; } subgraph cluster29149 { label="Filter"; 13027 [labelType="html" label="MapPartitionsRDD [13027] toJavaRDD at <unknown>:0"]; } subgraph cluster29148 { label="Project"; 13028 [labelType="html" label="MapPartitionsRDD [13028] toJavaRDD at <unknown>:0"]; } subgraph cluster29145 { label="WholeStageCodegen (2)"; 13029 [labelType="html" label="MapPartitionsRDD [13029] toJavaRDD at <unknown>:0"]; } subgraph cluster29144 { label="Project"; 13030 [labelType="html" label="MapPartitionsRDD [13030] toJavaRDD at <unknown>:0"]; } subgraph cluster29143 { label="DeserializeToObject"; 13031 [labelType="html" label="MapPartitionsRDD [13031] toJavaRDD at <unknown>:0"]; } subgraph cluster29142 { label="MapPartitions"; 13032 [labelType="html" label="MapPartitionsRDD [13032] toJavaRDD at <unknown>:0"]; } subgraph cluster29152 { label="mapPartitions"; 13034 [labelType="html" label="MapPartitionsRDD [13034] toJavaRDD at <unknown>:0"]; } } 13021->13022; 13022->13023; 13023->13024; 13024->13025; 13025->13026; 13026->13027; 13027->13028; 13028->13029; 13029->13030; 13030->13031; 13031->13032; 13032->13033; 13033->13034; 13034->13035; }

Event Timeline

Enable zooming