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

digraph G { subgraph clusterstage_1908 { label="Stage 1908"; 20038 [labelType="html" label="SQLExecutionRDD [20038] run at <unknown>:0"]; 20046 [labelType="html" label="SQLExecutionRDD [20046] toJavaRDD at <unknown>:0"]; 20048 [labelType="html" label="PythonRDD [20048] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster44843 { label="MicroBatchScan"; 20034 [labelType="html" label="DataSourceRDD [20034] run at <unknown>:0"]; 20035 [labelType="html" label="MapPartitionsRDD [20035] run at <unknown>:0"]; } subgraph cluster44842 { label="Project"; 20036 [labelType="html" label="MapPartitionsRDD [20036] run at <unknown>:0"]; } subgraph cluster44838 { label="WholeStageCodegen (1)"; 20037 [labelType="html" label="MapPartitionsRDD [20037] run at <unknown>:0"]; } subgraph cluster44852 { label="WholeStageCodegen (1)"; 20039 [labelType="html" label="MapPartitionsRDD [20039] toJavaRDD at <unknown>:0"]; } subgraph cluster44851 { label="Filter"; 20040 [labelType="html" label="MapPartitionsRDD [20040] toJavaRDD at <unknown>:0"]; } subgraph cluster44850 { label="Project"; 20041 [labelType="html" label="MapPartitionsRDD [20041] toJavaRDD at <unknown>:0"]; } subgraph cluster44847 { label="WholeStageCodegen (2)"; 20042 [labelType="html" label="MapPartitionsRDD [20042] toJavaRDD at <unknown>:0"]; } subgraph cluster44846 { label="Project"; 20043 [labelType="html" label="MapPartitionsRDD [20043] toJavaRDD at <unknown>:0"]; } subgraph cluster44845 { label="DeserializeToObject"; 20044 [labelType="html" label="MapPartitionsRDD [20044] toJavaRDD at <unknown>:0"]; } subgraph cluster44844 { label="MapPartitions"; 20045 [labelType="html" label="MapPartitionsRDD [20045] toJavaRDD at <unknown>:0"]; } subgraph cluster44854 { label="mapPartitions"; 20047 [labelType="html" label="MapPartitionsRDD [20047] toJavaRDD at <unknown>:0"]; } } 20034->20035; 20035->20036; 20036->20037; 20037->20038; 20038->20039; 20039->20040; 20040->20041; 20041->20042; 20042->20043; 20043->20044; 20044->20045; 20045->20046; 20046->20047; 20047->20048; }

Event Timeline

Enable zooming