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

digraph G { subgraph clusterstage_1378 { label="Stage 1378"; 14480 [labelType="html" label="SQLExecutionRDD [14480] run at <unknown>:0"]; 14488 [labelType="html" label="SQLExecutionRDD [14488] toJavaRDD at <unknown>:0"]; 14490 [labelType="html" label="PythonRDD [14490] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32392 { label="MicroBatchScan"; 14476 [labelType="html" label="DataSourceRDD [14476] run at <unknown>:0"]; 14477 [labelType="html" label="MapPartitionsRDD [14477] run at <unknown>:0"]; } subgraph cluster32391 { label="Project"; 14478 [labelType="html" label="MapPartitionsRDD [14478] run at <unknown>:0"]; } subgraph cluster32387 { label="WholeStageCodegen (1)"; 14479 [labelType="html" label="MapPartitionsRDD [14479] run at <unknown>:0"]; } subgraph cluster32401 { label="WholeStageCodegen (1)"; 14481 [labelType="html" label="MapPartitionsRDD [14481] toJavaRDD at <unknown>:0"]; } subgraph cluster32400 { label="Filter"; 14482 [labelType="html" label="MapPartitionsRDD [14482] toJavaRDD at <unknown>:0"]; } subgraph cluster32399 { label="Project"; 14483 [labelType="html" label="MapPartitionsRDD [14483] toJavaRDD at <unknown>:0"]; } subgraph cluster32396 { label="WholeStageCodegen (2)"; 14484 [labelType="html" label="MapPartitionsRDD [14484] toJavaRDD at <unknown>:0"]; } subgraph cluster32395 { label="Project"; 14485 [labelType="html" label="MapPartitionsRDD [14485] toJavaRDD at <unknown>:0"]; } subgraph cluster32394 { label="DeserializeToObject"; 14486 [labelType="html" label="MapPartitionsRDD [14486] toJavaRDD at <unknown>:0"]; } subgraph cluster32393 { label="MapPartitions"; 14487 [labelType="html" label="MapPartitionsRDD [14487] toJavaRDD at <unknown>:0"]; } subgraph cluster32403 { label="mapPartitions"; 14489 [labelType="html" label="MapPartitionsRDD [14489] toJavaRDD at <unknown>:0"]; } } 14476->14477; 14477->14478; 14478->14479; 14479->14480; 14480->14481; 14481->14482; 14482->14483; 14483->14484; 14484->14485; 14485->14486; 14486->14487; 14487->14488; 14488->14489; 14489->14490; }

Event Timeline

Enable zooming