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

digraph G { subgraph clusterstage_117 { label="Stage 117"; 1222 [labelType="html" label="SQLExecutionRDD [1222] run at <unknown>:0"]; 1236 [labelType="html" label="SQLExecutionRDD [1236] toJavaRDD at <unknown>:0"]; 1238 [labelType="html" label="PythonRDD [1238] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2731 { label="MicroBatchScan"; 1218 [labelType="html" label="DataSourceRDD [1218] run at <unknown>:0"]; 1219 [labelType="html" label="MapPartitionsRDD [1219] run at <unknown>:0"]; } subgraph cluster2730 { label="Project"; 1220 [labelType="html" label="MapPartitionsRDD [1220] run at <unknown>:0"]; } subgraph cluster2726 { label="WholeStageCodegen (1)"; 1221 [labelType="html" label="MapPartitionsRDD [1221] run at <unknown>:0"]; } subgraph cluster2748 { label="WholeStageCodegen (1)"; 1229 [labelType="html" label="MapPartitionsRDD [1229] toJavaRDD at <unknown>:0"]; } subgraph cluster2747 { label="Filter"; 1230 [labelType="html" label="MapPartitionsRDD [1230] toJavaRDD at <unknown>:0"]; } subgraph cluster2746 { label="Project"; 1231 [labelType="html" label="MapPartitionsRDD [1231] toJavaRDD at <unknown>:0"]; } subgraph cluster2743 { label="WholeStageCodegen (2)"; 1232 [labelType="html" label="MapPartitionsRDD [1232] toJavaRDD at <unknown>:0"]; } subgraph cluster2742 { label="Project"; 1233 [labelType="html" label="MapPartitionsRDD [1233] toJavaRDD at <unknown>:0"]; } subgraph cluster2741 { label="DeserializeToObject"; 1234 [labelType="html" label="MapPartitionsRDD [1234] toJavaRDD at <unknown>:0"]; } subgraph cluster2740 { label="MapPartitions"; 1235 [labelType="html" label="MapPartitionsRDD [1235] toJavaRDD at <unknown>:0"]; } subgraph cluster2750 { label="mapPartitions"; 1237 [labelType="html" label="MapPartitionsRDD [1237] toJavaRDD at <unknown>:0"]; } } 1218->1219; 1219->1220; 1220->1221; 1221->1222; 1222->1229; 1229->1230; 1230->1231; 1231->1232; 1232->1233; 1233->1234; 1234->1235; 1235->1236; 1236->1237; 1237->1238; }

Event Timeline

Enable zooming