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

digraph G { subgraph clusterstage_678 { label="Stage 678"; 7123 [labelType="html" label="SQLExecutionRDD [7123] run at <unknown>:0"]; 7131 [labelType="html" label="SQLExecutionRDD [7131] toJavaRDD at <unknown>:0"]; 7133 [labelType="html" label="PythonRDD [7133] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster15938 { label="MicroBatchScan"; 7119 [labelType="html" label="DataSourceRDD [7119] run at <unknown>:0"]; 7120 [labelType="html" label="MapPartitionsRDD [7120] run at <unknown>:0"]; } subgraph cluster15937 { label="Project"; 7121 [labelType="html" label="MapPartitionsRDD [7121] run at <unknown>:0"]; } subgraph cluster15933 { label="WholeStageCodegen (1)"; 7122 [labelType="html" label="MapPartitionsRDD [7122] run at <unknown>:0"]; } subgraph cluster15947 { label="WholeStageCodegen (1)"; 7124 [labelType="html" label="MapPartitionsRDD [7124] toJavaRDD at <unknown>:0"]; } subgraph cluster15946 { label="Filter"; 7125 [labelType="html" label="MapPartitionsRDD [7125] toJavaRDD at <unknown>:0"]; } subgraph cluster15945 { label="Project"; 7126 [labelType="html" label="MapPartitionsRDD [7126] toJavaRDD at <unknown>:0"]; } subgraph cluster15942 { label="WholeStageCodegen (2)"; 7127 [labelType="html" label="MapPartitionsRDD [7127] toJavaRDD at <unknown>:0"]; } subgraph cluster15941 { label="Project"; 7128 [labelType="html" label="MapPartitionsRDD [7128] toJavaRDD at <unknown>:0"]; } subgraph cluster15940 { label="DeserializeToObject"; 7129 [labelType="html" label="MapPartitionsRDD [7129] toJavaRDD at <unknown>:0"]; } subgraph cluster15939 { label="MapPartitions"; 7130 [labelType="html" label="MapPartitionsRDD [7130] toJavaRDD at <unknown>:0"]; } subgraph cluster15949 { label="mapPartitions"; 7132 [labelType="html" label="MapPartitionsRDD [7132] toJavaRDD at <unknown>:0"]; } } 7119->7120; 7120->7121; 7121->7122; 7122->7123; 7123->7124; 7124->7125; 7125->7126; 7126->7127; 7127->7128; 7128->7129; 7129->7130; 7130->7131; 7131->7132; 7132->7133; }

Event Timeline

Enable zooming