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

digraph G { subgraph clusterstage_910 { label="Stage 910"; 9560 [labelType="html" label="SQLExecutionRDD [9560] run at <unknown>:0"]; 9574 [labelType="html" label="SQLExecutionRDD [9574] toJavaRDD at <unknown>:0"]; 9576 [labelType="html" label="PythonRDD [9576] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21386 { label="MicroBatchScan"; 9556 [labelType="html" label="DataSourceRDD [9556] run at <unknown>:0"]; 9557 [labelType="html" label="MapPartitionsRDD [9557] run at <unknown>:0"]; } subgraph cluster21385 { label="Project"; 9558 [labelType="html" label="MapPartitionsRDD [9558] run at <unknown>:0"]; } subgraph cluster21381 { label="WholeStageCodegen (1)"; 9559 [labelType="html" label="MapPartitionsRDD [9559] run at <unknown>:0"]; } subgraph cluster21403 { label="WholeStageCodegen (1)"; 9567 [labelType="html" label="MapPartitionsRDD [9567] toJavaRDD at <unknown>:0"]; } subgraph cluster21402 { label="Filter"; 9568 [labelType="html" label="MapPartitionsRDD [9568] toJavaRDD at <unknown>:0"]; } subgraph cluster21401 { label="Project"; 9569 [labelType="html" label="MapPartitionsRDD [9569] toJavaRDD at <unknown>:0"]; } subgraph cluster21398 { label="WholeStageCodegen (2)"; 9570 [labelType="html" label="MapPartitionsRDD [9570] toJavaRDD at <unknown>:0"]; } subgraph cluster21397 { label="Project"; 9571 [labelType="html" label="MapPartitionsRDD [9571] toJavaRDD at <unknown>:0"]; } subgraph cluster21396 { label="DeserializeToObject"; 9572 [labelType="html" label="MapPartitionsRDD [9572] toJavaRDD at <unknown>:0"]; } subgraph cluster21395 { label="MapPartitions"; 9573 [labelType="html" label="MapPartitionsRDD [9573] toJavaRDD at <unknown>:0"]; } subgraph cluster21405 { label="mapPartitions"; 9575 [labelType="html" label="MapPartitionsRDD [9575] toJavaRDD at <unknown>:0"]; } } 9556->9557; 9557->9558; 9558->9559; 9559->9560; 9560->9567; 9567->9568; 9568->9569; 9569->9570; 9570->9571; 9571->9572; 9572->9573; 9573->9574; 9574->9575; 9575->9576; }

Event Timeline

Enable zooming