processing-stream-kafka-raw-to-minio - Details for Stage 1608 (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 / 532
Associated Job Ids: 1609

digraph G { subgraph clusterstage_1608 { label="Stage 1608"; 16895 [labelType="html" label="SQLExecutionRDD [16895] run at <unknown>:0"]; 16903 [labelType="html" label="SQLExecutionRDD [16903] toJavaRDD at <unknown>:0"]; 16905 [labelType="html" label="PythonRDD [16905] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37797 { label="MicroBatchScan"; 16891 [labelType="html" label="DataSourceRDD [16891] run at <unknown>:0"]; 16892 [labelType="html" label="MapPartitionsRDD [16892] run at <unknown>:0"]; } subgraph cluster37796 { label="Project"; 16893 [labelType="html" label="MapPartitionsRDD [16893] run at <unknown>:0"]; } subgraph cluster37792 { label="WholeStageCodegen (1)"; 16894 [labelType="html" label="MapPartitionsRDD [16894] run at <unknown>:0"]; } subgraph cluster37806 { label="WholeStageCodegen (1)"; 16896 [labelType="html" label="MapPartitionsRDD [16896] toJavaRDD at <unknown>:0"]; } subgraph cluster37805 { label="Filter"; 16897 [labelType="html" label="MapPartitionsRDD [16897] toJavaRDD at <unknown>:0"]; } subgraph cluster37804 { label="Project"; 16898 [labelType="html" label="MapPartitionsRDD [16898] toJavaRDD at <unknown>:0"]; } subgraph cluster37801 { label="WholeStageCodegen (2)"; 16899 [labelType="html" label="MapPartitionsRDD [16899] toJavaRDD at <unknown>:0"]; } subgraph cluster37800 { label="Project"; 16900 [labelType="html" label="MapPartitionsRDD [16900] toJavaRDD at <unknown>:0"]; } subgraph cluster37799 { label="DeserializeToObject"; 16901 [labelType="html" label="MapPartitionsRDD [16901] toJavaRDD at <unknown>:0"]; } subgraph cluster37798 { label="MapPartitions"; 16902 [labelType="html" label="MapPartitionsRDD [16902] toJavaRDD at <unknown>:0"]; } subgraph cluster37808 { label="mapPartitions"; 16904 [labelType="html" label="MapPartitionsRDD [16904] toJavaRDD at <unknown>:0"]; } } 16891->16892; 16892->16893; 16893->16894; 16894->16895; 16895->16896; 16896->16897; 16897->16898; 16898->16899; 16899->16900; 16900->16901; 16901->16902; 16902->16903; 16903->16904; 16904->16905; }

Event Timeline

Enable zooming