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

digraph G { subgraph clusterstage_1466 { label="Stage 1466"; 15397 [labelType="html" label="SQLExecutionRDD [15397] run at <unknown>:0"]; 15405 [labelType="html" label="SQLExecutionRDD [15405] toJavaRDD at <unknown>:0"]; 15407 [labelType="html" label="PythonRDD [15407] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34456 { label="MicroBatchScan"; 15393 [labelType="html" label="DataSourceRDD [15393] run at <unknown>:0"]; 15394 [labelType="html" label="MapPartitionsRDD [15394] run at <unknown>:0"]; } subgraph cluster34455 { label="Project"; 15395 [labelType="html" label="MapPartitionsRDD [15395] run at <unknown>:0"]; } subgraph cluster34451 { label="WholeStageCodegen (1)"; 15396 [labelType="html" label="MapPartitionsRDD [15396] run at <unknown>:0"]; } subgraph cluster34465 { label="WholeStageCodegen (1)"; 15398 [labelType="html" label="MapPartitionsRDD [15398] toJavaRDD at <unknown>:0"]; } subgraph cluster34464 { label="Filter"; 15399 [labelType="html" label="MapPartitionsRDD [15399] toJavaRDD at <unknown>:0"]; } subgraph cluster34463 { label="Project"; 15400 [labelType="html" label="MapPartitionsRDD [15400] toJavaRDD at <unknown>:0"]; } subgraph cluster34460 { label="WholeStageCodegen (2)"; 15401 [labelType="html" label="MapPartitionsRDD [15401] toJavaRDD at <unknown>:0"]; } subgraph cluster34459 { label="Project"; 15402 [labelType="html" label="MapPartitionsRDD [15402] toJavaRDD at <unknown>:0"]; } subgraph cluster34458 { label="DeserializeToObject"; 15403 [labelType="html" label="MapPartitionsRDD [15403] toJavaRDD at <unknown>:0"]; } subgraph cluster34457 { label="MapPartitions"; 15404 [labelType="html" label="MapPartitionsRDD [15404] toJavaRDD at <unknown>:0"]; } subgraph cluster34467 { label="mapPartitions"; 15406 [labelType="html" label="MapPartitionsRDD [15406] toJavaRDD at <unknown>:0"]; } } 15393->15394; 15394->15395; 15395->15396; 15396->15397; 15397->15398; 15398->15399; 15399->15400; 15400->15401; 15401->15402; 15402->15403; 15403->15404; 15404->15405; 15405->15406; 15406->15407; }

Event Timeline

Enable zooming