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

digraph G { subgraph clusterstage_322 { label="Stage 322"; 3385 [labelType="html" label="SQLExecutionRDD [3385] run at <unknown>:0"]; 3393 [labelType="html" label="SQLExecutionRDD [3393] toJavaRDD at <unknown>:0"]; 3395 [labelType="html" label="PythonRDD [3395] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7572 { label="MicroBatchScan"; 3381 [labelType="html" label="DataSourceRDD [3381] run at <unknown>:0"]; 3382 [labelType="html" label="MapPartitionsRDD [3382] run at <unknown>:0"]; } subgraph cluster7571 { label="Project"; 3383 [labelType="html" label="MapPartitionsRDD [3383] run at <unknown>:0"]; } subgraph cluster7567 { label="WholeStageCodegen (1)"; 3384 [labelType="html" label="MapPartitionsRDD [3384] run at <unknown>:0"]; } subgraph cluster7581 { label="WholeStageCodegen (1)"; 3386 [labelType="html" label="MapPartitionsRDD [3386] toJavaRDD at <unknown>:0"]; } subgraph cluster7580 { label="Filter"; 3387 [labelType="html" label="MapPartitionsRDD [3387] toJavaRDD at <unknown>:0"]; } subgraph cluster7579 { label="Project"; 3388 [labelType="html" label="MapPartitionsRDD [3388] toJavaRDD at <unknown>:0"]; } subgraph cluster7576 { label="WholeStageCodegen (2)"; 3389 [labelType="html" label="MapPartitionsRDD [3389] toJavaRDD at <unknown>:0"]; } subgraph cluster7575 { label="Project"; 3390 [labelType="html" label="MapPartitionsRDD [3390] toJavaRDD at <unknown>:0"]; } subgraph cluster7574 { label="DeserializeToObject"; 3391 [labelType="html" label="MapPartitionsRDD [3391] toJavaRDD at <unknown>:0"]; } subgraph cluster7573 { label="MapPartitions"; 3392 [labelType="html" label="MapPartitionsRDD [3392] toJavaRDD at <unknown>:0"]; } subgraph cluster7583 { label="mapPartitions"; 3394 [labelType="html" label="MapPartitionsRDD [3394] toJavaRDD at <unknown>:0"]; } } 3381->3382; 3382->3383; 3383->3384; 3384->3385; 3385->3386; 3386->3387; 3387->3388; 3388->3389; 3389->3390; 3390->3391; 3391->3392; 3392->3393; 3393->3394; 3394->3395; }

Event Timeline

Enable zooming