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

digraph G { subgraph clusterstage_609 { label="Stage 609"; 6410 [labelType="html" label="SQLExecutionRDD [6410] run at <unknown>:0"]; 6418 [labelType="html" label="SQLExecutionRDD [6418] toJavaRDD at <unknown>:0"]; 6420 [labelType="html" label="PythonRDD [6420] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14336 { label="MicroBatchScan"; 6406 [labelType="html" label="DataSourceRDD [6406] run at <unknown>:0"]; 6407 [labelType="html" label="MapPartitionsRDD [6407] run at <unknown>:0"]; } subgraph cluster14335 { label="Project"; 6408 [labelType="html" label="MapPartitionsRDD [6408] run at <unknown>:0"]; } subgraph cluster14331 { label="WholeStageCodegen (1)"; 6409 [labelType="html" label="MapPartitionsRDD [6409] run at <unknown>:0"]; } subgraph cluster14345 { label="WholeStageCodegen (1)"; 6411 [labelType="html" label="MapPartitionsRDD [6411] toJavaRDD at <unknown>:0"]; } subgraph cluster14344 { label="Filter"; 6412 [labelType="html" label="MapPartitionsRDD [6412] toJavaRDD at <unknown>:0"]; } subgraph cluster14343 { label="Project"; 6413 [labelType="html" label="MapPartitionsRDD [6413] toJavaRDD at <unknown>:0"]; } subgraph cluster14340 { label="WholeStageCodegen (2)"; 6414 [labelType="html" label="MapPartitionsRDD [6414] toJavaRDD at <unknown>:0"]; } subgraph cluster14339 { label="Project"; 6415 [labelType="html" label="MapPartitionsRDD [6415] toJavaRDD at <unknown>:0"]; } subgraph cluster14338 { label="DeserializeToObject"; 6416 [labelType="html" label="MapPartitionsRDD [6416] toJavaRDD at <unknown>:0"]; } subgraph cluster14337 { label="MapPartitions"; 6417 [labelType="html" label="MapPartitionsRDD [6417] toJavaRDD at <unknown>:0"]; } subgraph cluster14347 { label="mapPartitions"; 6419 [labelType="html" label="MapPartitionsRDD [6419] toJavaRDD at <unknown>:0"]; } } 6406->6407; 6407->6408; 6408->6409; 6409->6410; 6410->6411; 6411->6412; 6412->6413; 6413->6414; 6414->6415; 6415->6416; 6416->6417; 6417->6418; 6418->6419; 6419->6420; }

Event Timeline

Enable zooming