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

digraph G { subgraph clusterstage_1504 { label="Stage 1504"; 15796 [labelType="html" label="SQLExecutionRDD [15796] run at <unknown>:0"]; 15804 [labelType="html" label="SQLExecutionRDD [15804] toJavaRDD at <unknown>:0"]; 15806 [labelType="html" label="PythonRDD [15806] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35349 { label="MicroBatchScan"; 15792 [labelType="html" label="DataSourceRDD [15792] run at <unknown>:0"]; 15793 [labelType="html" label="MapPartitionsRDD [15793] run at <unknown>:0"]; } subgraph cluster35348 { label="Project"; 15794 [labelType="html" label="MapPartitionsRDD [15794] run at <unknown>:0"]; } subgraph cluster35344 { label="WholeStageCodegen (1)"; 15795 [labelType="html" label="MapPartitionsRDD [15795] run at <unknown>:0"]; } subgraph cluster35358 { label="WholeStageCodegen (1)"; 15797 [labelType="html" label="MapPartitionsRDD [15797] toJavaRDD at <unknown>:0"]; } subgraph cluster35357 { label="Filter"; 15798 [labelType="html" label="MapPartitionsRDD [15798] toJavaRDD at <unknown>:0"]; } subgraph cluster35356 { label="Project"; 15799 [labelType="html" label="MapPartitionsRDD [15799] toJavaRDD at <unknown>:0"]; } subgraph cluster35353 { label="WholeStageCodegen (2)"; 15800 [labelType="html" label="MapPartitionsRDD [15800] toJavaRDD at <unknown>:0"]; } subgraph cluster35352 { label="Project"; 15801 [labelType="html" label="MapPartitionsRDD [15801] toJavaRDD at <unknown>:0"]; } subgraph cluster35351 { label="DeserializeToObject"; 15802 [labelType="html" label="MapPartitionsRDD [15802] toJavaRDD at <unknown>:0"]; } subgraph cluster35350 { label="MapPartitions"; 15803 [labelType="html" label="MapPartitionsRDD [15803] toJavaRDD at <unknown>:0"]; } subgraph cluster35360 { label="mapPartitions"; 15805 [labelType="html" label="MapPartitionsRDD [15805] toJavaRDD at <unknown>:0"]; } } 15792->15793; 15793->15794; 15794->15795; 15795->15796; 15796->15797; 15797->15798; 15798->15799; 15799->15800; 15800->15801; 15801->15802; 15802->15803; 15803->15804; 15804->15805; 15805->15806; }

Event Timeline

Enable zooming