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

digraph G { subgraph clusterstage_1099 { label="Stage 1099"; 11555 [labelType="html" label="SQLExecutionRDD [11555] run at <unknown>:0"]; 11563 [labelType="html" label="SQLExecutionRDD [11563] toJavaRDD at <unknown>:0"]; 11565 [labelType="html" label="PythonRDD [11565] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25851 { label="MicroBatchScan"; 11551 [labelType="html" label="DataSourceRDD [11551] run at <unknown>:0"]; 11552 [labelType="html" label="MapPartitionsRDD [11552] run at <unknown>:0"]; } subgraph cluster25850 { label="Project"; 11553 [labelType="html" label="MapPartitionsRDD [11553] run at <unknown>:0"]; } subgraph cluster25846 { label="WholeStageCodegen (1)"; 11554 [labelType="html" label="MapPartitionsRDD [11554] run at <unknown>:0"]; } subgraph cluster25860 { label="WholeStageCodegen (1)"; 11556 [labelType="html" label="MapPartitionsRDD [11556] toJavaRDD at <unknown>:0"]; } subgraph cluster25859 { label="Filter"; 11557 [labelType="html" label="MapPartitionsRDD [11557] toJavaRDD at <unknown>:0"]; } subgraph cluster25858 { label="Project"; 11558 [labelType="html" label="MapPartitionsRDD [11558] toJavaRDD at <unknown>:0"]; } subgraph cluster25855 { label="WholeStageCodegen (2)"; 11559 [labelType="html" label="MapPartitionsRDD [11559] toJavaRDD at <unknown>:0"]; } subgraph cluster25854 { label="Project"; 11560 [labelType="html" label="MapPartitionsRDD [11560] toJavaRDD at <unknown>:0"]; } subgraph cluster25853 { label="DeserializeToObject"; 11561 [labelType="html" label="MapPartitionsRDD [11561] toJavaRDD at <unknown>:0"]; } subgraph cluster25852 { label="MapPartitions"; 11562 [labelType="html" label="MapPartitionsRDD [11562] toJavaRDD at <unknown>:0"]; } subgraph cluster25862 { label="mapPartitions"; 11564 [labelType="html" label="MapPartitionsRDD [11564] toJavaRDD at <unknown>:0"]; } } 11551->11552; 11552->11553; 11553->11554; 11554->11555; 11555->11556; 11556->11557; 11557->11558; 11558->11559; 11559->11560; 11560->11561; 11561->11562; 11562->11563; 11563->11564; 11564->11565; }

Event Timeline

Enable zooming