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

digraph G { subgraph clusterstage_1362 { label="Stage 1362"; 14306 [labelType="html" label="SQLExecutionRDD [14306] run at <unknown>:0"]; 14320 [labelType="html" label="SQLExecutionRDD [14320] toJavaRDD at <unknown>:0"]; 14322 [labelType="html" label="PythonRDD [14322] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32008 { label="MicroBatchScan"; 14302 [labelType="html" label="DataSourceRDD [14302] run at <unknown>:0"]; 14303 [labelType="html" label="MapPartitionsRDD [14303] run at <unknown>:0"]; } subgraph cluster32007 { label="Project"; 14304 [labelType="html" label="MapPartitionsRDD [14304] run at <unknown>:0"]; } subgraph cluster32003 { label="WholeStageCodegen (1)"; 14305 [labelType="html" label="MapPartitionsRDD [14305] run at <unknown>:0"]; } subgraph cluster32025 { label="WholeStageCodegen (1)"; 14313 [labelType="html" label="MapPartitionsRDD [14313] toJavaRDD at <unknown>:0"]; } subgraph cluster32024 { label="Filter"; 14314 [labelType="html" label="MapPartitionsRDD [14314] toJavaRDD at <unknown>:0"]; } subgraph cluster32023 { label="Project"; 14315 [labelType="html" label="MapPartitionsRDD [14315] toJavaRDD at <unknown>:0"]; } subgraph cluster32020 { label="WholeStageCodegen (2)"; 14316 [labelType="html" label="MapPartitionsRDD [14316] toJavaRDD at <unknown>:0"]; } subgraph cluster32019 { label="Project"; 14317 [labelType="html" label="MapPartitionsRDD [14317] toJavaRDD at <unknown>:0"]; } subgraph cluster32018 { label="DeserializeToObject"; 14318 [labelType="html" label="MapPartitionsRDD [14318] toJavaRDD at <unknown>:0"]; } subgraph cluster32017 { label="MapPartitions"; 14319 [labelType="html" label="MapPartitionsRDD [14319] toJavaRDD at <unknown>:0"]; } subgraph cluster32027 { label="mapPartitions"; 14321 [labelType="html" label="MapPartitionsRDD [14321] toJavaRDD at <unknown>:0"]; } } 14302->14303; 14303->14304; 14304->14305; 14305->14306; 14306->14313; 14313->14314; 14314->14315; 14315->14316; 14316->14317; 14317->14318; 14318->14319; 14319->14320; 14320->14321; 14321->14322; }

Event Timeline

Enable zooming