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

digraph G { subgraph clusterstage_608 { label="Stage 608"; 6388 [labelType="html" label="SQLExecutionRDD [6388] run at <unknown>:0"]; 6396 [labelType="html" label="SQLExecutionRDD [6396] toJavaRDD at <unknown>:0"]; 6398 [labelType="html" label="PythonRDD [6398] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14293 { label="MicroBatchScan"; 6384 [labelType="html" label="DataSourceRDD [6384] run at <unknown>:0"]; 6385 [labelType="html" label="MapPartitionsRDD [6385] run at <unknown>:0"]; } subgraph cluster14292 { label="Project"; 6386 [labelType="html" label="MapPartitionsRDD [6386] run at <unknown>:0"]; } subgraph cluster14288 { label="WholeStageCodegen (1)"; 6387 [labelType="html" label="MapPartitionsRDD [6387] run at <unknown>:0"]; } subgraph cluster14302 { label="WholeStageCodegen (1)"; 6389 [labelType="html" label="MapPartitionsRDD [6389] toJavaRDD at <unknown>:0"]; } subgraph cluster14301 { label="Filter"; 6390 [labelType="html" label="MapPartitionsRDD [6390] toJavaRDD at <unknown>:0"]; } subgraph cluster14300 { label="Project"; 6391 [labelType="html" label="MapPartitionsRDD [6391] toJavaRDD at <unknown>:0"]; } subgraph cluster14297 { label="WholeStageCodegen (2)"; 6392 [labelType="html" label="MapPartitionsRDD [6392] toJavaRDD at <unknown>:0"]; } subgraph cluster14296 { label="Project"; 6393 [labelType="html" label="MapPartitionsRDD [6393] toJavaRDD at <unknown>:0"]; } subgraph cluster14295 { label="DeserializeToObject"; 6394 [labelType="html" label="MapPartitionsRDD [6394] toJavaRDD at <unknown>:0"]; } subgraph cluster14294 { label="MapPartitions"; 6395 [labelType="html" label="MapPartitionsRDD [6395] toJavaRDD at <unknown>:0"]; } subgraph cluster14304 { label="mapPartitions"; 6397 [labelType="html" label="MapPartitionsRDD [6397] toJavaRDD at <unknown>:0"]; } } 6384->6385; 6385->6386; 6386->6387; 6387->6388; 6388->6389; 6389->6390; 6390->6391; 6391->6392; 6392->6393; 6393->6394; 6394->6395; 6395->6396; 6396->6397; 6397->6398; }

Event Timeline

Enable zooming