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

digraph G { subgraph clusterstage_1255 { label="Stage 1255"; 13193 [labelType="html" label="SQLExecutionRDD [13193] run at <unknown>:0"]; 13201 [labelType="html" label="SQLExecutionRDD [13201] toJavaRDD at <unknown>:0"]; 13203 [labelType="html" label="PythonRDD [13203] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29517 { label="MicroBatchScan"; 13189 [labelType="html" label="DataSourceRDD [13189] run at <unknown>:0"]; 13190 [labelType="html" label="MapPartitionsRDD [13190] run at <unknown>:0"]; } subgraph cluster29516 { label="Project"; 13191 [labelType="html" label="MapPartitionsRDD [13191] run at <unknown>:0"]; } subgraph cluster29512 { label="WholeStageCodegen (1)"; 13192 [labelType="html" label="MapPartitionsRDD [13192] run at <unknown>:0"]; } subgraph cluster29526 { label="WholeStageCodegen (1)"; 13194 [labelType="html" label="MapPartitionsRDD [13194] toJavaRDD at <unknown>:0"]; } subgraph cluster29525 { label="Filter"; 13195 [labelType="html" label="MapPartitionsRDD [13195] toJavaRDD at <unknown>:0"]; } subgraph cluster29524 { label="Project"; 13196 [labelType="html" label="MapPartitionsRDD [13196] toJavaRDD at <unknown>:0"]; } subgraph cluster29521 { label="WholeStageCodegen (2)"; 13197 [labelType="html" label="MapPartitionsRDD [13197] toJavaRDD at <unknown>:0"]; } subgraph cluster29520 { label="Project"; 13198 [labelType="html" label="MapPartitionsRDD [13198] toJavaRDD at <unknown>:0"]; } subgraph cluster29519 { label="DeserializeToObject"; 13199 [labelType="html" label="MapPartitionsRDD [13199] toJavaRDD at <unknown>:0"]; } subgraph cluster29518 { label="MapPartitions"; 13200 [labelType="html" label="MapPartitionsRDD [13200] toJavaRDD at <unknown>:0"]; } subgraph cluster29528 { label="mapPartitions"; 13202 [labelType="html" label="MapPartitionsRDD [13202] toJavaRDD at <unknown>:0"]; } } 13189->13190; 13190->13191; 13191->13192; 13192->13193; 13193->13194; 13194->13195; 13195->13196; 13196->13197; 13197->13198; 13198->13199; 13199->13200; 13200->13201; 13201->13202; 13202->13203; }

Event Timeline

Enable zooming