processing-stream-kafka-raw-to-minio - Details for Stage 566 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 410
Associated Job Ids: 566

digraph G { subgraph clusterstage_566 { label="Stage 566"; 5947 [labelType="html" label="SQLExecutionRDD [5947] run at <unknown>:0"]; 5955 [labelType="html" label="SQLExecutionRDD [5955] toJavaRDD at <unknown>:0"]; 5957 [labelType="html" label="PythonRDD [5957] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13306 { label="MicroBatchScan"; 5943 [labelType="html" label="DataSourceRDD [5943] run at <unknown>:0"]; 5944 [labelType="html" label="MapPartitionsRDD [5944] run at <unknown>:0"]; } subgraph cluster13305 { label="Project"; 5945 [labelType="html" label="MapPartitionsRDD [5945] run at <unknown>:0"]; } subgraph cluster13301 { label="WholeStageCodegen (1)"; 5946 [labelType="html" label="MapPartitionsRDD [5946] run at <unknown>:0"]; } subgraph cluster13315 { label="WholeStageCodegen (1)"; 5948 [labelType="html" label="MapPartitionsRDD [5948] toJavaRDD at <unknown>:0"]; } subgraph cluster13314 { label="Filter"; 5949 [labelType="html" label="MapPartitionsRDD [5949] toJavaRDD at <unknown>:0"]; } subgraph cluster13313 { label="Project"; 5950 [labelType="html" label="MapPartitionsRDD [5950] toJavaRDD at <unknown>:0"]; } subgraph cluster13310 { label="WholeStageCodegen (2)"; 5951 [labelType="html" label="MapPartitionsRDD [5951] toJavaRDD at <unknown>:0"]; } subgraph cluster13309 { label="Project"; 5952 [labelType="html" label="MapPartitionsRDD [5952] toJavaRDD at <unknown>:0"]; } subgraph cluster13308 { label="DeserializeToObject"; 5953 [labelType="html" label="MapPartitionsRDD [5953] toJavaRDD at <unknown>:0"]; } subgraph cluster13307 { label="MapPartitions"; 5954 [labelType="html" label="MapPartitionsRDD [5954] toJavaRDD at <unknown>:0"]; } subgraph cluster13317 { label="mapPartitions"; 5956 [labelType="html" label="MapPartitionsRDD [5956] toJavaRDD at <unknown>:0"]; } } 5943->5944; 5944->5945; 5945->5946; 5946->5947; 5947->5948; 5948->5949; 5949->5950; 5950->5951; 5951->5952; 5952->5953; 5953->5954; 5954->5955; 5955->5956; 5956->5957; }

Event Timeline

Enable zooming