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

digraph G { subgraph clusterstage_1991 { label="Stage 1991"; 20921 [labelType="html" label="SQLExecutionRDD [20921] run at <unknown>:0"]; 20929 [labelType="html" label="SQLExecutionRDD [20929] toJavaRDD at <unknown>:0"]; 20931 [labelType="html" label="PythonRDD [20931] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46813 { label="MicroBatchScan"; 20917 [labelType="html" label="DataSourceRDD [20917] run at <unknown>:0"]; 20918 [labelType="html" label="MapPartitionsRDD [20918] run at <unknown>:0"]; } subgraph cluster46812 { label="Project"; 20919 [labelType="html" label="MapPartitionsRDD [20919] run at <unknown>:0"]; } subgraph cluster46808 { label="WholeStageCodegen (1)"; 20920 [labelType="html" label="MapPartitionsRDD [20920] run at <unknown>:0"]; } subgraph cluster46822 { label="WholeStageCodegen (1)"; 20922 [labelType="html" label="MapPartitionsRDD [20922] toJavaRDD at <unknown>:0"]; } subgraph cluster46821 { label="Filter"; 20923 [labelType="html" label="MapPartitionsRDD [20923] toJavaRDD at <unknown>:0"]; } subgraph cluster46820 { label="Project"; 20924 [labelType="html" label="MapPartitionsRDD [20924] toJavaRDD at <unknown>:0"]; } subgraph cluster46817 { label="WholeStageCodegen (2)"; 20925 [labelType="html" label="MapPartitionsRDD [20925] toJavaRDD at <unknown>:0"]; } subgraph cluster46816 { label="Project"; 20926 [labelType="html" label="MapPartitionsRDD [20926] toJavaRDD at <unknown>:0"]; } subgraph cluster46815 { label="DeserializeToObject"; 20927 [labelType="html" label="MapPartitionsRDD [20927] toJavaRDD at <unknown>:0"]; } subgraph cluster46814 { label="MapPartitions"; 20928 [labelType="html" label="MapPartitionsRDD [20928] toJavaRDD at <unknown>:0"]; } subgraph cluster46824 { label="mapPartitions"; 20930 [labelType="html" label="MapPartitionsRDD [20930] toJavaRDD at <unknown>:0"]; } } 20917->20918; 20918->20919; 20919->20920; 20920->20921; 20921->20922; 20922->20923; 20923->20924; 20924->20925; 20925->20926; 20926->20927; 20927->20928; 20928->20929; 20929->20930; 20930->20931; }

Event Timeline

Enable zooming