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

digraph G { subgraph clusterstage_2047 { label="Stage 2047"; 21509 [labelType="html" label="SQLExecutionRDD [21509] run at <unknown>:0"]; 21517 [labelType="html" label="SQLExecutionRDD [21517] toJavaRDD at <unknown>:0"]; 21519 [labelType="html" label="PythonRDD [21519] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster48129 { label="MicroBatchScan"; 21505 [labelType="html" label="DataSourceRDD [21505] run at <unknown>:0"]; 21506 [labelType="html" label="MapPartitionsRDD [21506] run at <unknown>:0"]; } subgraph cluster48128 { label="Project"; 21507 [labelType="html" label="MapPartitionsRDD [21507] run at <unknown>:0"]; } subgraph cluster48124 { label="WholeStageCodegen (1)"; 21508 [labelType="html" label="MapPartitionsRDD [21508] run at <unknown>:0"]; } subgraph cluster48138 { label="WholeStageCodegen (1)"; 21510 [labelType="html" label="MapPartitionsRDD [21510] toJavaRDD at <unknown>:0"]; } subgraph cluster48137 { label="Filter"; 21511 [labelType="html" label="MapPartitionsRDD [21511] toJavaRDD at <unknown>:0"]; } subgraph cluster48136 { label="Project"; 21512 [labelType="html" label="MapPartitionsRDD [21512] toJavaRDD at <unknown>:0"]; } subgraph cluster48133 { label="WholeStageCodegen (2)"; 21513 [labelType="html" label="MapPartitionsRDD [21513] toJavaRDD at <unknown>:0"]; } subgraph cluster48132 { label="Project"; 21514 [labelType="html" label="MapPartitionsRDD [21514] toJavaRDD at <unknown>:0"]; } subgraph cluster48131 { label="DeserializeToObject"; 21515 [labelType="html" label="MapPartitionsRDD [21515] toJavaRDD at <unknown>:0"]; } subgraph cluster48130 { label="MapPartitions"; 21516 [labelType="html" label="MapPartitionsRDD [21516] toJavaRDD at <unknown>:0"]; } subgraph cluster48140 { label="mapPartitions"; 21518 [labelType="html" label="MapPartitionsRDD [21518] toJavaRDD at <unknown>:0"]; } } 21505->21506; 21506->21507; 21507->21508; 21508->21509; 21509->21510; 21510->21511; 21511->21512; 21512->21513; 21513->21514; 21514->21515; 21515->21516; 21516->21517; 21517->21518; 21518->21519; }

Event Timeline

Enable zooming