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

digraph G { subgraph clusterstage_597 { label="Stage 597"; 6284 [labelType="html" label="SQLExecutionRDD [6284] run at <unknown>:0"]; 6292 [labelType="html" label="SQLExecutionRDD [6292] toJavaRDD at <unknown>:0"]; 6294 [labelType="html" label="PythonRDD [6294] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14054 { label="MicroBatchScan"; 6280 [labelType="html" label="DataSourceRDD [6280] run at <unknown>:0"]; 6281 [labelType="html" label="MapPartitionsRDD [6281] run at <unknown>:0"]; } subgraph cluster14053 { label="Project"; 6282 [labelType="html" label="MapPartitionsRDD [6282] run at <unknown>:0"]; } subgraph cluster14049 { label="WholeStageCodegen (1)"; 6283 [labelType="html" label="MapPartitionsRDD [6283] run at <unknown>:0"]; } subgraph cluster14063 { label="WholeStageCodegen (1)"; 6285 [labelType="html" label="MapPartitionsRDD [6285] toJavaRDD at <unknown>:0"]; } subgraph cluster14062 { label="Filter"; 6286 [labelType="html" label="MapPartitionsRDD [6286] toJavaRDD at <unknown>:0"]; } subgraph cluster14061 { label="Project"; 6287 [labelType="html" label="MapPartitionsRDD [6287] toJavaRDD at <unknown>:0"]; } subgraph cluster14058 { label="WholeStageCodegen (2)"; 6288 [labelType="html" label="MapPartitionsRDD [6288] toJavaRDD at <unknown>:0"]; } subgraph cluster14057 { label="Project"; 6289 [labelType="html" label="MapPartitionsRDD [6289] toJavaRDD at <unknown>:0"]; } subgraph cluster14056 { label="DeserializeToObject"; 6290 [labelType="html" label="MapPartitionsRDD [6290] toJavaRDD at <unknown>:0"]; } subgraph cluster14055 { label="MapPartitions"; 6291 [labelType="html" label="MapPartitionsRDD [6291] toJavaRDD at <unknown>:0"]; } subgraph cluster14065 { label="mapPartitions"; 6293 [labelType="html" label="MapPartitionsRDD [6293] toJavaRDD at <unknown>:0"]; } } 6280->6281; 6281->6282; 6282->6283; 6283->6284; 6284->6285; 6285->6286; 6286->6287; 6287->6288; 6288->6289; 6289->6290; 6290->6291; 6291->6292; 6292->6293; 6293->6294; }

Event Timeline

Enable zooming