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

digraph G { subgraph clusterstage_1469 { label="Stage 1469"; 15418 [labelType="html" label="SQLExecutionRDD [15418] run at <unknown>:0"]; 15432 [labelType="html" label="SQLExecutionRDD [15432] toJavaRDD at <unknown>:0"]; 15434 [labelType="html" label="PythonRDD [15434] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34503 { label="MicroBatchScan"; 15414 [labelType="html" label="DataSourceRDD [15414] run at <unknown>:0"]; 15415 [labelType="html" label="MapPartitionsRDD [15415] run at <unknown>:0"]; } subgraph cluster34502 { label="Project"; 15416 [labelType="html" label="MapPartitionsRDD [15416] run at <unknown>:0"]; } subgraph cluster34498 { label="WholeStageCodegen (1)"; 15417 [labelType="html" label="MapPartitionsRDD [15417] run at <unknown>:0"]; } subgraph cluster34520 { label="WholeStageCodegen (1)"; 15425 [labelType="html" label="MapPartitionsRDD [15425] toJavaRDD at <unknown>:0"]; } subgraph cluster34519 { label="Filter"; 15426 [labelType="html" label="MapPartitionsRDD [15426] toJavaRDD at <unknown>:0"]; } subgraph cluster34518 { label="Project"; 15427 [labelType="html" label="MapPartitionsRDD [15427] toJavaRDD at <unknown>:0"]; } subgraph cluster34515 { label="WholeStageCodegen (2)"; 15428 [labelType="html" label="MapPartitionsRDD [15428] toJavaRDD at <unknown>:0"]; } subgraph cluster34514 { label="Project"; 15429 [labelType="html" label="MapPartitionsRDD [15429] toJavaRDD at <unknown>:0"]; } subgraph cluster34513 { label="DeserializeToObject"; 15430 [labelType="html" label="MapPartitionsRDD [15430] toJavaRDD at <unknown>:0"]; } subgraph cluster34512 { label="MapPartitions"; 15431 [labelType="html" label="MapPartitionsRDD [15431] toJavaRDD at <unknown>:0"]; } subgraph cluster34522 { label="mapPartitions"; 15433 [labelType="html" label="MapPartitionsRDD [15433] toJavaRDD at <unknown>:0"]; } } 15414->15415; 15415->15416; 15416->15417; 15417->15418; 15418->15425; 15425->15426; 15426->15427; 15427->15428; 15428->15429; 15429->15430; 15430->15431; 15431->15432; 15432->15433; 15433->15434; }

Event Timeline

Enable zooming