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

digraph G { subgraph clusterstage_1382 { label="Stage 1382"; 14522 [labelType="html" label="SQLExecutionRDD [14522] run at <unknown>:0"]; 14530 [labelType="html" label="SQLExecutionRDD [14530] toJavaRDD at <unknown>:0"]; 14532 [labelType="html" label="PythonRDD [14532] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32486 { label="MicroBatchScan"; 14518 [labelType="html" label="DataSourceRDD [14518] run at <unknown>:0"]; 14519 [labelType="html" label="MapPartitionsRDD [14519] run at <unknown>:0"]; } subgraph cluster32485 { label="Project"; 14520 [labelType="html" label="MapPartitionsRDD [14520] run at <unknown>:0"]; } subgraph cluster32481 { label="WholeStageCodegen (1)"; 14521 [labelType="html" label="MapPartitionsRDD [14521] run at <unknown>:0"]; } subgraph cluster32495 { label="WholeStageCodegen (1)"; 14523 [labelType="html" label="MapPartitionsRDD [14523] toJavaRDD at <unknown>:0"]; } subgraph cluster32494 { label="Filter"; 14524 [labelType="html" label="MapPartitionsRDD [14524] toJavaRDD at <unknown>:0"]; } subgraph cluster32493 { label="Project"; 14525 [labelType="html" label="MapPartitionsRDD [14525] toJavaRDD at <unknown>:0"]; } subgraph cluster32490 { label="WholeStageCodegen (2)"; 14526 [labelType="html" label="MapPartitionsRDD [14526] toJavaRDD at <unknown>:0"]; } subgraph cluster32489 { label="Project"; 14527 [labelType="html" label="MapPartitionsRDD [14527] toJavaRDD at <unknown>:0"]; } subgraph cluster32488 { label="DeserializeToObject"; 14528 [labelType="html" label="MapPartitionsRDD [14528] toJavaRDD at <unknown>:0"]; } subgraph cluster32487 { label="MapPartitions"; 14529 [labelType="html" label="MapPartitionsRDD [14529] toJavaRDD at <unknown>:0"]; } subgraph cluster32497 { label="mapPartitions"; 14531 [labelType="html" label="MapPartitionsRDD [14531] toJavaRDD at <unknown>:0"]; } } 14518->14519; 14519->14520; 14520->14521; 14521->14522; 14522->14523; 14523->14524; 14524->14525; 14525->14526; 14526->14527; 14527->14528; 14528->14529; 14529->14530; 14530->14531; 14531->14532; }

Event Timeline

Enable zooming