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

digraph G { subgraph clusterstage_59 { label="Stage 59"; 613 [labelType="html" label="SQLExecutionRDD [613] run at <unknown>:0"]; 627 [labelType="html" label="SQLExecutionRDD [627] toJavaRDD at <unknown>:0"]; 629 [labelType="html" label="PythonRDD [629] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster1368 { label="MicroBatchScan"; 609 [labelType="html" label="DataSourceRDD [609] run at <unknown>:0"]; 610 [labelType="html" label="MapPartitionsRDD [610] run at <unknown>:0"]; } subgraph cluster1367 { label="Project"; 611 [labelType="html" label="MapPartitionsRDD [611] run at <unknown>:0"]; } subgraph cluster1363 { label="WholeStageCodegen (1)"; 612 [labelType="html" label="MapPartitionsRDD [612] run at <unknown>:0"]; } subgraph cluster1385 { label="WholeStageCodegen (1)"; 620 [labelType="html" label="MapPartitionsRDD [620] toJavaRDD at <unknown>:0"]; } subgraph cluster1384 { label="Filter"; 621 [labelType="html" label="MapPartitionsRDD [621] toJavaRDD at <unknown>:0"]; } subgraph cluster1383 { label="Project"; 622 [labelType="html" label="MapPartitionsRDD [622] toJavaRDD at <unknown>:0"]; } subgraph cluster1380 { label="WholeStageCodegen (2)"; 623 [labelType="html" label="MapPartitionsRDD [623] toJavaRDD at <unknown>:0"]; } subgraph cluster1379 { label="Project"; 624 [labelType="html" label="MapPartitionsRDD [624] toJavaRDD at <unknown>:0"]; } subgraph cluster1378 { label="DeserializeToObject"; 625 [labelType="html" label="MapPartitionsRDD [625] toJavaRDD at <unknown>:0"]; } subgraph cluster1377 { label="MapPartitions"; 626 [labelType="html" label="MapPartitionsRDD [626] toJavaRDD at <unknown>:0"]; } subgraph cluster1387 { label="mapPartitions"; 628 [labelType="html" label="MapPartitionsRDD [628] toJavaRDD at <unknown>:0"]; } } 609->610; 610->611; 611->612; 612->613; 613->620; 620->621; 621->622; 622->623; 623->624; 624->625; 625->626; 626->627; 627->628; 628->629; }

Event Timeline

Enable zooming