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

digraph G { subgraph clusterstage_998 { label="Stage 998"; 10483 [labelType="html" label="SQLExecutionRDD [10483] run at <unknown>:0"]; 10491 [labelType="html" label="SQLExecutionRDD [10491] toJavaRDD at <unknown>:0"]; 10499 [labelType="html" label="PythonRDD [10499] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23458 { label="MicroBatchScan"; 10479 [labelType="html" label="DataSourceRDD [10479] run at <unknown>:0"]; 10480 [labelType="html" label="MapPartitionsRDD [10480] run at <unknown>:0"]; } subgraph cluster23457 { label="Project"; 10481 [labelType="html" label="MapPartitionsRDD [10481] run at <unknown>:0"]; } subgraph cluster23453 { label="WholeStageCodegen (1)"; 10482 [labelType="html" label="MapPartitionsRDD [10482] run at <unknown>:0"]; } subgraph cluster23467 { label="WholeStageCodegen (1)"; 10484 [labelType="html" label="MapPartitionsRDD [10484] toJavaRDD at <unknown>:0"]; } subgraph cluster23466 { label="Filter"; 10485 [labelType="html" label="MapPartitionsRDD [10485] toJavaRDD at <unknown>:0"]; } subgraph cluster23465 { label="Project"; 10486 [labelType="html" label="MapPartitionsRDD [10486] toJavaRDD at <unknown>:0"]; } subgraph cluster23462 { label="WholeStageCodegen (2)"; 10487 [labelType="html" label="MapPartitionsRDD [10487] toJavaRDD at <unknown>:0"]; } subgraph cluster23461 { label="Project"; 10488 [labelType="html" label="MapPartitionsRDD [10488] toJavaRDD at <unknown>:0"]; } subgraph cluster23460 { label="DeserializeToObject"; 10489 [labelType="html" label="MapPartitionsRDD [10489] toJavaRDD at <unknown>:0"]; } subgraph cluster23459 { label="MapPartitions"; 10490 [labelType="html" label="MapPartitionsRDD [10490] toJavaRDD at <unknown>:0"]; } subgraph cluster23469 { label="mapPartitions"; 10492 [labelType="html" label="MapPartitionsRDD [10492] toJavaRDD at <unknown>:0"]; } } 10479->10480; 10480->10481; 10481->10482; 10482->10483; 10483->10484; 10484->10485; 10485->10486; 10486->10487; 10487->10488; 10488->10489; 10489->10490; 10490->10491; 10491->10492; 10492->10499; }

Event Timeline

Enable zooming