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

digraph G { subgraph clusterstage_1766 { label="Stage 1766"; 18547 [labelType="html" label="SQLExecutionRDD [18547] run at <unknown>:0"]; 18555 [labelType="html" label="SQLExecutionRDD [18555] toJavaRDD at <unknown>:0"]; 18557 [labelType="html" label="PythonRDD [18557] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41506 { label="MicroBatchScan"; 18543 [labelType="html" label="DataSourceRDD [18543] run at <unknown>:0"]; 18544 [labelType="html" label="MapPartitionsRDD [18544] run at <unknown>:0"]; } subgraph cluster41505 { label="Project"; 18545 [labelType="html" label="MapPartitionsRDD [18545] run at <unknown>:0"]; } subgraph cluster41501 { label="WholeStageCodegen (1)"; 18546 [labelType="html" label="MapPartitionsRDD [18546] run at <unknown>:0"]; } subgraph cluster41515 { label="WholeStageCodegen (1)"; 18548 [labelType="html" label="MapPartitionsRDD [18548] toJavaRDD at <unknown>:0"]; } subgraph cluster41514 { label="Filter"; 18549 [labelType="html" label="MapPartitionsRDD [18549] toJavaRDD at <unknown>:0"]; } subgraph cluster41513 { label="Project"; 18550 [labelType="html" label="MapPartitionsRDD [18550] toJavaRDD at <unknown>:0"]; } subgraph cluster41510 { label="WholeStageCodegen (2)"; 18551 [labelType="html" label="MapPartitionsRDD [18551] toJavaRDD at <unknown>:0"]; } subgraph cluster41509 { label="Project"; 18552 [labelType="html" label="MapPartitionsRDD [18552] toJavaRDD at <unknown>:0"]; } subgraph cluster41508 { label="DeserializeToObject"; 18553 [labelType="html" label="MapPartitionsRDD [18553] toJavaRDD at <unknown>:0"]; } subgraph cluster41507 { label="MapPartitions"; 18554 [labelType="html" label="MapPartitionsRDD [18554] toJavaRDD at <unknown>:0"]; } subgraph cluster41517 { label="mapPartitions"; 18556 [labelType="html" label="MapPartitionsRDD [18556] toJavaRDD at <unknown>:0"]; } } 18543->18544; 18544->18545; 18545->18546; 18546->18547; 18547->18548; 18548->18549; 18549->18550; 18550->18551; 18551->18552; 18552->18553; 18553->18554; 18554->18555; 18555->18556; 18556->18557; }

Event Timeline

Enable zooming