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

digraph G { subgraph clusterstage_712 { label="Stage 712"; 7480 [labelType="html" label="SQLExecutionRDD [7480] run at <unknown>:0"]; 7488 [labelType="html" label="SQLExecutionRDD [7488] toJavaRDD at <unknown>:0"]; 7490 [labelType="html" label="PythonRDD [7490] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster16737 { label="MicroBatchScan"; 7476 [labelType="html" label="DataSourceRDD [7476] run at <unknown>:0"]; 7477 [labelType="html" label="MapPartitionsRDD [7477] run at <unknown>:0"]; } subgraph cluster16736 { label="Project"; 7478 [labelType="html" label="MapPartitionsRDD [7478] run at <unknown>:0"]; } subgraph cluster16732 { label="WholeStageCodegen (1)"; 7479 [labelType="html" label="MapPartitionsRDD [7479] run at <unknown>:0"]; } subgraph cluster16746 { label="WholeStageCodegen (1)"; 7481 [labelType="html" label="MapPartitionsRDD [7481] toJavaRDD at <unknown>:0"]; } subgraph cluster16745 { label="Filter"; 7482 [labelType="html" label="MapPartitionsRDD [7482] toJavaRDD at <unknown>:0"]; } subgraph cluster16744 { label="Project"; 7483 [labelType="html" label="MapPartitionsRDD [7483] toJavaRDD at <unknown>:0"]; } subgraph cluster16741 { label="WholeStageCodegen (2)"; 7484 [labelType="html" label="MapPartitionsRDD [7484] toJavaRDD at <unknown>:0"]; } subgraph cluster16740 { label="Project"; 7485 [labelType="html" label="MapPartitionsRDD [7485] toJavaRDD at <unknown>:0"]; } subgraph cluster16739 { label="DeserializeToObject"; 7486 [labelType="html" label="MapPartitionsRDD [7486] toJavaRDD at <unknown>:0"]; } subgraph cluster16738 { label="MapPartitions"; 7487 [labelType="html" label="MapPartitionsRDD [7487] toJavaRDD at <unknown>:0"]; } subgraph cluster16748 { label="mapPartitions"; 7489 [labelType="html" label="MapPartitionsRDD [7489] toJavaRDD at <unknown>:0"]; } } 7476->7477; 7477->7478; 7478->7479; 7479->7480; 7480->7481; 7481->7482; 7482->7483; 7483->7484; 7484->7485; 7485->7486; 7486->7487; 7487->7488; 7488->7489; 7489->7490; }

Event Timeline

Enable zooming