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

digraph G { subgraph clusterstage_1147 { label="Stage 1147"; 12059 [labelType="html" label="SQLExecutionRDD [12059] run at <unknown>:0"]; 12067 [labelType="html" label="SQLExecutionRDD [12067] toJavaRDD at <unknown>:0"]; 12069 [labelType="html" label="PythonRDD [12069] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26979 { label="MicroBatchScan"; 12055 [labelType="html" label="DataSourceRDD [12055] run at <unknown>:0"]; 12056 [labelType="html" label="MapPartitionsRDD [12056] run at <unknown>:0"]; } subgraph cluster26978 { label="Project"; 12057 [labelType="html" label="MapPartitionsRDD [12057] run at <unknown>:0"]; } subgraph cluster26974 { label="WholeStageCodegen (1)"; 12058 [labelType="html" label="MapPartitionsRDD [12058] run at <unknown>:0"]; } subgraph cluster26988 { label="WholeStageCodegen (1)"; 12060 [labelType="html" label="MapPartitionsRDD [12060] toJavaRDD at <unknown>:0"]; } subgraph cluster26987 { label="Filter"; 12061 [labelType="html" label="MapPartitionsRDD [12061] toJavaRDD at <unknown>:0"]; } subgraph cluster26986 { label="Project"; 12062 [labelType="html" label="MapPartitionsRDD [12062] toJavaRDD at <unknown>:0"]; } subgraph cluster26983 { label="WholeStageCodegen (2)"; 12063 [labelType="html" label="MapPartitionsRDD [12063] toJavaRDD at <unknown>:0"]; } subgraph cluster26982 { label="Project"; 12064 [labelType="html" label="MapPartitionsRDD [12064] toJavaRDD at <unknown>:0"]; } subgraph cluster26981 { label="DeserializeToObject"; 12065 [labelType="html" label="MapPartitionsRDD [12065] toJavaRDD at <unknown>:0"]; } subgraph cluster26980 { label="MapPartitions"; 12066 [labelType="html" label="MapPartitionsRDD [12066] toJavaRDD at <unknown>:0"]; } subgraph cluster26990 { label="mapPartitions"; 12068 [labelType="html" label="MapPartitionsRDD [12068] toJavaRDD at <unknown>:0"]; } } 12055->12056; 12056->12057; 12057->12058; 12058->12059; 12059->12060; 12060->12061; 12061->12062; 12062->12063; 12063->12064; 12064->12065; 12065->12066; 12066->12067; 12067->12068; 12068->12069; }

Event Timeline

Enable zooming