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

digraph G { subgraph clusterstage_619 { label="Stage 619"; 6515 [labelType="html" label="SQLExecutionRDD [6515] run at <unknown>:0"]; 6523 [labelType="html" label="SQLExecutionRDD [6523] toJavaRDD at <unknown>:0"]; 6525 [labelType="html" label="PythonRDD [6525] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14571 { label="MicroBatchScan"; 6511 [labelType="html" label="DataSourceRDD [6511] run at <unknown>:0"]; 6512 [labelType="html" label="MapPartitionsRDD [6512] run at <unknown>:0"]; } subgraph cluster14570 { label="Project"; 6513 [labelType="html" label="MapPartitionsRDD [6513] run at <unknown>:0"]; } subgraph cluster14566 { label="WholeStageCodegen (1)"; 6514 [labelType="html" label="MapPartitionsRDD [6514] run at <unknown>:0"]; } subgraph cluster14580 { label="WholeStageCodegen (1)"; 6516 [labelType="html" label="MapPartitionsRDD [6516] toJavaRDD at <unknown>:0"]; } subgraph cluster14579 { label="Filter"; 6517 [labelType="html" label="MapPartitionsRDD [6517] toJavaRDD at <unknown>:0"]; } subgraph cluster14578 { label="Project"; 6518 [labelType="html" label="MapPartitionsRDD [6518] toJavaRDD at <unknown>:0"]; } subgraph cluster14575 { label="WholeStageCodegen (2)"; 6519 [labelType="html" label="MapPartitionsRDD [6519] toJavaRDD at <unknown>:0"]; } subgraph cluster14574 { label="Project"; 6520 [labelType="html" label="MapPartitionsRDD [6520] toJavaRDD at <unknown>:0"]; } subgraph cluster14573 { label="DeserializeToObject"; 6521 [labelType="html" label="MapPartitionsRDD [6521] toJavaRDD at <unknown>:0"]; } subgraph cluster14572 { label="MapPartitions"; 6522 [labelType="html" label="MapPartitionsRDD [6522] toJavaRDD at <unknown>:0"]; } subgraph cluster14582 { label="mapPartitions"; 6524 [labelType="html" label="MapPartitionsRDD [6524] toJavaRDD at <unknown>:0"]; } } 6511->6512; 6512->6513; 6513->6514; 6514->6515; 6515->6516; 6516->6517; 6517->6518; 6518->6519; 6519->6520; 6520->6521; 6521->6522; 6522->6523; 6523->6524; 6524->6525; }

Event Timeline

Enable zooming