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

digraph G { subgraph clusterstage_1857 { label="Stage 1857"; 19492 [labelType="html" label="SQLExecutionRDD [19492] run at <unknown>:0"]; 19506 [labelType="html" label="SQLExecutionRDD [19506] toJavaRDD at <unknown>:0"]; 19508 [labelType="html" label="PythonRDD [19508] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43621 { label="MicroBatchScan"; 19488 [labelType="html" label="DataSourceRDD [19488] run at <unknown>:0"]; 19489 [labelType="html" label="MapPartitionsRDD [19489] run at <unknown>:0"]; } subgraph cluster43620 { label="Project"; 19490 [labelType="html" label="MapPartitionsRDD [19490] run at <unknown>:0"]; } subgraph cluster43616 { label="WholeStageCodegen (1)"; 19491 [labelType="html" label="MapPartitionsRDD [19491] run at <unknown>:0"]; } subgraph cluster43638 { label="WholeStageCodegen (1)"; 19499 [labelType="html" label="MapPartitionsRDD [19499] toJavaRDD at <unknown>:0"]; } subgraph cluster43637 { label="Filter"; 19500 [labelType="html" label="MapPartitionsRDD [19500] toJavaRDD at <unknown>:0"]; } subgraph cluster43636 { label="Project"; 19501 [labelType="html" label="MapPartitionsRDD [19501] toJavaRDD at <unknown>:0"]; } subgraph cluster43633 { label="WholeStageCodegen (2)"; 19502 [labelType="html" label="MapPartitionsRDD [19502] toJavaRDD at <unknown>:0"]; } subgraph cluster43632 { label="Project"; 19503 [labelType="html" label="MapPartitionsRDD [19503] toJavaRDD at <unknown>:0"]; } subgraph cluster43631 { label="DeserializeToObject"; 19504 [labelType="html" label="MapPartitionsRDD [19504] toJavaRDD at <unknown>:0"]; } subgraph cluster43630 { label="MapPartitions"; 19505 [labelType="html" label="MapPartitionsRDD [19505] toJavaRDD at <unknown>:0"]; } subgraph cluster43640 { label="mapPartitions"; 19507 [labelType="html" label="MapPartitionsRDD [19507] toJavaRDD at <unknown>:0"]; } } 19488->19489; 19489->19490; 19490->19491; 19491->19492; 19492->19499; 19499->19500; 19500->19501; 19501->19502; 19502->19503; 19503->19504; 19504->19505; 19505->19506; 19506->19507; 19507->19508; }

Event Timeline

Enable zooming