processing-stream-kafka-raw-to-minio - Details for Stage 1689 (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 / 371
Associated Job Ids: 1690

digraph G { subgraph clusterstage_1689 { label="Stage 1689"; 17750 [labelType="html" label="SQLExecutionRDD [17750] run at <unknown>:0"]; 17758 [labelType="html" label="SQLExecutionRDD [17758] toJavaRDD at <unknown>:0"]; 17760 [labelType="html" label="PythonRDD [17760] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39716 { label="MicroBatchScan"; 17746 [labelType="html" label="DataSourceRDD [17746] run at <unknown>:0"]; 17747 [labelType="html" label="MapPartitionsRDD [17747] run at <unknown>:0"]; } subgraph cluster39715 { label="Project"; 17748 [labelType="html" label="MapPartitionsRDD [17748] run at <unknown>:0"]; } subgraph cluster39711 { label="WholeStageCodegen (1)"; 17749 [labelType="html" label="MapPartitionsRDD [17749] run at <unknown>:0"]; } subgraph cluster39725 { label="WholeStageCodegen (1)"; 17751 [labelType="html" label="MapPartitionsRDD [17751] toJavaRDD at <unknown>:0"]; } subgraph cluster39724 { label="Filter"; 17752 [labelType="html" label="MapPartitionsRDD [17752] toJavaRDD at <unknown>:0"]; } subgraph cluster39723 { label="Project"; 17753 [labelType="html" label="MapPartitionsRDD [17753] toJavaRDD at <unknown>:0"]; } subgraph cluster39720 { label="WholeStageCodegen (2)"; 17754 [labelType="html" label="MapPartitionsRDD [17754] toJavaRDD at <unknown>:0"]; } subgraph cluster39719 { label="Project"; 17755 [labelType="html" label="MapPartitionsRDD [17755] toJavaRDD at <unknown>:0"]; } subgraph cluster39718 { label="DeserializeToObject"; 17756 [labelType="html" label="MapPartitionsRDD [17756] toJavaRDD at <unknown>:0"]; } subgraph cluster39717 { label="MapPartitions"; 17757 [labelType="html" label="MapPartitionsRDD [17757] toJavaRDD at <unknown>:0"]; } subgraph cluster39727 { label="mapPartitions"; 17759 [labelType="html" label="MapPartitionsRDD [17759] toJavaRDD at <unknown>:0"]; } } 17746->17747; 17747->17748; 17748->17749; 17749->17750; 17750->17751; 17751->17752; 17752->17753; 17753->17754; 17754->17755; 17755->17756; 17756->17757; 17757->17758; 17758->17759; 17759->17760; }

Event Timeline

Enable zooming