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

digraph G { subgraph clusterstage_703 { label="Stage 703"; 7397 [labelType="html" label="SQLExecutionRDD [7397] run at <unknown>:0"]; 7405 [labelType="html" label="SQLExecutionRDD [7405] toJavaRDD at <unknown>:0"]; 7407 [labelType="html" label="PythonRDD [7407] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster16545 { label="MicroBatchScan"; 7393 [labelType="html" label="DataSourceRDD [7393] run at <unknown>:0"]; 7394 [labelType="html" label="MapPartitionsRDD [7394] run at <unknown>:0"]; } subgraph cluster16544 { label="Project"; 7395 [labelType="html" label="MapPartitionsRDD [7395] run at <unknown>:0"]; } subgraph cluster16540 { label="WholeStageCodegen (1)"; 7396 [labelType="html" label="MapPartitionsRDD [7396] run at <unknown>:0"]; } subgraph cluster16554 { label="WholeStageCodegen (1)"; 7398 [labelType="html" label="MapPartitionsRDD [7398] toJavaRDD at <unknown>:0"]; } subgraph cluster16553 { label="Filter"; 7399 [labelType="html" label="MapPartitionsRDD [7399] toJavaRDD at <unknown>:0"]; } subgraph cluster16552 { label="Project"; 7400 [labelType="html" label="MapPartitionsRDD [7400] toJavaRDD at <unknown>:0"]; } subgraph cluster16549 { label="WholeStageCodegen (2)"; 7401 [labelType="html" label="MapPartitionsRDD [7401] toJavaRDD at <unknown>:0"]; } subgraph cluster16548 { label="Project"; 7402 [labelType="html" label="MapPartitionsRDD [7402] toJavaRDD at <unknown>:0"]; } subgraph cluster16547 { label="DeserializeToObject"; 7403 [labelType="html" label="MapPartitionsRDD [7403] toJavaRDD at <unknown>:0"]; } subgraph cluster16546 { label="MapPartitions"; 7404 [labelType="html" label="MapPartitionsRDD [7404] toJavaRDD at <unknown>:0"]; } subgraph cluster16556 { label="mapPartitions"; 7406 [labelType="html" label="MapPartitionsRDD [7406] toJavaRDD at <unknown>:0"]; } } 7393->7394; 7394->7395; 7395->7396; 7396->7397; 7397->7398; 7398->7399; 7399->7400; 7400->7401; 7401->7402; 7402->7403; 7403->7404; 7404->7405; 7405->7406; 7406->7407; }

Event Timeline

Enable zooming