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

digraph G { subgraph clusterstage_1207 { label="Stage 1207"; 12689 [labelType="html" label="SQLExecutionRDD [12689] run at <unknown>:0"]; 12697 [labelType="html" label="SQLExecutionRDD [12697] toJavaRDD at <unknown>:0"]; 12699 [labelType="html" label="PythonRDD [12699] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28389 { label="MicroBatchScan"; 12685 [labelType="html" label="DataSourceRDD [12685] run at <unknown>:0"]; 12686 [labelType="html" label="MapPartitionsRDD [12686] run at <unknown>:0"]; } subgraph cluster28388 { label="Project"; 12687 [labelType="html" label="MapPartitionsRDD [12687] run at <unknown>:0"]; } subgraph cluster28384 { label="WholeStageCodegen (1)"; 12688 [labelType="html" label="MapPartitionsRDD [12688] run at <unknown>:0"]; } subgraph cluster28398 { label="WholeStageCodegen (1)"; 12690 [labelType="html" label="MapPartitionsRDD [12690] toJavaRDD at <unknown>:0"]; } subgraph cluster28397 { label="Filter"; 12691 [labelType="html" label="MapPartitionsRDD [12691] toJavaRDD at <unknown>:0"]; } subgraph cluster28396 { label="Project"; 12692 [labelType="html" label="MapPartitionsRDD [12692] toJavaRDD at <unknown>:0"]; } subgraph cluster28393 { label="WholeStageCodegen (2)"; 12693 [labelType="html" label="MapPartitionsRDD [12693] toJavaRDD at <unknown>:0"]; } subgraph cluster28392 { label="Project"; 12694 [labelType="html" label="MapPartitionsRDD [12694] toJavaRDD at <unknown>:0"]; } subgraph cluster28391 { label="DeserializeToObject"; 12695 [labelType="html" label="MapPartitionsRDD [12695] toJavaRDD at <unknown>:0"]; } subgraph cluster28390 { label="MapPartitions"; 12696 [labelType="html" label="MapPartitionsRDD [12696] toJavaRDD at <unknown>:0"]; } subgraph cluster28400 { label="mapPartitions"; 12698 [labelType="html" label="MapPartitionsRDD [12698] toJavaRDD at <unknown>:0"]; } } 12685->12686; 12686->12687; 12687->12688; 12688->12689; 12689->12690; 12690->12691; 12691->12692; 12692->12693; 12693->12694; 12694->12695; 12695->12696; 12696->12697; 12697->12698; 12698->12699; }

Event Timeline

Enable zooming