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

digraph G { subgraph clusterstage_738 { label="Stage 738"; 7753 [labelType="html" label="SQLExecutionRDD [7753] run at <unknown>:0"]; 7761 [labelType="html" label="SQLExecutionRDD [7761] toJavaRDD at <unknown>:0"]; 7763 [labelType="html" label="PythonRDD [7763] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17348 { label="MicroBatchScan"; 7749 [labelType="html" label="DataSourceRDD [7749] run at <unknown>:0"]; 7750 [labelType="html" label="MapPartitionsRDD [7750] run at <unknown>:0"]; } subgraph cluster17347 { label="Project"; 7751 [labelType="html" label="MapPartitionsRDD [7751] run at <unknown>:0"]; } subgraph cluster17343 { label="WholeStageCodegen (1)"; 7752 [labelType="html" label="MapPartitionsRDD [7752] run at <unknown>:0"]; } subgraph cluster17357 { label="WholeStageCodegen (1)"; 7754 [labelType="html" label="MapPartitionsRDD [7754] toJavaRDD at <unknown>:0"]; } subgraph cluster17356 { label="Filter"; 7755 [labelType="html" label="MapPartitionsRDD [7755] toJavaRDD at <unknown>:0"]; } subgraph cluster17355 { label="Project"; 7756 [labelType="html" label="MapPartitionsRDD [7756] toJavaRDD at <unknown>:0"]; } subgraph cluster17352 { label="WholeStageCodegen (2)"; 7757 [labelType="html" label="MapPartitionsRDD [7757] toJavaRDD at <unknown>:0"]; } subgraph cluster17351 { label="Project"; 7758 [labelType="html" label="MapPartitionsRDD [7758] toJavaRDD at <unknown>:0"]; } subgraph cluster17350 { label="DeserializeToObject"; 7759 [labelType="html" label="MapPartitionsRDD [7759] toJavaRDD at <unknown>:0"]; } subgraph cluster17349 { label="MapPartitions"; 7760 [labelType="html" label="MapPartitionsRDD [7760] toJavaRDD at <unknown>:0"]; } subgraph cluster17359 { label="mapPartitions"; 7762 [labelType="html" label="MapPartitionsRDD [7762] toJavaRDD at <unknown>:0"]; } } 7749->7750; 7750->7751; 7751->7752; 7752->7753; 7753->7754; 7754->7755; 7755->7756; 7756->7757; 7757->7758; 7758->7759; 7759->7760; 7760->7761; 7761->7762; 7762->7763; }

Event Timeline

Enable zooming