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

digraph G { subgraph clusterstage_415 { label="Stage 415"; 4357 [labelType="html" label="SQLExecutionRDD [4357] run at <unknown>:0"]; 4365 [labelType="html" label="SQLExecutionRDD [4365] toJavaRDD at <unknown>:0"]; 4367 [labelType="html" label="PythonRDD [4367] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster9742 { label="MicroBatchScan"; 4353 [labelType="html" label="DataSourceRDD [4353] run at <unknown>:0"]; 4354 [labelType="html" label="MapPartitionsRDD [4354] run at <unknown>:0"]; } subgraph cluster9741 { label="Project"; 4355 [labelType="html" label="MapPartitionsRDD [4355] run at <unknown>:0"]; } subgraph cluster9737 { label="WholeStageCodegen (1)"; 4356 [labelType="html" label="MapPartitionsRDD [4356] run at <unknown>:0"]; } subgraph cluster9751 { label="WholeStageCodegen (1)"; 4358 [labelType="html" label="MapPartitionsRDD [4358] toJavaRDD at <unknown>:0"]; } subgraph cluster9750 { label="Filter"; 4359 [labelType="html" label="MapPartitionsRDD [4359] toJavaRDD at <unknown>:0"]; } subgraph cluster9749 { label="Project"; 4360 [labelType="html" label="MapPartitionsRDD [4360] toJavaRDD at <unknown>:0"]; } subgraph cluster9746 { label="WholeStageCodegen (2)"; 4361 [labelType="html" label="MapPartitionsRDD [4361] toJavaRDD at <unknown>:0"]; } subgraph cluster9745 { label="Project"; 4362 [labelType="html" label="MapPartitionsRDD [4362] toJavaRDD at <unknown>:0"]; } subgraph cluster9744 { label="DeserializeToObject"; 4363 [labelType="html" label="MapPartitionsRDD [4363] toJavaRDD at <unknown>:0"]; } subgraph cluster9743 { label="MapPartitions"; 4364 [labelType="html" label="MapPartitionsRDD [4364] toJavaRDD at <unknown>:0"]; } subgraph cluster9753 { label="mapPartitions"; 4366 [labelType="html" label="MapPartitionsRDD [4366] toJavaRDD at <unknown>:0"]; } } 4353->4354; 4354->4355; 4355->4356; 4356->4357; 4357->4358; 4358->4359; 4359->4360; 4360->4361; 4361->4362; 4362->4363; 4363->4364; 4364->4365; 4365->4366; 4366->4367; }

Event Timeline

Enable zooming