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

digraph G { subgraph clusterstage_1400 { label="Stage 1400"; 14705 [labelType="html" label="SQLExecutionRDD [14705] run at <unknown>:0"]; 14719 [labelType="html" label="SQLExecutionRDD [14719] toJavaRDD at <unknown>:0"]; 14721 [labelType="html" label="PythonRDD [14721] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32901 { label="MicroBatchScan"; 14701 [labelType="html" label="DataSourceRDD [14701] run at <unknown>:0"]; 14702 [labelType="html" label="MapPartitionsRDD [14702] run at <unknown>:0"]; } subgraph cluster32900 { label="Project"; 14703 [labelType="html" label="MapPartitionsRDD [14703] run at <unknown>:0"]; } subgraph cluster32896 { label="WholeStageCodegen (1)"; 14704 [labelType="html" label="MapPartitionsRDD [14704] run at <unknown>:0"]; } subgraph cluster32918 { label="WholeStageCodegen (1)"; 14712 [labelType="html" label="MapPartitionsRDD [14712] toJavaRDD at <unknown>:0"]; } subgraph cluster32917 { label="Filter"; 14713 [labelType="html" label="MapPartitionsRDD [14713] toJavaRDD at <unknown>:0"]; } subgraph cluster32916 { label="Project"; 14714 [labelType="html" label="MapPartitionsRDD [14714] toJavaRDD at <unknown>:0"]; } subgraph cluster32913 { label="WholeStageCodegen (2)"; 14715 [labelType="html" label="MapPartitionsRDD [14715] toJavaRDD at <unknown>:0"]; } subgraph cluster32912 { label="Project"; 14716 [labelType="html" label="MapPartitionsRDD [14716] toJavaRDD at <unknown>:0"]; } subgraph cluster32911 { label="DeserializeToObject"; 14717 [labelType="html" label="MapPartitionsRDD [14717] toJavaRDD at <unknown>:0"]; } subgraph cluster32910 { label="MapPartitions"; 14718 [labelType="html" label="MapPartitionsRDD [14718] toJavaRDD at <unknown>:0"]; } subgraph cluster32920 { label="mapPartitions"; 14720 [labelType="html" label="MapPartitionsRDD [14720] toJavaRDD at <unknown>:0"]; } } 14701->14702; 14702->14703; 14703->14704; 14704->14705; 14705->14712; 14712->14713; 14713->14714; 14714->14715; 14715->14716; 14716->14717; 14717->14718; 14718->14719; 14719->14720; 14720->14721; }

Event Timeline

Enable zooming