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

digraph G { subgraph clusterstage_1113 { label="Stage 1113"; 11702 [labelType="html" label="SQLExecutionRDD [11702] run at <unknown>:0"]; 11710 [labelType="html" label="SQLExecutionRDD [11710] toJavaRDD at <unknown>:0"]; 11718 [labelType="html" label="PythonRDD [11718] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26180 { label="MicroBatchScan"; 11698 [labelType="html" label="DataSourceRDD [11698] run at <unknown>:0"]; 11699 [labelType="html" label="MapPartitionsRDD [11699] run at <unknown>:0"]; } subgraph cluster26179 { label="Project"; 11700 [labelType="html" label="MapPartitionsRDD [11700] run at <unknown>:0"]; } subgraph cluster26175 { label="WholeStageCodegen (1)"; 11701 [labelType="html" label="MapPartitionsRDD [11701] run at <unknown>:0"]; } subgraph cluster26189 { label="WholeStageCodegen (1)"; 11703 [labelType="html" label="MapPartitionsRDD [11703] toJavaRDD at <unknown>:0"]; } subgraph cluster26188 { label="Filter"; 11704 [labelType="html" label="MapPartitionsRDD [11704] toJavaRDD at <unknown>:0"]; } subgraph cluster26187 { label="Project"; 11705 [labelType="html" label="MapPartitionsRDD [11705] toJavaRDD at <unknown>:0"]; } subgraph cluster26184 { label="WholeStageCodegen (2)"; 11706 [labelType="html" label="MapPartitionsRDD [11706] toJavaRDD at <unknown>:0"]; } subgraph cluster26183 { label="Project"; 11707 [labelType="html" label="MapPartitionsRDD [11707] toJavaRDD at <unknown>:0"]; } subgraph cluster26182 { label="DeserializeToObject"; 11708 [labelType="html" label="MapPartitionsRDD [11708] toJavaRDD at <unknown>:0"]; } subgraph cluster26181 { label="MapPartitions"; 11709 [labelType="html" label="MapPartitionsRDD [11709] toJavaRDD at <unknown>:0"]; } subgraph cluster26191 { label="mapPartitions"; 11711 [labelType="html" label="MapPartitionsRDD [11711] toJavaRDD at <unknown>:0"]; } } 11698->11699; 11699->11700; 11700->11701; 11701->11702; 11702->11703; 11703->11704; 11704->11705; 11705->11706; 11706->11707; 11707->11708; 11708->11709; 11709->11710; 11710->11711; 11711->11718; }

Event Timeline

Enable zooming