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

digraph G { subgraph clusterstage_346 { label="Stage 346"; 3637 [labelType="html" label="SQLExecutionRDD [3637] run at <unknown>:0"]; 3645 [labelType="html" label="SQLExecutionRDD [3645] toJavaRDD at <unknown>:0"]; 3647 [labelType="html" label="PythonRDD [3647] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8136 { label="MicroBatchScan"; 3633 [labelType="html" label="DataSourceRDD [3633] run at <unknown>:0"]; 3634 [labelType="html" label="MapPartitionsRDD [3634] run at <unknown>:0"]; } subgraph cluster8135 { label="Project"; 3635 [labelType="html" label="MapPartitionsRDD [3635] run at <unknown>:0"]; } subgraph cluster8131 { label="WholeStageCodegen (1)"; 3636 [labelType="html" label="MapPartitionsRDD [3636] run at <unknown>:0"]; } subgraph cluster8145 { label="WholeStageCodegen (1)"; 3638 [labelType="html" label="MapPartitionsRDD [3638] toJavaRDD at <unknown>:0"]; } subgraph cluster8144 { label="Filter"; 3639 [labelType="html" label="MapPartitionsRDD [3639] toJavaRDD at <unknown>:0"]; } subgraph cluster8143 { label="Project"; 3640 [labelType="html" label="MapPartitionsRDD [3640] toJavaRDD at <unknown>:0"]; } subgraph cluster8140 { label="WholeStageCodegen (2)"; 3641 [labelType="html" label="MapPartitionsRDD [3641] toJavaRDD at <unknown>:0"]; } subgraph cluster8139 { label="Project"; 3642 [labelType="html" label="MapPartitionsRDD [3642] toJavaRDD at <unknown>:0"]; } subgraph cluster8138 { label="DeserializeToObject"; 3643 [labelType="html" label="MapPartitionsRDD [3643] toJavaRDD at <unknown>:0"]; } subgraph cluster8137 { label="MapPartitions"; 3644 [labelType="html" label="MapPartitionsRDD [3644] toJavaRDD at <unknown>:0"]; } subgraph cluster8147 { label="mapPartitions"; 3646 [labelType="html" label="MapPartitionsRDD [3646] toJavaRDD at <unknown>:0"]; } } 3633->3634; 3634->3635; 3635->3636; 3636->3637; 3637->3638; 3638->3639; 3639->3640; 3640->3641; 3641->3642; 3642->3643; 3643->3644; 3644->3645; 3645->3646; 3646->3647; }

Event Timeline

Enable zooming