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

digraph G { subgraph clusterstage_469 { label="Stage 469"; 4940 [labelType="html" label="SQLExecutionRDD [4940] run at <unknown>:0"]; 4948 [labelType="html" label="SQLExecutionRDD [4948] toJavaRDD at <unknown>:0"]; 4950 [labelType="html" label="PythonRDD [4950] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster11046 { label="MicroBatchScan"; 4936 [labelType="html" label="DataSourceRDD [4936] run at <unknown>:0"]; 4937 [labelType="html" label="MapPartitionsRDD [4937] run at <unknown>:0"]; } subgraph cluster11045 { label="Project"; 4938 [labelType="html" label="MapPartitionsRDD [4938] run at <unknown>:0"]; } subgraph cluster11041 { label="WholeStageCodegen (1)"; 4939 [labelType="html" label="MapPartitionsRDD [4939] run at <unknown>:0"]; } subgraph cluster11055 { label="WholeStageCodegen (1)"; 4941 [labelType="html" label="MapPartitionsRDD [4941] toJavaRDD at <unknown>:0"]; } subgraph cluster11054 { label="Filter"; 4942 [labelType="html" label="MapPartitionsRDD [4942] toJavaRDD at <unknown>:0"]; } subgraph cluster11053 { label="Project"; 4943 [labelType="html" label="MapPartitionsRDD [4943] toJavaRDD at <unknown>:0"]; } subgraph cluster11050 { label="WholeStageCodegen (2)"; 4944 [labelType="html" label="MapPartitionsRDD [4944] toJavaRDD at <unknown>:0"]; } subgraph cluster11049 { label="Project"; 4945 [labelType="html" label="MapPartitionsRDD [4945] toJavaRDD at <unknown>:0"]; } subgraph cluster11048 { label="DeserializeToObject"; 4946 [labelType="html" label="MapPartitionsRDD [4946] toJavaRDD at <unknown>:0"]; } subgraph cluster11047 { label="MapPartitions"; 4947 [labelType="html" label="MapPartitionsRDD [4947] toJavaRDD at <unknown>:0"]; } subgraph cluster11057 { label="mapPartitions"; 4949 [labelType="html" label="MapPartitionsRDD [4949] toJavaRDD at <unknown>:0"]; } } 4936->4937; 4937->4938; 4938->4939; 4939->4940; 4940->4941; 4941->4942; 4942->4943; 4943->4944; 4944->4945; 4945->4946; 4946->4947; 4947->4948; 4948->4949; 4949->4950; }

Event Timeline

Enable zooming