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

digraph G { subgraph clusterstage_1001 { label="Stage 1001"; 10526 [labelType="html" label="SQLExecutionRDD [10526] run at <unknown>:0"]; 10534 [labelType="html" label="SQLExecutionRDD [10534] toJavaRDD at <unknown>:0"]; 10536 [labelType="html" label="PythonRDD [10536] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23548 { label="MicroBatchScan"; 10522 [labelType="html" label="DataSourceRDD [10522] run at <unknown>:0"]; 10523 [labelType="html" label="MapPartitionsRDD [10523] run at <unknown>:0"]; } subgraph cluster23547 { label="Project"; 10524 [labelType="html" label="MapPartitionsRDD [10524] run at <unknown>:0"]; } subgraph cluster23543 { label="WholeStageCodegen (1)"; 10525 [labelType="html" label="MapPartitionsRDD [10525] run at <unknown>:0"]; } subgraph cluster23557 { label="WholeStageCodegen (1)"; 10527 [labelType="html" label="MapPartitionsRDD [10527] toJavaRDD at <unknown>:0"]; } subgraph cluster23556 { label="Filter"; 10528 [labelType="html" label="MapPartitionsRDD [10528] toJavaRDD at <unknown>:0"]; } subgraph cluster23555 { label="Project"; 10529 [labelType="html" label="MapPartitionsRDD [10529] toJavaRDD at <unknown>:0"]; } subgraph cluster23552 { label="WholeStageCodegen (2)"; 10530 [labelType="html" label="MapPartitionsRDD [10530] toJavaRDD at <unknown>:0"]; } subgraph cluster23551 { label="Project"; 10531 [labelType="html" label="MapPartitionsRDD [10531] toJavaRDD at <unknown>:0"]; } subgraph cluster23550 { label="DeserializeToObject"; 10532 [labelType="html" label="MapPartitionsRDD [10532] toJavaRDD at <unknown>:0"]; } subgraph cluster23549 { label="MapPartitions"; 10533 [labelType="html" label="MapPartitionsRDD [10533] toJavaRDD at <unknown>:0"]; } subgraph cluster23559 { label="mapPartitions"; 10535 [labelType="html" label="MapPartitionsRDD [10535] toJavaRDD at <unknown>:0"]; } } 10522->10523; 10523->10524; 10524->10525; 10525->10526; 10526->10527; 10527->10528; 10528->10529; 10529->10530; 10530->10531; 10531->10532; 10532->10533; 10533->10534; 10534->10535; 10535->10536; }

Event Timeline

Enable zooming