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

digraph G { subgraph clusterstage_1876 { label="Stage 1876"; 19702 [labelType="html" label="SQLExecutionRDD [19702] run at <unknown>:0"]; 19710 [labelType="html" label="SQLExecutionRDD [19710] toJavaRDD at <unknown>:0"]; 19712 [labelType="html" label="PythonRDD [19712] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44091 { label="MicroBatchScan"; 19698 [labelType="html" label="DataSourceRDD [19698] run at <unknown>:0"]; 19699 [labelType="html" label="MapPartitionsRDD [19699] run at <unknown>:0"]; } subgraph cluster44090 { label="Project"; 19700 [labelType="html" label="MapPartitionsRDD [19700] run at <unknown>:0"]; } subgraph cluster44086 { label="WholeStageCodegen (1)"; 19701 [labelType="html" label="MapPartitionsRDD [19701] run at <unknown>:0"]; } subgraph cluster44100 { label="WholeStageCodegen (1)"; 19703 [labelType="html" label="MapPartitionsRDD [19703] toJavaRDD at <unknown>:0"]; } subgraph cluster44099 { label="Filter"; 19704 [labelType="html" label="MapPartitionsRDD [19704] toJavaRDD at <unknown>:0"]; } subgraph cluster44098 { label="Project"; 19705 [labelType="html" label="MapPartitionsRDD [19705] toJavaRDD at <unknown>:0"]; } subgraph cluster44095 { label="WholeStageCodegen (2)"; 19706 [labelType="html" label="MapPartitionsRDD [19706] toJavaRDD at <unknown>:0"]; } subgraph cluster44094 { label="Project"; 19707 [labelType="html" label="MapPartitionsRDD [19707] toJavaRDD at <unknown>:0"]; } subgraph cluster44093 { label="DeserializeToObject"; 19708 [labelType="html" label="MapPartitionsRDD [19708] toJavaRDD at <unknown>:0"]; } subgraph cluster44092 { label="MapPartitions"; 19709 [labelType="html" label="MapPartitionsRDD [19709] toJavaRDD at <unknown>:0"]; } subgraph cluster44102 { label="mapPartitions"; 19711 [labelType="html" label="MapPartitionsRDD [19711] toJavaRDD at <unknown>:0"]; } } 19698->19699; 19699->19700; 19700->19701; 19701->19702; 19702->19703; 19703->19704; 19704->19705; 19705->19706; 19706->19707; 19707->19708; 19708->19709; 19709->19710; 19710->19711; 19711->19712; }

Event Timeline

Enable zooming