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

digraph G { subgraph clusterstage_1096 { label="Stage 1096"; 11512 [labelType="html" label="SQLExecutionRDD [11512] run at <unknown>:0"]; 11520 [labelType="html" label="SQLExecutionRDD [11520] toJavaRDD at <unknown>:0"]; 11522 [labelType="html" label="PythonRDD [11522] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25761 { label="MicroBatchScan"; 11508 [labelType="html" label="DataSourceRDD [11508] run at <unknown>:0"]; 11509 [labelType="html" label="MapPartitionsRDD [11509] run at <unknown>:0"]; } subgraph cluster25760 { label="Project"; 11510 [labelType="html" label="MapPartitionsRDD [11510] run at <unknown>:0"]; } subgraph cluster25756 { label="WholeStageCodegen (1)"; 11511 [labelType="html" label="MapPartitionsRDD [11511] run at <unknown>:0"]; } subgraph cluster25770 { label="WholeStageCodegen (1)"; 11513 [labelType="html" label="MapPartitionsRDD [11513] toJavaRDD at <unknown>:0"]; } subgraph cluster25769 { label="Filter"; 11514 [labelType="html" label="MapPartitionsRDD [11514] toJavaRDD at <unknown>:0"]; } subgraph cluster25768 { label="Project"; 11515 [labelType="html" label="MapPartitionsRDD [11515] toJavaRDD at <unknown>:0"]; } subgraph cluster25765 { label="WholeStageCodegen (2)"; 11516 [labelType="html" label="MapPartitionsRDD [11516] toJavaRDD at <unknown>:0"]; } subgraph cluster25764 { label="Project"; 11517 [labelType="html" label="MapPartitionsRDD [11517] toJavaRDD at <unknown>:0"]; } subgraph cluster25763 { label="DeserializeToObject"; 11518 [labelType="html" label="MapPartitionsRDD [11518] toJavaRDD at <unknown>:0"]; } subgraph cluster25762 { label="MapPartitions"; 11519 [labelType="html" label="MapPartitionsRDD [11519] toJavaRDD at <unknown>:0"]; } subgraph cluster25772 { label="mapPartitions"; 11521 [labelType="html" label="MapPartitionsRDD [11521] toJavaRDD at <unknown>:0"]; } } 11508->11509; 11509->11510; 11510->11511; 11511->11512; 11512->11513; 11513->11514; 11514->11515; 11515->11516; 11516->11517; 11517->11518; 11518->11519; 11519->11520; 11520->11521; 11521->11522; }

Event Timeline

Enable zooming