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

digraph G { subgraph clusterstage_1371 { label="Stage 1371"; 14411 [labelType="html" label="SQLExecutionRDD [14411] run at <unknown>:0"]; 14419 [labelType="html" label="SQLExecutionRDD [14419] toJavaRDD at <unknown>:0"]; 14421 [labelType="html" label="PythonRDD [14421] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32243 { label="MicroBatchScan"; 14407 [labelType="html" label="DataSourceRDD [14407] run at <unknown>:0"]; 14408 [labelType="html" label="MapPartitionsRDD [14408] run at <unknown>:0"]; } subgraph cluster32242 { label="Project"; 14409 [labelType="html" label="MapPartitionsRDD [14409] run at <unknown>:0"]; } subgraph cluster32238 { label="WholeStageCodegen (1)"; 14410 [labelType="html" label="MapPartitionsRDD [14410] run at <unknown>:0"]; } subgraph cluster32252 { label="WholeStageCodegen (1)"; 14412 [labelType="html" label="MapPartitionsRDD [14412] toJavaRDD at <unknown>:0"]; } subgraph cluster32251 { label="Filter"; 14413 [labelType="html" label="MapPartitionsRDD [14413] toJavaRDD at <unknown>:0"]; } subgraph cluster32250 { label="Project"; 14414 [labelType="html" label="MapPartitionsRDD [14414] toJavaRDD at <unknown>:0"]; } subgraph cluster32247 { label="WholeStageCodegen (2)"; 14415 [labelType="html" label="MapPartitionsRDD [14415] toJavaRDD at <unknown>:0"]; } subgraph cluster32246 { label="Project"; 14416 [labelType="html" label="MapPartitionsRDD [14416] toJavaRDD at <unknown>:0"]; } subgraph cluster32245 { label="DeserializeToObject"; 14417 [labelType="html" label="MapPartitionsRDD [14417] toJavaRDD at <unknown>:0"]; } subgraph cluster32244 { label="MapPartitions"; 14418 [labelType="html" label="MapPartitionsRDD [14418] toJavaRDD at <unknown>:0"]; } subgraph cluster32254 { label="mapPartitions"; 14420 [labelType="html" label="MapPartitionsRDD [14420] toJavaRDD at <unknown>:0"]; } } 14407->14408; 14408->14409; 14409->14410; 14410->14411; 14411->14412; 14412->14413; 14413->14414; 14414->14415; 14415->14416; 14416->14417; 14417->14418; 14418->14419; 14419->14420; 14420->14421; }

Event Timeline

Enable zooming