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

digraph G { subgraph clusterstage_698 { label="Stage 698"; 7334 [labelType="html" label="SQLExecutionRDD [7334] run at <unknown>:0"]; 7348 [labelType="html" label="SQLExecutionRDD [7348] toJavaRDD at <unknown>:0"]; 7350 [labelType="html" label="PythonRDD [7350] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster16404 { label="MicroBatchScan"; 7330 [labelType="html" label="DataSourceRDD [7330] run at <unknown>:0"]; 7331 [labelType="html" label="MapPartitionsRDD [7331] run at <unknown>:0"]; } subgraph cluster16403 { label="Project"; 7332 [labelType="html" label="MapPartitionsRDD [7332] run at <unknown>:0"]; } subgraph cluster16399 { label="WholeStageCodegen (1)"; 7333 [labelType="html" label="MapPartitionsRDD [7333] run at <unknown>:0"]; } subgraph cluster16421 { label="WholeStageCodegen (1)"; 7341 [labelType="html" label="MapPartitionsRDD [7341] toJavaRDD at <unknown>:0"]; } subgraph cluster16420 { label="Filter"; 7342 [labelType="html" label="MapPartitionsRDD [7342] toJavaRDD at <unknown>:0"]; } subgraph cluster16419 { label="Project"; 7343 [labelType="html" label="MapPartitionsRDD [7343] toJavaRDD at <unknown>:0"]; } subgraph cluster16416 { label="WholeStageCodegen (2)"; 7344 [labelType="html" label="MapPartitionsRDD [7344] toJavaRDD at <unknown>:0"]; } subgraph cluster16415 { label="Project"; 7345 [labelType="html" label="MapPartitionsRDD [7345] toJavaRDD at <unknown>:0"]; } subgraph cluster16414 { label="DeserializeToObject"; 7346 [labelType="html" label="MapPartitionsRDD [7346] toJavaRDD at <unknown>:0"]; } subgraph cluster16413 { label="MapPartitions"; 7347 [labelType="html" label="MapPartitionsRDD [7347] toJavaRDD at <unknown>:0"]; } subgraph cluster16423 { label="mapPartitions"; 7349 [labelType="html" label="MapPartitionsRDD [7349] toJavaRDD at <unknown>:0"]; } } 7330->7331; 7331->7332; 7332->7333; 7333->7334; 7334->7341; 7341->7342; 7342->7343; 7343->7344; 7344->7345; 7345->7346; 7346->7347; 7347->7348; 7348->7349; 7349->7350; }

Event Timeline

Enable zooming