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

digraph G { subgraph clusterstage_1197 { label="Stage 1197"; 12584 [labelType="html" label="SQLExecutionRDD [12584] run at <unknown>:0"]; 12592 [labelType="html" label="SQLExecutionRDD [12592] toJavaRDD at <unknown>:0"]; 12594 [labelType="html" label="PythonRDD [12594] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28154 { label="MicroBatchScan"; 12580 [labelType="html" label="DataSourceRDD [12580] run at <unknown>:0"]; 12581 [labelType="html" label="MapPartitionsRDD [12581] run at <unknown>:0"]; } subgraph cluster28153 { label="Project"; 12582 [labelType="html" label="MapPartitionsRDD [12582] run at <unknown>:0"]; } subgraph cluster28149 { label="WholeStageCodegen (1)"; 12583 [labelType="html" label="MapPartitionsRDD [12583] run at <unknown>:0"]; } subgraph cluster28163 { label="WholeStageCodegen (1)"; 12585 [labelType="html" label="MapPartitionsRDD [12585] toJavaRDD at <unknown>:0"]; } subgraph cluster28162 { label="Filter"; 12586 [labelType="html" label="MapPartitionsRDD [12586] toJavaRDD at <unknown>:0"]; } subgraph cluster28161 { label="Project"; 12587 [labelType="html" label="MapPartitionsRDD [12587] toJavaRDD at <unknown>:0"]; } subgraph cluster28158 { label="WholeStageCodegen (2)"; 12588 [labelType="html" label="MapPartitionsRDD [12588] toJavaRDD at <unknown>:0"]; } subgraph cluster28157 { label="Project"; 12589 [labelType="html" label="MapPartitionsRDD [12589] toJavaRDD at <unknown>:0"]; } subgraph cluster28156 { label="DeserializeToObject"; 12590 [labelType="html" label="MapPartitionsRDD [12590] toJavaRDD at <unknown>:0"]; } subgraph cluster28155 { label="MapPartitions"; 12591 [labelType="html" label="MapPartitionsRDD [12591] toJavaRDD at <unknown>:0"]; } subgraph cluster28165 { label="mapPartitions"; 12593 [labelType="html" label="MapPartitionsRDD [12593] toJavaRDD at <unknown>:0"]; } } 12580->12581; 12581->12582; 12582->12583; 12583->12584; 12584->12585; 12585->12586; 12586->12587; 12587->12588; 12588->12589; 12589->12590; 12590->12591; 12591->12592; 12592->12593; 12593->12594; }

Event Timeline

Enable zooming