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

digraph G { subgraph clusterstage_1818 { label="Stage 1818"; 19093 [labelType="html" label="SQLExecutionRDD [19093] run at <unknown>:0"]; 19101 [labelType="html" label="SQLExecutionRDD [19101] toJavaRDD at <unknown>:0"]; 19103 [labelType="html" label="PythonRDD [19103] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42728 { label="MicroBatchScan"; 19089 [labelType="html" label="DataSourceRDD [19089] run at <unknown>:0"]; 19090 [labelType="html" label="MapPartitionsRDD [19090] run at <unknown>:0"]; } subgraph cluster42727 { label="Project"; 19091 [labelType="html" label="MapPartitionsRDD [19091] run at <unknown>:0"]; } subgraph cluster42723 { label="WholeStageCodegen (1)"; 19092 [labelType="html" label="MapPartitionsRDD [19092] run at <unknown>:0"]; } subgraph cluster42737 { label="WholeStageCodegen (1)"; 19094 [labelType="html" label="MapPartitionsRDD [19094] toJavaRDD at <unknown>:0"]; } subgraph cluster42736 { label="Filter"; 19095 [labelType="html" label="MapPartitionsRDD [19095] toJavaRDD at <unknown>:0"]; } subgraph cluster42735 { label="Project"; 19096 [labelType="html" label="MapPartitionsRDD [19096] toJavaRDD at <unknown>:0"]; } subgraph cluster42732 { label="WholeStageCodegen (2)"; 19097 [labelType="html" label="MapPartitionsRDD [19097] toJavaRDD at <unknown>:0"]; } subgraph cluster42731 { label="Project"; 19098 [labelType="html" label="MapPartitionsRDD [19098] toJavaRDD at <unknown>:0"]; } subgraph cluster42730 { label="DeserializeToObject"; 19099 [labelType="html" label="MapPartitionsRDD [19099] toJavaRDD at <unknown>:0"]; } subgraph cluster42729 { label="MapPartitions"; 19100 [labelType="html" label="MapPartitionsRDD [19100] toJavaRDD at <unknown>:0"]; } subgraph cluster42739 { label="mapPartitions"; 19102 [labelType="html" label="MapPartitionsRDD [19102] toJavaRDD at <unknown>:0"]; } } 19089->19090; 19090->19091; 19091->19092; 19092->19093; 19093->19094; 19094->19095; 19095->19096; 19096->19097; 19097->19098; 19098->19099; 19099->19100; 19100->19101; 19101->19102; 19102->19103; }

Event Timeline

Enable zooming