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

digraph G { subgraph clusterstage_1033 { label="Stage 1033"; 10862 [labelType="html" label="SQLExecutionRDD [10862] run at <unknown>:0"]; 10870 [labelType="html" label="SQLExecutionRDD [10870] toJavaRDD at <unknown>:0"]; 10872 [labelType="html" label="PythonRDD [10872] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24300 { label="MicroBatchScan"; 10858 [labelType="html" label="DataSourceRDD [10858] run at <unknown>:0"]; 10859 [labelType="html" label="MapPartitionsRDD [10859] run at <unknown>:0"]; } subgraph cluster24299 { label="Project"; 10860 [labelType="html" label="MapPartitionsRDD [10860] run at <unknown>:0"]; } subgraph cluster24295 { label="WholeStageCodegen (1)"; 10861 [labelType="html" label="MapPartitionsRDD [10861] run at <unknown>:0"]; } subgraph cluster24309 { label="WholeStageCodegen (1)"; 10863 [labelType="html" label="MapPartitionsRDD [10863] toJavaRDD at <unknown>:0"]; } subgraph cluster24308 { label="Filter"; 10864 [labelType="html" label="MapPartitionsRDD [10864] toJavaRDD at <unknown>:0"]; } subgraph cluster24307 { label="Project"; 10865 [labelType="html" label="MapPartitionsRDD [10865] toJavaRDD at <unknown>:0"]; } subgraph cluster24304 { label="WholeStageCodegen (2)"; 10866 [labelType="html" label="MapPartitionsRDD [10866] toJavaRDD at <unknown>:0"]; } subgraph cluster24303 { label="Project"; 10867 [labelType="html" label="MapPartitionsRDD [10867] toJavaRDD at <unknown>:0"]; } subgraph cluster24302 { label="DeserializeToObject"; 10868 [labelType="html" label="MapPartitionsRDD [10868] toJavaRDD at <unknown>:0"]; } subgraph cluster24301 { label="MapPartitions"; 10869 [labelType="html" label="MapPartitionsRDD [10869] toJavaRDD at <unknown>:0"]; } subgraph cluster24311 { label="mapPartitions"; 10871 [labelType="html" label="MapPartitionsRDD [10871] toJavaRDD at <unknown>:0"]; } } 10858->10859; 10859->10860; 10860->10861; 10861->10862; 10862->10863; 10863->10864; 10864->10865; 10865->10866; 10866->10867; 10867->10868; 10868->10869; 10869->10870; 10870->10871; 10871->10872; }

Event Timeline

Enable zooming