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

digraph G { subgraph clusterstage_1981 { label="Stage 1981"; 20816 [labelType="html" label="SQLExecutionRDD [20816] run at <unknown>:0"]; 20824 [labelType="html" label="SQLExecutionRDD [20824] toJavaRDD at <unknown>:0"]; 20826 [labelType="html" label="PythonRDD [20826] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46578 { label="MicroBatchScan"; 20812 [labelType="html" label="DataSourceRDD [20812] run at <unknown>:0"]; 20813 [labelType="html" label="MapPartitionsRDD [20813] run at <unknown>:0"]; } subgraph cluster46577 { label="Project"; 20814 [labelType="html" label="MapPartitionsRDD [20814] run at <unknown>:0"]; } subgraph cluster46573 { label="WholeStageCodegen (1)"; 20815 [labelType="html" label="MapPartitionsRDD [20815] run at <unknown>:0"]; } subgraph cluster46587 { label="WholeStageCodegen (1)"; 20817 [labelType="html" label="MapPartitionsRDD [20817] toJavaRDD at <unknown>:0"]; } subgraph cluster46586 { label="Filter"; 20818 [labelType="html" label="MapPartitionsRDD [20818] toJavaRDD at <unknown>:0"]; } subgraph cluster46585 { label="Project"; 20819 [labelType="html" label="MapPartitionsRDD [20819] toJavaRDD at <unknown>:0"]; } subgraph cluster46582 { label="WholeStageCodegen (2)"; 20820 [labelType="html" label="MapPartitionsRDD [20820] toJavaRDD at <unknown>:0"]; } subgraph cluster46581 { label="Project"; 20821 [labelType="html" label="MapPartitionsRDD [20821] toJavaRDD at <unknown>:0"]; } subgraph cluster46580 { label="DeserializeToObject"; 20822 [labelType="html" label="MapPartitionsRDD [20822] toJavaRDD at <unknown>:0"]; } subgraph cluster46579 { label="MapPartitions"; 20823 [labelType="html" label="MapPartitionsRDD [20823] toJavaRDD at <unknown>:0"]; } subgraph cluster46589 { label="mapPartitions"; 20825 [labelType="html" label="MapPartitionsRDD [20825] toJavaRDD at <unknown>:0"]; } } 20812->20813; 20813->20814; 20814->20815; 20815->20816; 20816->20817; 20817->20818; 20818->20819; 20819->20820; 20820->20821; 20821->20822; 20822->20823; 20823->20824; 20824->20825; 20825->20826; }

Event Timeline

Enable zooming