processing-stream-kafka-raw-to-minio - Details for Stage 232 (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: 232

digraph G { subgraph clusterstage_232 { label="Stage 232"; 2440 [labelType="html" label="SQLExecutionRDD [2440] run at <unknown>:0"]; 2448 [labelType="html" label="SQLExecutionRDD [2448] toJavaRDD at <unknown>:0"]; 2450 [labelType="html" label="PythonRDD [2450] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5457 { label="MicroBatchScan"; 2436 [labelType="html" label="DataSourceRDD [2436] run at <unknown>:0"]; 2437 [labelType="html" label="MapPartitionsRDD [2437] run at <unknown>:0"]; } subgraph cluster5456 { label="Project"; 2438 [labelType="html" label="MapPartitionsRDD [2438] run at <unknown>:0"]; } subgraph cluster5452 { label="WholeStageCodegen (1)"; 2439 [labelType="html" label="MapPartitionsRDD [2439] run at <unknown>:0"]; } subgraph cluster5466 { label="WholeStageCodegen (1)"; 2441 [labelType="html" label="MapPartitionsRDD [2441] toJavaRDD at <unknown>:0"]; } subgraph cluster5465 { label="Filter"; 2442 [labelType="html" label="MapPartitionsRDD [2442] toJavaRDD at <unknown>:0"]; } subgraph cluster5464 { label="Project"; 2443 [labelType="html" label="MapPartitionsRDD [2443] toJavaRDD at <unknown>:0"]; } subgraph cluster5461 { label="WholeStageCodegen (2)"; 2444 [labelType="html" label="MapPartitionsRDD [2444] toJavaRDD at <unknown>:0"]; } subgraph cluster5460 { label="Project"; 2445 [labelType="html" label="MapPartitionsRDD [2445] toJavaRDD at <unknown>:0"]; } subgraph cluster5459 { label="DeserializeToObject"; 2446 [labelType="html" label="MapPartitionsRDD [2446] toJavaRDD at <unknown>:0"]; } subgraph cluster5458 { label="MapPartitions"; 2447 [labelType="html" label="MapPartitionsRDD [2447] toJavaRDD at <unknown>:0"]; } subgraph cluster5468 { label="mapPartitions"; 2449 [labelType="html" label="MapPartitionsRDD [2449] toJavaRDD at <unknown>:0"]; } } 2436->2437; 2437->2438; 2438->2439; 2439->2440; 2440->2441; 2441->2442; 2442->2443; 2443->2444; 2444->2445; 2445->2446; 2446->2447; 2447->2448; 2448->2449; 2449->2450; }

Event Timeline

Enable zooming