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

digraph G { subgraph clusterstage_1482 { label="Stage 1482"; 15565 [labelType="html" label="SQLExecutionRDD [15565] run at <unknown>:0"]; 15573 [labelType="html" label="SQLExecutionRDD [15573] toJavaRDD at <unknown>:0"]; 15575 [labelType="html" label="PythonRDD [15575] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34832 { label="MicroBatchScan"; 15561 [labelType="html" label="DataSourceRDD [15561] run at <unknown>:0"]; 15562 [labelType="html" label="MapPartitionsRDD [15562] run at <unknown>:0"]; } subgraph cluster34831 { label="Project"; 15563 [labelType="html" label="MapPartitionsRDD [15563] run at <unknown>:0"]; } subgraph cluster34827 { label="WholeStageCodegen (1)"; 15564 [labelType="html" label="MapPartitionsRDD [15564] run at <unknown>:0"]; } subgraph cluster34841 { label="WholeStageCodegen (1)"; 15566 [labelType="html" label="MapPartitionsRDD [15566] toJavaRDD at <unknown>:0"]; } subgraph cluster34840 { label="Filter"; 15567 [labelType="html" label="MapPartitionsRDD [15567] toJavaRDD at <unknown>:0"]; } subgraph cluster34839 { label="Project"; 15568 [labelType="html" label="MapPartitionsRDD [15568] toJavaRDD at <unknown>:0"]; } subgraph cluster34836 { label="WholeStageCodegen (2)"; 15569 [labelType="html" label="MapPartitionsRDD [15569] toJavaRDD at <unknown>:0"]; } subgraph cluster34835 { label="Project"; 15570 [labelType="html" label="MapPartitionsRDD [15570] toJavaRDD at <unknown>:0"]; } subgraph cluster34834 { label="DeserializeToObject"; 15571 [labelType="html" label="MapPartitionsRDD [15571] toJavaRDD at <unknown>:0"]; } subgraph cluster34833 { label="MapPartitions"; 15572 [labelType="html" label="MapPartitionsRDD [15572] toJavaRDD at <unknown>:0"]; } subgraph cluster34843 { label="mapPartitions"; 15574 [labelType="html" label="MapPartitionsRDD [15574] toJavaRDD at <unknown>:0"]; } } 15561->15562; 15562->15563; 15563->15564; 15564->15565; 15565->15566; 15566->15567; 15567->15568; 15568->15569; 15569->15570; 15570->15571; 15571->15572; 15572->15573; 15573->15574; 15574->15575; }

Event Timeline

Enable zooming