processing-stream-kafka-raw-to-minio - Details for Stage 983 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 506
Associated Job Ids: 984

digraph G { subgraph clusterstage_983 { label="Stage 983"; 10337 [labelType="html" label="SQLExecutionRDD [10337] run at <unknown>:0"]; 10345 [labelType="html" label="SQLExecutionRDD [10345] toJavaRDD at <unknown>:0"]; 10347 [labelType="html" label="PythonRDD [10347] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23125 { label="MicroBatchScan"; 10333 [labelType="html" label="DataSourceRDD [10333] run at <unknown>:0"]; 10334 [labelType="html" label="MapPartitionsRDD [10334] run at <unknown>:0"]; } subgraph cluster23124 { label="Project"; 10335 [labelType="html" label="MapPartitionsRDD [10335] run at <unknown>:0"]; } subgraph cluster23120 { label="WholeStageCodegen (1)"; 10336 [labelType="html" label="MapPartitionsRDD [10336] run at <unknown>:0"]; } subgraph cluster23134 { label="WholeStageCodegen (1)"; 10338 [labelType="html" label="MapPartitionsRDD [10338] toJavaRDD at <unknown>:0"]; } subgraph cluster23133 { label="Filter"; 10339 [labelType="html" label="MapPartitionsRDD [10339] toJavaRDD at <unknown>:0"]; } subgraph cluster23132 { label="Project"; 10340 [labelType="html" label="MapPartitionsRDD [10340] toJavaRDD at <unknown>:0"]; } subgraph cluster23129 { label="WholeStageCodegen (2)"; 10341 [labelType="html" label="MapPartitionsRDD [10341] toJavaRDD at <unknown>:0"]; } subgraph cluster23128 { label="Project"; 10342 [labelType="html" label="MapPartitionsRDD [10342] toJavaRDD at <unknown>:0"]; } subgraph cluster23127 { label="DeserializeToObject"; 10343 [labelType="html" label="MapPartitionsRDD [10343] toJavaRDD at <unknown>:0"]; } subgraph cluster23126 { label="MapPartitions"; 10344 [labelType="html" label="MapPartitionsRDD [10344] toJavaRDD at <unknown>:0"]; } subgraph cluster23136 { label="mapPartitions"; 10346 [labelType="html" label="MapPartitionsRDD [10346] toJavaRDD at <unknown>:0"]; } } 10333->10334; 10334->10335; 10335->10336; 10336->10337; 10337->10338; 10338->10339; 10339->10340; 10340->10341; 10341->10342; 10342->10343; 10343->10344; 10344->10345; 10345->10346; 10346->10347; }

Event Timeline

Enable zooming