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

digraph G { subgraph clusterstage_536 { label="Stage 536"; 5632 [labelType="html" label="SQLExecutionRDD [5632] run at <unknown>:0"]; 5640 [labelType="html" label="SQLExecutionRDD [5640] toJavaRDD at <unknown>:0"]; 5642 [labelType="html" label="PythonRDD [5642] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12601 { label="MicroBatchScan"; 5628 [labelType="html" label="DataSourceRDD [5628] run at <unknown>:0"]; 5629 [labelType="html" label="MapPartitionsRDD [5629] run at <unknown>:0"]; } subgraph cluster12600 { label="Project"; 5630 [labelType="html" label="MapPartitionsRDD [5630] run at <unknown>:0"]; } subgraph cluster12596 { label="WholeStageCodegen (1)"; 5631 [labelType="html" label="MapPartitionsRDD [5631] run at <unknown>:0"]; } subgraph cluster12610 { label="WholeStageCodegen (1)"; 5633 [labelType="html" label="MapPartitionsRDD [5633] toJavaRDD at <unknown>:0"]; } subgraph cluster12609 { label="Filter"; 5634 [labelType="html" label="MapPartitionsRDD [5634] toJavaRDD at <unknown>:0"]; } subgraph cluster12608 { label="Project"; 5635 [labelType="html" label="MapPartitionsRDD [5635] toJavaRDD at <unknown>:0"]; } subgraph cluster12605 { label="WholeStageCodegen (2)"; 5636 [labelType="html" label="MapPartitionsRDD [5636] toJavaRDD at <unknown>:0"]; } subgraph cluster12604 { label="Project"; 5637 [labelType="html" label="MapPartitionsRDD [5637] toJavaRDD at <unknown>:0"]; } subgraph cluster12603 { label="DeserializeToObject"; 5638 [labelType="html" label="MapPartitionsRDD [5638] toJavaRDD at <unknown>:0"]; } subgraph cluster12602 { label="MapPartitions"; 5639 [labelType="html" label="MapPartitionsRDD [5639] toJavaRDD at <unknown>:0"]; } subgraph cluster12612 { label="mapPartitions"; 5641 [labelType="html" label="MapPartitionsRDD [5641] toJavaRDD at <unknown>:0"]; } } 5628->5629; 5629->5630; 5630->5631; 5631->5632; 5632->5633; 5633->5634; 5634->5635; 5635->5636; 5636->5637; 5637->5638; 5638->5639; 5639->5640; 5640->5641; 5641->5642; }

Event Timeline

Enable zooming