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

digraph G { subgraph clusterstage_1510 { label="Stage 1510"; 15859 [labelType="html" label="SQLExecutionRDD [15859] run at <unknown>:0"]; 15867 [labelType="html" label="SQLExecutionRDD [15867] toJavaRDD at <unknown>:0"]; 15869 [labelType="html" label="PythonRDD [15869] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35490 { label="MicroBatchScan"; 15855 [labelType="html" label="DataSourceRDD [15855] run at <unknown>:0"]; 15856 [labelType="html" label="MapPartitionsRDD [15856] run at <unknown>:0"]; } subgraph cluster35489 { label="Project"; 15857 [labelType="html" label="MapPartitionsRDD [15857] run at <unknown>:0"]; } subgraph cluster35485 { label="WholeStageCodegen (1)"; 15858 [labelType="html" label="MapPartitionsRDD [15858] run at <unknown>:0"]; } subgraph cluster35499 { label="WholeStageCodegen (1)"; 15860 [labelType="html" label="MapPartitionsRDD [15860] toJavaRDD at <unknown>:0"]; } subgraph cluster35498 { label="Filter"; 15861 [labelType="html" label="MapPartitionsRDD [15861] toJavaRDD at <unknown>:0"]; } subgraph cluster35497 { label="Project"; 15862 [labelType="html" label="MapPartitionsRDD [15862] toJavaRDD at <unknown>:0"]; } subgraph cluster35494 { label="WholeStageCodegen (2)"; 15863 [labelType="html" label="MapPartitionsRDD [15863] toJavaRDD at <unknown>:0"]; } subgraph cluster35493 { label="Project"; 15864 [labelType="html" label="MapPartitionsRDD [15864] toJavaRDD at <unknown>:0"]; } subgraph cluster35492 { label="DeserializeToObject"; 15865 [labelType="html" label="MapPartitionsRDD [15865] toJavaRDD at <unknown>:0"]; } subgraph cluster35491 { label="MapPartitions"; 15866 [labelType="html" label="MapPartitionsRDD [15866] toJavaRDD at <unknown>:0"]; } subgraph cluster35501 { label="mapPartitions"; 15868 [labelType="html" label="MapPartitionsRDD [15868] toJavaRDD at <unknown>:0"]; } } 15855->15856; 15856->15857; 15857->15858; 15858->15859; 15859->15860; 15860->15861; 15861->15862; 15862->15863; 15863->15864; 15864->15865; 15865->15866; 15866->15867; 15867->15868; 15868->15869; }

Event Timeline

Enable zooming