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

digraph G { subgraph clusterstage_1870 { label="Stage 1870"; 19639 [labelType="html" label="SQLExecutionRDD [19639] run at <unknown>:0"]; 19647 [labelType="html" label="SQLExecutionRDD [19647] toJavaRDD at <unknown>:0"]; 19649 [labelType="html" label="PythonRDD [19649] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43950 { label="MicroBatchScan"; 19635 [labelType="html" label="DataSourceRDD [19635] run at <unknown>:0"]; 19636 [labelType="html" label="MapPartitionsRDD [19636] run at <unknown>:0"]; } subgraph cluster43949 { label="Project"; 19637 [labelType="html" label="MapPartitionsRDD [19637] run at <unknown>:0"]; } subgraph cluster43945 { label="WholeStageCodegen (1)"; 19638 [labelType="html" label="MapPartitionsRDD [19638] run at <unknown>:0"]; } subgraph cluster43959 { label="WholeStageCodegen (1)"; 19640 [labelType="html" label="MapPartitionsRDD [19640] toJavaRDD at <unknown>:0"]; } subgraph cluster43958 { label="Filter"; 19641 [labelType="html" label="MapPartitionsRDD [19641] toJavaRDD at <unknown>:0"]; } subgraph cluster43957 { label="Project"; 19642 [labelType="html" label="MapPartitionsRDD [19642] toJavaRDD at <unknown>:0"]; } subgraph cluster43954 { label="WholeStageCodegen (2)"; 19643 [labelType="html" label="MapPartitionsRDD [19643] toJavaRDD at <unknown>:0"]; } subgraph cluster43953 { label="Project"; 19644 [labelType="html" label="MapPartitionsRDD [19644] toJavaRDD at <unknown>:0"]; } subgraph cluster43952 { label="DeserializeToObject"; 19645 [labelType="html" label="MapPartitionsRDD [19645] toJavaRDD at <unknown>:0"]; } subgraph cluster43951 { label="MapPartitions"; 19646 [labelType="html" label="MapPartitionsRDD [19646] toJavaRDD at <unknown>:0"]; } subgraph cluster43961 { label="mapPartitions"; 19648 [labelType="html" label="MapPartitionsRDD [19648] toJavaRDD at <unknown>:0"]; } } 19635->19636; 19636->19637; 19637->19638; 19638->19639; 19639->19640; 19640->19641; 19641->19642; 19642->19643; 19643->19644; 19644->19645; 19645->19646; 19646->19647; 19647->19648; 19648->19649; }

Event Timeline

Enable zooming