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

digraph G { subgraph clusterstage_1017 { label="Stage 1017"; 10694 [labelType="html" label="SQLExecutionRDD [10694] run at <unknown>:0"]; 10702 [labelType="html" label="SQLExecutionRDD [10702] toJavaRDD at <unknown>:0"]; 10704 [labelType="html" label="PythonRDD [10704] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23924 { label="MicroBatchScan"; 10690 [labelType="html" label="DataSourceRDD [10690] run at <unknown>:0"]; 10691 [labelType="html" label="MapPartitionsRDD [10691] run at <unknown>:0"]; } subgraph cluster23923 { label="Project"; 10692 [labelType="html" label="MapPartitionsRDD [10692] run at <unknown>:0"]; } subgraph cluster23919 { label="WholeStageCodegen (1)"; 10693 [labelType="html" label="MapPartitionsRDD [10693] run at <unknown>:0"]; } subgraph cluster23933 { label="WholeStageCodegen (1)"; 10695 [labelType="html" label="MapPartitionsRDD [10695] toJavaRDD at <unknown>:0"]; } subgraph cluster23932 { label="Filter"; 10696 [labelType="html" label="MapPartitionsRDD [10696] toJavaRDD at <unknown>:0"]; } subgraph cluster23931 { label="Project"; 10697 [labelType="html" label="MapPartitionsRDD [10697] toJavaRDD at <unknown>:0"]; } subgraph cluster23928 { label="WholeStageCodegen (2)"; 10698 [labelType="html" label="MapPartitionsRDD [10698] toJavaRDD at <unknown>:0"]; } subgraph cluster23927 { label="Project"; 10699 [labelType="html" label="MapPartitionsRDD [10699] toJavaRDD at <unknown>:0"]; } subgraph cluster23926 { label="DeserializeToObject"; 10700 [labelType="html" label="MapPartitionsRDD [10700] toJavaRDD at <unknown>:0"]; } subgraph cluster23925 { label="MapPartitions"; 10701 [labelType="html" label="MapPartitionsRDD [10701] toJavaRDD at <unknown>:0"]; } subgraph cluster23935 { label="mapPartitions"; 10703 [labelType="html" label="MapPartitionsRDD [10703] toJavaRDD at <unknown>:0"]; } } 10690->10691; 10691->10692; 10692->10693; 10693->10694; 10694->10695; 10695->10696; 10696->10697; 10697->10698; 10698->10699; 10699->10700; 10700->10701; 10701->10702; 10702->10703; 10703->10704; }

Event Timeline

Enable zooming