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

digraph G { subgraph clusterstage_1850 { label="Stage 1850"; 19429 [labelType="html" label="SQLExecutionRDD [19429] run at <unknown>:0"]; 19437 [labelType="html" label="SQLExecutionRDD [19437] toJavaRDD at <unknown>:0"]; 19439 [labelType="html" label="PythonRDD [19439] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43480 { label="MicroBatchScan"; 19425 [labelType="html" label="DataSourceRDD [19425] run at <unknown>:0"]; 19426 [labelType="html" label="MapPartitionsRDD [19426] run at <unknown>:0"]; } subgraph cluster43479 { label="Project"; 19427 [labelType="html" label="MapPartitionsRDD [19427] run at <unknown>:0"]; } subgraph cluster43475 { label="WholeStageCodegen (1)"; 19428 [labelType="html" label="MapPartitionsRDD [19428] run at <unknown>:0"]; } subgraph cluster43489 { label="WholeStageCodegen (1)"; 19430 [labelType="html" label="MapPartitionsRDD [19430] toJavaRDD at <unknown>:0"]; } subgraph cluster43488 { label="Filter"; 19431 [labelType="html" label="MapPartitionsRDD [19431] toJavaRDD at <unknown>:0"]; } subgraph cluster43487 { label="Project"; 19432 [labelType="html" label="MapPartitionsRDD [19432] toJavaRDD at <unknown>:0"]; } subgraph cluster43484 { label="WholeStageCodegen (2)"; 19433 [labelType="html" label="MapPartitionsRDD [19433] toJavaRDD at <unknown>:0"]; } subgraph cluster43483 { label="Project"; 19434 [labelType="html" label="MapPartitionsRDD [19434] toJavaRDD at <unknown>:0"]; } subgraph cluster43482 { label="DeserializeToObject"; 19435 [labelType="html" label="MapPartitionsRDD [19435] toJavaRDD at <unknown>:0"]; } subgraph cluster43481 { label="MapPartitions"; 19436 [labelType="html" label="MapPartitionsRDD [19436] toJavaRDD at <unknown>:0"]; } subgraph cluster43491 { label="mapPartitions"; 19438 [labelType="html" label="MapPartitionsRDD [19438] toJavaRDD at <unknown>:0"]; } } 19425->19426; 19426->19427; 19427->19428; 19428->19429; 19429->19430; 19430->19431; 19431->19432; 19432->19433; 19433->19434; 19434->19435; 19435->19436; 19436->19437; 19437->19438; 19438->19439; }

Event Timeline

Enable zooming