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

digraph G { subgraph clusterstage_1343 { label="Stage 1343"; 14095 [labelType="html" label="SQLExecutionRDD [14095] run at <unknown>:0"]; 14106 [labelType="html" label="SQLExecutionRDD [14106] toJavaRDD at <unknown>:0"]; 14111 [labelType="html" label="PythonRDD [14111] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31542 { label="MicroBatchScan"; 14091 [labelType="html" label="DataSourceRDD [14091] run at <unknown>:0"]; 14092 [labelType="html" label="MapPartitionsRDD [14092] run at <unknown>:0"]; } subgraph cluster31541 { label="Project"; 14093 [labelType="html" label="MapPartitionsRDD [14093] run at <unknown>:0"]; } subgraph cluster31537 { label="WholeStageCodegen (1)"; 14094 [labelType="html" label="MapPartitionsRDD [14094] run at <unknown>:0"]; } subgraph cluster31557 { label="WholeStageCodegen (1)"; 14097 [labelType="html" label="MapPartitionsRDD [14097] toJavaRDD at <unknown>:0"]; } subgraph cluster31556 { label="Filter"; 14098 [labelType="html" label="MapPartitionsRDD [14098] toJavaRDD at <unknown>:0"]; } subgraph cluster31555 { label="Project"; 14099 [labelType="html" label="MapPartitionsRDD [14099] toJavaRDD at <unknown>:0"]; } subgraph cluster31546 { label="WholeStageCodegen (2)"; 14102 [labelType="html" label="MapPartitionsRDD [14102] toJavaRDD at <unknown>:0"]; } subgraph cluster31545 { label="Project"; 14103 [labelType="html" label="MapPartitionsRDD [14103] toJavaRDD at <unknown>:0"]; } subgraph cluster31544 { label="DeserializeToObject"; 14104 [labelType="html" label="MapPartitionsRDD [14104] toJavaRDD at <unknown>:0"]; } subgraph cluster31543 { label="MapPartitions"; 14105 [labelType="html" label="MapPartitionsRDD [14105] toJavaRDD at <unknown>:0"]; } subgraph cluster31561 { label="mapPartitions"; 14110 [labelType="html" label="MapPartitionsRDD [14110] toJavaRDD at <unknown>:0"]; } } 14091->14092; 14092->14093; 14093->14094; 14094->14095; 14095->14097; 14097->14098; 14098->14099; 14099->14102; 14102->14103; 14103->14104; 14104->14105; 14105->14106; 14106->14110; 14110->14111; }

Event Timeline

Enable zooming