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

digraph G { subgraph clusterstage_242 { label="Stage 242"; 2545 [labelType="html" label="SQLExecutionRDD [2545] run at <unknown>:0"]; 2553 [labelType="html" label="SQLExecutionRDD [2553] toJavaRDD at <unknown>:0"]; 2555 [labelType="html" label="PythonRDD [2555] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5692 { label="MicroBatchScan"; 2541 [labelType="html" label="DataSourceRDD [2541] run at <unknown>:0"]; 2542 [labelType="html" label="MapPartitionsRDD [2542] run at <unknown>:0"]; } subgraph cluster5691 { label="Project"; 2543 [labelType="html" label="MapPartitionsRDD [2543] run at <unknown>:0"]; } subgraph cluster5687 { label="WholeStageCodegen (1)"; 2544 [labelType="html" label="MapPartitionsRDD [2544] run at <unknown>:0"]; } subgraph cluster5701 { label="WholeStageCodegen (1)"; 2546 [labelType="html" label="MapPartitionsRDD [2546] toJavaRDD at <unknown>:0"]; } subgraph cluster5700 { label="Filter"; 2547 [labelType="html" label="MapPartitionsRDD [2547] toJavaRDD at <unknown>:0"]; } subgraph cluster5699 { label="Project"; 2548 [labelType="html" label="MapPartitionsRDD [2548] toJavaRDD at <unknown>:0"]; } subgraph cluster5696 { label="WholeStageCodegen (2)"; 2549 [labelType="html" label="MapPartitionsRDD [2549] toJavaRDD at <unknown>:0"]; } subgraph cluster5695 { label="Project"; 2550 [labelType="html" label="MapPartitionsRDD [2550] toJavaRDD at <unknown>:0"]; } subgraph cluster5694 { label="DeserializeToObject"; 2551 [labelType="html" label="MapPartitionsRDD [2551] toJavaRDD at <unknown>:0"]; } subgraph cluster5693 { label="MapPartitions"; 2552 [labelType="html" label="MapPartitionsRDD [2552] toJavaRDD at <unknown>:0"]; } subgraph cluster5703 { label="mapPartitions"; 2554 [labelType="html" label="MapPartitionsRDD [2554] toJavaRDD at <unknown>:0"]; } } 2541->2542; 2542->2543; 2543->2544; 2544->2545; 2545->2546; 2546->2547; 2547->2548; 2548->2549; 2549->2550; 2550->2551; 2551->2552; 2552->2553; 2553->2554; 2554->2555; }

Event Timeline

Enable zooming