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

digraph G { subgraph clusterstage_961 { label="Stage 961"; 10106 [labelType="html" label="SQLExecutionRDD [10106] run at <unknown>:0"]; 10114 [labelType="html" label="SQLExecutionRDD [10114] toJavaRDD at <unknown>:0"]; 10116 [labelType="html" label="PythonRDD [10116] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22608 { label="MicroBatchScan"; 10102 [labelType="html" label="DataSourceRDD [10102] run at <unknown>:0"]; 10103 [labelType="html" label="MapPartitionsRDD [10103] run at <unknown>:0"]; } subgraph cluster22607 { label="Project"; 10104 [labelType="html" label="MapPartitionsRDD [10104] run at <unknown>:0"]; } subgraph cluster22603 { label="WholeStageCodegen (1)"; 10105 [labelType="html" label="MapPartitionsRDD [10105] run at <unknown>:0"]; } subgraph cluster22617 { label="WholeStageCodegen (1)"; 10107 [labelType="html" label="MapPartitionsRDD [10107] toJavaRDD at <unknown>:0"]; } subgraph cluster22616 { label="Filter"; 10108 [labelType="html" label="MapPartitionsRDD [10108] toJavaRDD at <unknown>:0"]; } subgraph cluster22615 { label="Project"; 10109 [labelType="html" label="MapPartitionsRDD [10109] toJavaRDD at <unknown>:0"]; } subgraph cluster22612 { label="WholeStageCodegen (2)"; 10110 [labelType="html" label="MapPartitionsRDD [10110] toJavaRDD at <unknown>:0"]; } subgraph cluster22611 { label="Project"; 10111 [labelType="html" label="MapPartitionsRDD [10111] toJavaRDD at <unknown>:0"]; } subgraph cluster22610 { label="DeserializeToObject"; 10112 [labelType="html" label="MapPartitionsRDD [10112] toJavaRDD at <unknown>:0"]; } subgraph cluster22609 { label="MapPartitions"; 10113 [labelType="html" label="MapPartitionsRDD [10113] toJavaRDD at <unknown>:0"]; } subgraph cluster22619 { label="mapPartitions"; 10115 [labelType="html" label="MapPartitionsRDD [10115] toJavaRDD at <unknown>:0"]; } } 10102->10103; 10103->10104; 10104->10105; 10105->10106; 10106->10107; 10107->10108; 10108->10109; 10109->10110; 10110->10111; 10111->10112; 10112->10113; 10113->10114; 10114->10115; 10115->10116; }

Event Timeline

Enable zooming