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

digraph G { subgraph clusterstage_1145 { label="Stage 1145"; 12038 [labelType="html" label="SQLExecutionRDD [12038] run at <unknown>:0"]; 12046 [labelType="html" label="SQLExecutionRDD [12046] toJavaRDD at <unknown>:0"]; 12048 [labelType="html" label="PythonRDD [12048] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26932 { label="MicroBatchScan"; 12034 [labelType="html" label="DataSourceRDD [12034] run at <unknown>:0"]; 12035 [labelType="html" label="MapPartitionsRDD [12035] run at <unknown>:0"]; } subgraph cluster26931 { label="Project"; 12036 [labelType="html" label="MapPartitionsRDD [12036] run at <unknown>:0"]; } subgraph cluster26927 { label="WholeStageCodegen (1)"; 12037 [labelType="html" label="MapPartitionsRDD [12037] run at <unknown>:0"]; } subgraph cluster26941 { label="WholeStageCodegen (1)"; 12039 [labelType="html" label="MapPartitionsRDD [12039] toJavaRDD at <unknown>:0"]; } subgraph cluster26940 { label="Filter"; 12040 [labelType="html" label="MapPartitionsRDD [12040] toJavaRDD at <unknown>:0"]; } subgraph cluster26939 { label="Project"; 12041 [labelType="html" label="MapPartitionsRDD [12041] toJavaRDD at <unknown>:0"]; } subgraph cluster26936 { label="WholeStageCodegen (2)"; 12042 [labelType="html" label="MapPartitionsRDD [12042] toJavaRDD at <unknown>:0"]; } subgraph cluster26935 { label="Project"; 12043 [labelType="html" label="MapPartitionsRDD [12043] toJavaRDD at <unknown>:0"]; } subgraph cluster26934 { label="DeserializeToObject"; 12044 [labelType="html" label="MapPartitionsRDD [12044] toJavaRDD at <unknown>:0"]; } subgraph cluster26933 { label="MapPartitions"; 12045 [labelType="html" label="MapPartitionsRDD [12045] toJavaRDD at <unknown>:0"]; } subgraph cluster26943 { label="mapPartitions"; 12047 [labelType="html" label="MapPartitionsRDD [12047] toJavaRDD at <unknown>:0"]; } } 12034->12035; 12035->12036; 12036->12037; 12037->12038; 12038->12039; 12039->12040; 12040->12041; 12041->12042; 12042->12043; 12043->12044; 12044->12045; 12045->12046; 12046->12047; 12047->12048; }

Event Timeline

Enable zooming