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

digraph G { subgraph clusterstage_1589 { label="Stage 1589"; 16700 [labelType="html" label="SQLExecutionRDD [16700] run at <unknown>:0"]; 16708 [labelType="html" label="SQLExecutionRDD [16708] toJavaRDD at <unknown>:0"]; 16710 [labelType="html" label="PythonRDD [16710] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37366 { label="MicroBatchScan"; 16696 [labelType="html" label="DataSourceRDD [16696] run at <unknown>:0"]; 16697 [labelType="html" label="MapPartitionsRDD [16697] run at <unknown>:0"]; } subgraph cluster37365 { label="Project"; 16698 [labelType="html" label="MapPartitionsRDD [16698] run at <unknown>:0"]; } subgraph cluster37361 { label="WholeStageCodegen (1)"; 16699 [labelType="html" label="MapPartitionsRDD [16699] run at <unknown>:0"]; } subgraph cluster37375 { label="WholeStageCodegen (1)"; 16701 [labelType="html" label="MapPartitionsRDD [16701] toJavaRDD at <unknown>:0"]; } subgraph cluster37374 { label="Filter"; 16702 [labelType="html" label="MapPartitionsRDD [16702] toJavaRDD at <unknown>:0"]; } subgraph cluster37373 { label="Project"; 16703 [labelType="html" label="MapPartitionsRDD [16703] toJavaRDD at <unknown>:0"]; } subgraph cluster37370 { label="WholeStageCodegen (2)"; 16704 [labelType="html" label="MapPartitionsRDD [16704] toJavaRDD at <unknown>:0"]; } subgraph cluster37369 { label="Project"; 16705 [labelType="html" label="MapPartitionsRDD [16705] toJavaRDD at <unknown>:0"]; } subgraph cluster37368 { label="DeserializeToObject"; 16706 [labelType="html" label="MapPartitionsRDD [16706] toJavaRDD at <unknown>:0"]; } subgraph cluster37367 { label="MapPartitions"; 16707 [labelType="html" label="MapPartitionsRDD [16707] toJavaRDD at <unknown>:0"]; } subgraph cluster37377 { label="mapPartitions"; 16709 [labelType="html" label="MapPartitionsRDD [16709] toJavaRDD at <unknown>:0"]; } } 16696->16697; 16697->16698; 16698->16699; 16699->16700; 16700->16701; 16701->16702; 16702->16703; 16703->16704; 16704->16705; 16705->16706; 16706->16707; 16707->16708; 16708->16709; 16709->16710; }

Event Timeline

Enable zooming