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

digraph G { subgraph clusterstage_1677 { label="Stage 1677"; 17624 [labelType="html" label="SQLExecutionRDD [17624] run at <unknown>:0"]; 17632 [labelType="html" label="SQLExecutionRDD [17632] toJavaRDD at <unknown>:0"]; 17634 [labelType="html" label="PythonRDD [17634] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39434 { label="MicroBatchScan"; 17620 [labelType="html" label="DataSourceRDD [17620] run at <unknown>:0"]; 17621 [labelType="html" label="MapPartitionsRDD [17621] run at <unknown>:0"]; } subgraph cluster39433 { label="Project"; 17622 [labelType="html" label="MapPartitionsRDD [17622] run at <unknown>:0"]; } subgraph cluster39429 { label="WholeStageCodegen (1)"; 17623 [labelType="html" label="MapPartitionsRDD [17623] run at <unknown>:0"]; } subgraph cluster39443 { label="WholeStageCodegen (1)"; 17625 [labelType="html" label="MapPartitionsRDD [17625] toJavaRDD at <unknown>:0"]; } subgraph cluster39442 { label="Filter"; 17626 [labelType="html" label="MapPartitionsRDD [17626] toJavaRDD at <unknown>:0"]; } subgraph cluster39441 { label="Project"; 17627 [labelType="html" label="MapPartitionsRDD [17627] toJavaRDD at <unknown>:0"]; } subgraph cluster39438 { label="WholeStageCodegen (2)"; 17628 [labelType="html" label="MapPartitionsRDD [17628] toJavaRDD at <unknown>:0"]; } subgraph cluster39437 { label="Project"; 17629 [labelType="html" label="MapPartitionsRDD [17629] toJavaRDD at <unknown>:0"]; } subgraph cluster39436 { label="DeserializeToObject"; 17630 [labelType="html" label="MapPartitionsRDD [17630] toJavaRDD at <unknown>:0"]; } subgraph cluster39435 { label="MapPartitions"; 17631 [labelType="html" label="MapPartitionsRDD [17631] toJavaRDD at <unknown>:0"]; } subgraph cluster39445 { label="mapPartitions"; 17633 [labelType="html" label="MapPartitionsRDD [17633] toJavaRDD at <unknown>:0"]; } } 17620->17621; 17621->17622; 17622->17623; 17623->17624; 17624->17625; 17625->17626; 17626->17627; 17627->17628; 17628->17629; 17629->17630; 17630->17631; 17631->17632; 17632->17633; 17633->17634; }

Event Timeline

Enable zooming