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

digraph G { subgraph clusterstage_2002 { label="Stage 2002"; 21026 [labelType="html" label="SQLExecutionRDD [21026] run at <unknown>:0"]; 21040 [labelType="html" label="SQLExecutionRDD [21040] toJavaRDD at <unknown>:0"]; 21042 [labelType="html" label="PythonRDD [21042] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47048 { label="MicroBatchScan"; 21022 [labelType="html" label="DataSourceRDD [21022] run at <unknown>:0"]; 21023 [labelType="html" label="MapPartitionsRDD [21023] run at <unknown>:0"]; } subgraph cluster47047 { label="Project"; 21024 [labelType="html" label="MapPartitionsRDD [21024] run at <unknown>:0"]; } subgraph cluster47043 { label="WholeStageCodegen (1)"; 21025 [labelType="html" label="MapPartitionsRDD [21025] run at <unknown>:0"]; } subgraph cluster47065 { label="WholeStageCodegen (1)"; 21033 [labelType="html" label="MapPartitionsRDD [21033] toJavaRDD at <unknown>:0"]; } subgraph cluster47064 { label="Filter"; 21034 [labelType="html" label="MapPartitionsRDD [21034] toJavaRDD at <unknown>:0"]; } subgraph cluster47063 { label="Project"; 21035 [labelType="html" label="MapPartitionsRDD [21035] toJavaRDD at <unknown>:0"]; } subgraph cluster47060 { label="WholeStageCodegen (2)"; 21036 [labelType="html" label="MapPartitionsRDD [21036] toJavaRDD at <unknown>:0"]; } subgraph cluster47059 { label="Project"; 21037 [labelType="html" label="MapPartitionsRDD [21037] toJavaRDD at <unknown>:0"]; } subgraph cluster47058 { label="DeserializeToObject"; 21038 [labelType="html" label="MapPartitionsRDD [21038] toJavaRDD at <unknown>:0"]; } subgraph cluster47057 { label="MapPartitions"; 21039 [labelType="html" label="MapPartitionsRDD [21039] toJavaRDD at <unknown>:0"]; } subgraph cluster47067 { label="mapPartitions"; 21041 [labelType="html" label="MapPartitionsRDD [21041] toJavaRDD at <unknown>:0"]; } } 21022->21023; 21023->21024; 21024->21025; 21025->21026; 21026->21033; 21033->21034; 21034->21035; 21035->21036; 21036->21037; 21037->21038; 21038->21039; 21039->21040; 21040->21041; 21041->21042; }

Event Timeline

Enable zooming