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

digraph G { subgraph clusterstage_986 { label="Stage 986"; 10357 [labelType="html" label="SQLExecutionRDD [10357] run at <unknown>:0"]; 10365 [labelType="html" label="SQLExecutionRDD [10365] toJavaRDD at <unknown>:0"]; 10367 [labelType="html" label="PythonRDD [10367] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23176 { label="MicroBatchScan"; 10353 [labelType="html" label="DataSourceRDD [10353] run at <unknown>:0"]; 10354 [labelType="html" label="MapPartitionsRDD [10354] run at <unknown>:0"]; } subgraph cluster23175 { label="Project"; 10355 [labelType="html" label="MapPartitionsRDD [10355] run at <unknown>:0"]; } subgraph cluster23171 { label="WholeStageCodegen (1)"; 10356 [labelType="html" label="MapPartitionsRDD [10356] run at <unknown>:0"]; } subgraph cluster23185 { label="WholeStageCodegen (1)"; 10358 [labelType="html" label="MapPartitionsRDD [10358] toJavaRDD at <unknown>:0"]; } subgraph cluster23184 { label="Filter"; 10359 [labelType="html" label="MapPartitionsRDD [10359] toJavaRDD at <unknown>:0"]; } subgraph cluster23183 { label="Project"; 10360 [labelType="html" label="MapPartitionsRDD [10360] toJavaRDD at <unknown>:0"]; } subgraph cluster23180 { label="WholeStageCodegen (2)"; 10361 [labelType="html" label="MapPartitionsRDD [10361] toJavaRDD at <unknown>:0"]; } subgraph cluster23179 { label="Project"; 10362 [labelType="html" label="MapPartitionsRDD [10362] toJavaRDD at <unknown>:0"]; } subgraph cluster23178 { label="DeserializeToObject"; 10363 [labelType="html" label="MapPartitionsRDD [10363] toJavaRDD at <unknown>:0"]; } subgraph cluster23177 { label="MapPartitions"; 10364 [labelType="html" label="MapPartitionsRDD [10364] toJavaRDD at <unknown>:0"]; } subgraph cluster23187 { label="mapPartitions"; 10366 [labelType="html" label="MapPartitionsRDD [10366] toJavaRDD at <unknown>:0"]; } } 10353->10354; 10354->10355; 10355->10356; 10356->10357; 10357->10358; 10358->10359; 10359->10360; 10360->10361; 10361->10362; 10362->10363; 10363->10364; 10364->10365; 10365->10366; 10366->10367; }

Event Timeline

Enable zooming