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

digraph G { subgraph clusterstage_1717 { label="Stage 1717"; 18044 [labelType="html" label="SQLExecutionRDD [18044] run at <unknown>:0"]; 18052 [labelType="html" label="SQLExecutionRDD [18052] toJavaRDD at <unknown>:0"]; 18054 [labelType="html" label="PythonRDD [18054] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40374 { label="MicroBatchScan"; 18040 [labelType="html" label="DataSourceRDD [18040] run at <unknown>:0"]; 18041 [labelType="html" label="MapPartitionsRDD [18041] run at <unknown>:0"]; } subgraph cluster40373 { label="Project"; 18042 [labelType="html" label="MapPartitionsRDD [18042] run at <unknown>:0"]; } subgraph cluster40369 { label="WholeStageCodegen (1)"; 18043 [labelType="html" label="MapPartitionsRDD [18043] run at <unknown>:0"]; } subgraph cluster40383 { label="WholeStageCodegen (1)"; 18045 [labelType="html" label="MapPartitionsRDD [18045] toJavaRDD at <unknown>:0"]; } subgraph cluster40382 { label="Filter"; 18046 [labelType="html" label="MapPartitionsRDD [18046] toJavaRDD at <unknown>:0"]; } subgraph cluster40381 { label="Project"; 18047 [labelType="html" label="MapPartitionsRDD [18047] toJavaRDD at <unknown>:0"]; } subgraph cluster40378 { label="WholeStageCodegen (2)"; 18048 [labelType="html" label="MapPartitionsRDD [18048] toJavaRDD at <unknown>:0"]; } subgraph cluster40377 { label="Project"; 18049 [labelType="html" label="MapPartitionsRDD [18049] toJavaRDD at <unknown>:0"]; } subgraph cluster40376 { label="DeserializeToObject"; 18050 [labelType="html" label="MapPartitionsRDD [18050] toJavaRDD at <unknown>:0"]; } subgraph cluster40375 { label="MapPartitions"; 18051 [labelType="html" label="MapPartitionsRDD [18051] toJavaRDD at <unknown>:0"]; } subgraph cluster40385 { label="mapPartitions"; 18053 [labelType="html" label="MapPartitionsRDD [18053] toJavaRDD at <unknown>:0"]; } } 18040->18041; 18041->18042; 18042->18043; 18043->18044; 18044->18045; 18045->18046; 18046->18047; 18047->18048; 18048->18049; 18049->18050; 18050->18051; 18051->18052; 18052->18053; 18053->18054; }

Event Timeline

Enable zooming