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

digraph G { subgraph clusterstage_1249 { label="Stage 1249"; 13130 [labelType="html" label="SQLExecutionRDD [13130] run at <unknown>:0"]; 13138 [labelType="html" label="SQLExecutionRDD [13138] toJavaRDD at <unknown>:0"]; 13140 [labelType="html" label="PythonRDD [13140] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29376 { label="MicroBatchScan"; 13126 [labelType="html" label="DataSourceRDD [13126] run at <unknown>:0"]; 13127 [labelType="html" label="MapPartitionsRDD [13127] run at <unknown>:0"]; } subgraph cluster29375 { label="Project"; 13128 [labelType="html" label="MapPartitionsRDD [13128] run at <unknown>:0"]; } subgraph cluster29371 { label="WholeStageCodegen (1)"; 13129 [labelType="html" label="MapPartitionsRDD [13129] run at <unknown>:0"]; } subgraph cluster29385 { label="WholeStageCodegen (1)"; 13131 [labelType="html" label="MapPartitionsRDD [13131] toJavaRDD at <unknown>:0"]; } subgraph cluster29384 { label="Filter"; 13132 [labelType="html" label="MapPartitionsRDD [13132] toJavaRDD at <unknown>:0"]; } subgraph cluster29383 { label="Project"; 13133 [labelType="html" label="MapPartitionsRDD [13133] toJavaRDD at <unknown>:0"]; } subgraph cluster29380 { label="WholeStageCodegen (2)"; 13134 [labelType="html" label="MapPartitionsRDD [13134] toJavaRDD at <unknown>:0"]; } subgraph cluster29379 { label="Project"; 13135 [labelType="html" label="MapPartitionsRDD [13135] toJavaRDD at <unknown>:0"]; } subgraph cluster29378 { label="DeserializeToObject"; 13136 [labelType="html" label="MapPartitionsRDD [13136] toJavaRDD at <unknown>:0"]; } subgraph cluster29377 { label="MapPartitions"; 13137 [labelType="html" label="MapPartitionsRDD [13137] toJavaRDD at <unknown>:0"]; } subgraph cluster29387 { label="mapPartitions"; 13139 [labelType="html" label="MapPartitionsRDD [13139] toJavaRDD at <unknown>:0"]; } } 13126->13127; 13127->13128; 13128->13129; 13129->13130; 13130->13131; 13131->13132; 13132->13133; 13133->13134; 13134->13135; 13135->13136; 13136->13137; 13137->13138; 13138->13139; 13139->13140; }

Event Timeline

Enable zooming