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

digraph G { subgraph clusterstage_1776 { label="Stage 1776"; 18652 [labelType="html" label="SQLExecutionRDD [18652] run at <unknown>:0"]; 18660 [labelType="html" label="SQLExecutionRDD [18660] toJavaRDD at <unknown>:0"]; 18662 [labelType="html" label="PythonRDD [18662] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41741 { label="MicroBatchScan"; 18648 [labelType="html" label="DataSourceRDD [18648] run at <unknown>:0"]; 18649 [labelType="html" label="MapPartitionsRDD [18649] run at <unknown>:0"]; } subgraph cluster41740 { label="Project"; 18650 [labelType="html" label="MapPartitionsRDD [18650] run at <unknown>:0"]; } subgraph cluster41736 { label="WholeStageCodegen (1)"; 18651 [labelType="html" label="MapPartitionsRDD [18651] run at <unknown>:0"]; } subgraph cluster41750 { label="WholeStageCodegen (1)"; 18653 [labelType="html" label="MapPartitionsRDD [18653] toJavaRDD at <unknown>:0"]; } subgraph cluster41749 { label="Filter"; 18654 [labelType="html" label="MapPartitionsRDD [18654] toJavaRDD at <unknown>:0"]; } subgraph cluster41748 { label="Project"; 18655 [labelType="html" label="MapPartitionsRDD [18655] toJavaRDD at <unknown>:0"]; } subgraph cluster41745 { label="WholeStageCodegen (2)"; 18656 [labelType="html" label="MapPartitionsRDD [18656] toJavaRDD at <unknown>:0"]; } subgraph cluster41744 { label="Project"; 18657 [labelType="html" label="MapPartitionsRDD [18657] toJavaRDD at <unknown>:0"]; } subgraph cluster41743 { label="DeserializeToObject"; 18658 [labelType="html" label="MapPartitionsRDD [18658] toJavaRDD at <unknown>:0"]; } subgraph cluster41742 { label="MapPartitions"; 18659 [labelType="html" label="MapPartitionsRDD [18659] toJavaRDD at <unknown>:0"]; } subgraph cluster41752 { label="mapPartitions"; 18661 [labelType="html" label="MapPartitionsRDD [18661] toJavaRDD at <unknown>:0"]; } } 18648->18649; 18649->18650; 18650->18651; 18651->18652; 18652->18653; 18653->18654; 18654->18655; 18655->18656; 18656->18657; 18657->18658; 18658->18659; 18659->18660; 18660->18661; 18661->18662; }

Event Timeline

Enable zooming