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

digraph G { subgraph clusterstage_251 { label="Stage 251"; 2635 [labelType="html" label="SQLExecutionRDD [2635] run at <unknown>:0"]; 2643 [labelType="html" label="SQLExecutionRDD [2643] toJavaRDD at <unknown>:0"]; 2645 [labelType="html" label="PythonRDD [2645] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5888 { label="MicroBatchScan"; 2631 [labelType="html" label="DataSourceRDD [2631] run at <unknown>:0"]; 2632 [labelType="html" label="MapPartitionsRDD [2632] run at <unknown>:0"]; } subgraph cluster5887 { label="Project"; 2633 [labelType="html" label="MapPartitionsRDD [2633] run at <unknown>:0"]; } subgraph cluster5883 { label="WholeStageCodegen (1)"; 2634 [labelType="html" label="MapPartitionsRDD [2634] run at <unknown>:0"]; } subgraph cluster5897 { label="WholeStageCodegen (1)"; 2636 [labelType="html" label="MapPartitionsRDD [2636] toJavaRDD at <unknown>:0"]; } subgraph cluster5896 { label="Filter"; 2637 [labelType="html" label="MapPartitionsRDD [2637] toJavaRDD at <unknown>:0"]; } subgraph cluster5895 { label="Project"; 2638 [labelType="html" label="MapPartitionsRDD [2638] toJavaRDD at <unknown>:0"]; } subgraph cluster5892 { label="WholeStageCodegen (2)"; 2639 [labelType="html" label="MapPartitionsRDD [2639] toJavaRDD at <unknown>:0"]; } subgraph cluster5891 { label="Project"; 2640 [labelType="html" label="MapPartitionsRDD [2640] toJavaRDD at <unknown>:0"]; } subgraph cluster5890 { label="DeserializeToObject"; 2641 [labelType="html" label="MapPartitionsRDD [2641] toJavaRDD at <unknown>:0"]; } subgraph cluster5889 { label="MapPartitions"; 2642 [labelType="html" label="MapPartitionsRDD [2642] toJavaRDD at <unknown>:0"]; } subgraph cluster5899 { label="mapPartitions"; 2644 [labelType="html" label="MapPartitionsRDD [2644] toJavaRDD at <unknown>:0"]; } } 2631->2632; 2632->2633; 2633->2634; 2634->2635; 2635->2636; 2636->2637; 2637->2638; 2638->2639; 2639->2640; 2640->2641; 2641->2642; 2642->2643; 2643->2644; 2644->2645; }

Event Timeline

Enable zooming