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

digraph G { subgraph clusterstage_994 { label="Stage 994"; 10442 [labelType="html" label="SQLExecutionRDD [10442] run at <unknown>:0"]; 10456 [labelType="html" label="SQLExecutionRDD [10456] toJavaRDD at <unknown>:0"]; 10458 [labelType="html" label="PythonRDD [10458] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23360 { label="MicroBatchScan"; 10438 [labelType="html" label="DataSourceRDD [10438] run at <unknown>:0"]; 10439 [labelType="html" label="MapPartitionsRDD [10439] run at <unknown>:0"]; } subgraph cluster23359 { label="Project"; 10440 [labelType="html" label="MapPartitionsRDD [10440] run at <unknown>:0"]; } subgraph cluster23355 { label="WholeStageCodegen (1)"; 10441 [labelType="html" label="MapPartitionsRDD [10441] run at <unknown>:0"]; } subgraph cluster23377 { label="WholeStageCodegen (1)"; 10449 [labelType="html" label="MapPartitionsRDD [10449] toJavaRDD at <unknown>:0"]; } subgraph cluster23376 { label="Filter"; 10450 [labelType="html" label="MapPartitionsRDD [10450] toJavaRDD at <unknown>:0"]; } subgraph cluster23375 { label="Project"; 10451 [labelType="html" label="MapPartitionsRDD [10451] toJavaRDD at <unknown>:0"]; } subgraph cluster23372 { label="WholeStageCodegen (2)"; 10452 [labelType="html" label="MapPartitionsRDD [10452] toJavaRDD at <unknown>:0"]; } subgraph cluster23371 { label="Project"; 10453 [labelType="html" label="MapPartitionsRDD [10453] toJavaRDD at <unknown>:0"]; } subgraph cluster23370 { label="DeserializeToObject"; 10454 [labelType="html" label="MapPartitionsRDD [10454] toJavaRDD at <unknown>:0"]; } subgraph cluster23369 { label="MapPartitions"; 10455 [labelType="html" label="MapPartitionsRDD [10455] toJavaRDD at <unknown>:0"]; } subgraph cluster23379 { label="mapPartitions"; 10457 [labelType="html" label="MapPartitionsRDD [10457] toJavaRDD at <unknown>:0"]; } } 10438->10439; 10439->10440; 10440->10441; 10441->10442; 10442->10449; 10449->10450; 10450->10451; 10451->10452; 10452->10453; 10453->10454; 10454->10455; 10455->10456; 10456->10457; 10457->10458; }

Event Timeline

Enable zooming