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

digraph G { subgraph clusterstage_1786 { label="Stage 1786"; 18757 [labelType="html" label="SQLExecutionRDD [18757] run at <unknown>:0"]; 18765 [labelType="html" label="SQLExecutionRDD [18765] toJavaRDD at <unknown>:0"]; 18767 [labelType="html" label="PythonRDD [18767] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41976 { label="MicroBatchScan"; 18753 [labelType="html" label="DataSourceRDD [18753] run at <unknown>:0"]; 18754 [labelType="html" label="MapPartitionsRDD [18754] run at <unknown>:0"]; } subgraph cluster41975 { label="Project"; 18755 [labelType="html" label="MapPartitionsRDD [18755] run at <unknown>:0"]; } subgraph cluster41971 { label="WholeStageCodegen (1)"; 18756 [labelType="html" label="MapPartitionsRDD [18756] run at <unknown>:0"]; } subgraph cluster41985 { label="WholeStageCodegen (1)"; 18758 [labelType="html" label="MapPartitionsRDD [18758] toJavaRDD at <unknown>:0"]; } subgraph cluster41984 { label="Filter"; 18759 [labelType="html" label="MapPartitionsRDD [18759] toJavaRDD at <unknown>:0"]; } subgraph cluster41983 { label="Project"; 18760 [labelType="html" label="MapPartitionsRDD [18760] toJavaRDD at <unknown>:0"]; } subgraph cluster41980 { label="WholeStageCodegen (2)"; 18761 [labelType="html" label="MapPartitionsRDD [18761] toJavaRDD at <unknown>:0"]; } subgraph cluster41979 { label="Project"; 18762 [labelType="html" label="MapPartitionsRDD [18762] toJavaRDD at <unknown>:0"]; } subgraph cluster41978 { label="DeserializeToObject"; 18763 [labelType="html" label="MapPartitionsRDD [18763] toJavaRDD at <unknown>:0"]; } subgraph cluster41977 { label="MapPartitions"; 18764 [labelType="html" label="MapPartitionsRDD [18764] toJavaRDD at <unknown>:0"]; } subgraph cluster41987 { label="mapPartitions"; 18766 [labelType="html" label="MapPartitionsRDD [18766] toJavaRDD at <unknown>:0"]; } } 18753->18754; 18754->18755; 18755->18756; 18756->18757; 18757->18758; 18758->18759; 18759->18760; 18760->18761; 18761->18762; 18762->18763; 18763->18764; 18764->18765; 18765->18766; 18766->18767; }

Event Timeline

Enable zooming