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

digraph G { subgraph clusterstage_1479 { label="Stage 1479"; 15529 [labelType="html" label="SQLExecutionRDD [15529] run at <unknown>:0"]; 15537 [labelType="html" label="SQLExecutionRDD [15537] toJavaRDD at <unknown>:0"]; 15539 [labelType="html" label="PythonRDD [15539] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34746 { label="MicroBatchScan"; 15525 [labelType="html" label="DataSourceRDD [15525] run at <unknown>:0"]; 15526 [labelType="html" label="MapPartitionsRDD [15526] run at <unknown>:0"]; } subgraph cluster34745 { label="Project"; 15527 [labelType="html" label="MapPartitionsRDD [15527] run at <unknown>:0"]; } subgraph cluster34741 { label="WholeStageCodegen (1)"; 15528 [labelType="html" label="MapPartitionsRDD [15528] run at <unknown>:0"]; } subgraph cluster34755 { label="WholeStageCodegen (1)"; 15530 [labelType="html" label="MapPartitionsRDD [15530] toJavaRDD at <unknown>:0"]; } subgraph cluster34754 { label="Filter"; 15531 [labelType="html" label="MapPartitionsRDD [15531] toJavaRDD at <unknown>:0"]; } subgraph cluster34753 { label="Project"; 15532 [labelType="html" label="MapPartitionsRDD [15532] toJavaRDD at <unknown>:0"]; } subgraph cluster34750 { label="WholeStageCodegen (2)"; 15533 [labelType="html" label="MapPartitionsRDD [15533] toJavaRDD at <unknown>:0"]; } subgraph cluster34749 { label="Project"; 15534 [labelType="html" label="MapPartitionsRDD [15534] toJavaRDD at <unknown>:0"]; } subgraph cluster34748 { label="DeserializeToObject"; 15535 [labelType="html" label="MapPartitionsRDD [15535] toJavaRDD at <unknown>:0"]; } subgraph cluster34747 { label="MapPartitions"; 15536 [labelType="html" label="MapPartitionsRDD [15536] toJavaRDD at <unknown>:0"]; } subgraph cluster34757 { label="mapPartitions"; 15538 [labelType="html" label="MapPartitionsRDD [15538] toJavaRDD at <unknown>:0"]; } } 15525->15526; 15526->15527; 15527->15528; 15528->15529; 15529->15530; 15530->15531; 15531->15532; 15532->15533; 15533->15534; 15534->15535; 15535->15536; 15536->15537; 15537->15538; 15538->15539; }

Event Timeline

Enable zooming