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

digraph G { subgraph clusterstage_90 { label="Stage 90"; 949 [labelType="html" label="SQLExecutionRDD [949] run at <unknown>:0"]; 957 [labelType="html" label="SQLExecutionRDD [957] toJavaRDD at <unknown>:0"]; 959 [labelType="html" label="PythonRDD [959] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2120 { label="MicroBatchScan"; 945 [labelType="html" label="DataSourceRDD [945] run at <unknown>:0"]; 946 [labelType="html" label="MapPartitionsRDD [946] run at <unknown>:0"]; } subgraph cluster2119 { label="Project"; 947 [labelType="html" label="MapPartitionsRDD [947] run at <unknown>:0"]; } subgraph cluster2115 { label="WholeStageCodegen (1)"; 948 [labelType="html" label="MapPartitionsRDD [948] run at <unknown>:0"]; } subgraph cluster2129 { label="WholeStageCodegen (1)"; 950 [labelType="html" label="MapPartitionsRDD [950] toJavaRDD at <unknown>:0"]; } subgraph cluster2128 { label="Filter"; 951 [labelType="html" label="MapPartitionsRDD [951] toJavaRDD at <unknown>:0"]; } subgraph cluster2127 { label="Project"; 952 [labelType="html" label="MapPartitionsRDD [952] toJavaRDD at <unknown>:0"]; } subgraph cluster2124 { label="WholeStageCodegen (2)"; 953 [labelType="html" label="MapPartitionsRDD [953] toJavaRDD at <unknown>:0"]; } subgraph cluster2123 { label="Project"; 954 [labelType="html" label="MapPartitionsRDD [954] toJavaRDD at <unknown>:0"]; } subgraph cluster2122 { label="DeserializeToObject"; 955 [labelType="html" label="MapPartitionsRDD [955] toJavaRDD at <unknown>:0"]; } subgraph cluster2121 { label="MapPartitions"; 956 [labelType="html" label="MapPartitionsRDD [956] toJavaRDD at <unknown>:0"]; } subgraph cluster2131 { label="mapPartitions"; 958 [labelType="html" label="MapPartitionsRDD [958] toJavaRDD at <unknown>:0"]; } } 945->946; 946->947; 947->948; 948->949; 949->950; 950->951; 951->952; 952->953; 953->954; 954->955; 955->956; 956->957; 957->958; 958->959; }

Event Timeline

Enable zooming