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

digraph G { subgraph clusterstage_262 { label="Stage 262"; 2755 [labelType="html" label="SQLExecutionRDD [2755] run at <unknown>:0"]; 2763 [labelType="html" label="SQLExecutionRDD [2763] toJavaRDD at <unknown>:0"]; 2765 [labelType="html" label="PythonRDD [2765] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster6162 { label="MicroBatchScan"; 2751 [labelType="html" label="DataSourceRDD [2751] run at <unknown>:0"]; 2752 [labelType="html" label="MapPartitionsRDD [2752] run at <unknown>:0"]; } subgraph cluster6161 { label="Project"; 2753 [labelType="html" label="MapPartitionsRDD [2753] run at <unknown>:0"]; } subgraph cluster6157 { label="WholeStageCodegen (1)"; 2754 [labelType="html" label="MapPartitionsRDD [2754] run at <unknown>:0"]; } subgraph cluster6171 { label="WholeStageCodegen (1)"; 2756 [labelType="html" label="MapPartitionsRDD [2756] toJavaRDD at <unknown>:0"]; } subgraph cluster6170 { label="Filter"; 2757 [labelType="html" label="MapPartitionsRDD [2757] toJavaRDD at <unknown>:0"]; } subgraph cluster6169 { label="Project"; 2758 [labelType="html" label="MapPartitionsRDD [2758] toJavaRDD at <unknown>:0"]; } subgraph cluster6166 { label="WholeStageCodegen (2)"; 2759 [labelType="html" label="MapPartitionsRDD [2759] toJavaRDD at <unknown>:0"]; } subgraph cluster6165 { label="Project"; 2760 [labelType="html" label="MapPartitionsRDD [2760] toJavaRDD at <unknown>:0"]; } subgraph cluster6164 { label="DeserializeToObject"; 2761 [labelType="html" label="MapPartitionsRDD [2761] toJavaRDD at <unknown>:0"]; } subgraph cluster6163 { label="MapPartitions"; 2762 [labelType="html" label="MapPartitionsRDD [2762] toJavaRDD at <unknown>:0"]; } subgraph cluster6173 { label="mapPartitions"; 2764 [labelType="html" label="MapPartitionsRDD [2764] toJavaRDD at <unknown>:0"]; } } 2751->2752; 2752->2753; 2753->2754; 2754->2755; 2755->2756; 2756->2757; 2757->2758; 2758->2759; 2759->2760; 2760->2761; 2761->2762; 2762->2763; 2763->2764; 2764->2765; }

Event Timeline

Enable zooming