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

digraph G { subgraph clusterstage_548 { label="Stage 548"; 5758 [labelType="html" label="SQLExecutionRDD [5758] run at <unknown>:0"]; 5766 [labelType="html" label="SQLExecutionRDD [5766] toJavaRDD at <unknown>:0"]; 5768 [labelType="html" label="PythonRDD [5768] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12883 { label="MicroBatchScan"; 5754 [labelType="html" label="DataSourceRDD [5754] run at <unknown>:0"]; 5755 [labelType="html" label="MapPartitionsRDD [5755] run at <unknown>:0"]; } subgraph cluster12882 { label="Project"; 5756 [labelType="html" label="MapPartitionsRDD [5756] run at <unknown>:0"]; } subgraph cluster12878 { label="WholeStageCodegen (1)"; 5757 [labelType="html" label="MapPartitionsRDD [5757] run at <unknown>:0"]; } subgraph cluster12892 { label="WholeStageCodegen (1)"; 5759 [labelType="html" label="MapPartitionsRDD [5759] toJavaRDD at <unknown>:0"]; } subgraph cluster12891 { label="Filter"; 5760 [labelType="html" label="MapPartitionsRDD [5760] toJavaRDD at <unknown>:0"]; } subgraph cluster12890 { label="Project"; 5761 [labelType="html" label="MapPartitionsRDD [5761] toJavaRDD at <unknown>:0"]; } subgraph cluster12887 { label="WholeStageCodegen (2)"; 5762 [labelType="html" label="MapPartitionsRDD [5762] toJavaRDD at <unknown>:0"]; } subgraph cluster12886 { label="Project"; 5763 [labelType="html" label="MapPartitionsRDD [5763] toJavaRDD at <unknown>:0"]; } subgraph cluster12885 { label="DeserializeToObject"; 5764 [labelType="html" label="MapPartitionsRDD [5764] toJavaRDD at <unknown>:0"]; } subgraph cluster12884 { label="MapPartitions"; 5765 [labelType="html" label="MapPartitionsRDD [5765] toJavaRDD at <unknown>:0"]; } subgraph cluster12894 { label="mapPartitions"; 5767 [labelType="html" label="MapPartitionsRDD [5767] toJavaRDD at <unknown>:0"]; } } 5754->5755; 5755->5756; 5756->5757; 5757->5758; 5758->5759; 5759->5760; 5760->5761; 5761->5762; 5762->5763; 5763->5764; 5764->5765; 5765->5766; 5766->5767; 5767->5768; }

Event Timeline

Enable zooming