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

digraph G { subgraph clusterstage_1284 { label="Stage 1284"; 13486 [labelType="html" label="SQLExecutionRDD [13486] run at <unknown>:0"]; 13494 [labelType="html" label="SQLExecutionRDD [13494] toJavaRDD at <unknown>:0"]; 13496 [labelType="html" label="PythonRDD [13496] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30179 { label="MicroBatchScan"; 13482 [labelType="html" label="DataSourceRDD [13482] run at <unknown>:0"]; 13483 [labelType="html" label="MapPartitionsRDD [13483] run at <unknown>:0"]; } subgraph cluster30178 { label="Project"; 13484 [labelType="html" label="MapPartitionsRDD [13484] run at <unknown>:0"]; } subgraph cluster30174 { label="WholeStageCodegen (1)"; 13485 [labelType="html" label="MapPartitionsRDD [13485] run at <unknown>:0"]; } subgraph cluster30188 { label="WholeStageCodegen (1)"; 13487 [labelType="html" label="MapPartitionsRDD [13487] toJavaRDD at <unknown>:0"]; } subgraph cluster30187 { label="Filter"; 13488 [labelType="html" label="MapPartitionsRDD [13488] toJavaRDD at <unknown>:0"]; } subgraph cluster30186 { label="Project"; 13489 [labelType="html" label="MapPartitionsRDD [13489] toJavaRDD at <unknown>:0"]; } subgraph cluster30183 { label="WholeStageCodegen (2)"; 13490 [labelType="html" label="MapPartitionsRDD [13490] toJavaRDD at <unknown>:0"]; } subgraph cluster30182 { label="Project"; 13491 [labelType="html" label="MapPartitionsRDD [13491] toJavaRDD at <unknown>:0"]; } subgraph cluster30181 { label="DeserializeToObject"; 13492 [labelType="html" label="MapPartitionsRDD [13492] toJavaRDD at <unknown>:0"]; } subgraph cluster30180 { label="MapPartitions"; 13493 [labelType="html" label="MapPartitionsRDD [13493] toJavaRDD at <unknown>:0"]; } subgraph cluster30190 { label="mapPartitions"; 13495 [labelType="html" label="MapPartitionsRDD [13495] toJavaRDD at <unknown>:0"]; } } 13482->13483; 13483->13484; 13484->13485; 13485->13486; 13486->13487; 13487->13488; 13488->13489; 13489->13490; 13490->13491; 13491->13492; 13492->13493; 13493->13494; 13494->13495; 13495->13496; }

Event Timeline

Enable zooming