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

digraph G { subgraph clusterstage_1048 { label="Stage 1048"; 11009 [labelType="html" label="SQLExecutionRDD [11009] run at <unknown>:0"]; 11023 [labelType="html" label="SQLExecutionRDD [11023] toJavaRDD at <unknown>:0"]; 11025 [labelType="html" label="PythonRDD [11025] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24629 { label="MicroBatchScan"; 11005 [labelType="html" label="DataSourceRDD [11005] run at <unknown>:0"]; 11006 [labelType="html" label="MapPartitionsRDD [11006] run at <unknown>:0"]; } subgraph cluster24628 { label="Project"; 11007 [labelType="html" label="MapPartitionsRDD [11007] run at <unknown>:0"]; } subgraph cluster24624 { label="WholeStageCodegen (1)"; 11008 [labelType="html" label="MapPartitionsRDD [11008] run at <unknown>:0"]; } subgraph cluster24646 { label="WholeStageCodegen (1)"; 11016 [labelType="html" label="MapPartitionsRDD [11016] toJavaRDD at <unknown>:0"]; } subgraph cluster24645 { label="Filter"; 11017 [labelType="html" label="MapPartitionsRDD [11017] toJavaRDD at <unknown>:0"]; } subgraph cluster24644 { label="Project"; 11018 [labelType="html" label="MapPartitionsRDD [11018] toJavaRDD at <unknown>:0"]; } subgraph cluster24641 { label="WholeStageCodegen (2)"; 11019 [labelType="html" label="MapPartitionsRDD [11019] toJavaRDD at <unknown>:0"]; } subgraph cluster24640 { label="Project"; 11020 [labelType="html" label="MapPartitionsRDD [11020] toJavaRDD at <unknown>:0"]; } subgraph cluster24639 { label="DeserializeToObject"; 11021 [labelType="html" label="MapPartitionsRDD [11021] toJavaRDD at <unknown>:0"]; } subgraph cluster24638 { label="MapPartitions"; 11022 [labelType="html" label="MapPartitionsRDD [11022] toJavaRDD at <unknown>:0"]; } subgraph cluster24648 { label="mapPartitions"; 11024 [labelType="html" label="MapPartitionsRDD [11024] toJavaRDD at <unknown>:0"]; } } 11005->11006; 11006->11007; 11007->11008; 11008->11009; 11009->11016; 11016->11017; 11017->11018; 11018->11019; 11019->11020; 11020->11021; 11021->11022; 11022->11023; 11023->11024; 11024->11025; }

Event Timeline

Enable zooming