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

digraph G { subgraph clusterstage_1088 { label="Stage 1088"; 11435 [labelType="html" label="SQLExecutionRDD [11435] run at <unknown>:0"]; 11443 [labelType="html" label="SQLExecutionRDD [11443] toJavaRDD at <unknown>:0"]; 11445 [labelType="html" label="PythonRDD [11445] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25577 { label="MicroBatchScan"; 11431 [labelType="html" label="DataSourceRDD [11431] run at <unknown>:0"]; 11432 [labelType="html" label="MapPartitionsRDD [11432] run at <unknown>:0"]; } subgraph cluster25576 { label="Project"; 11433 [labelType="html" label="MapPartitionsRDD [11433] run at <unknown>:0"]; } subgraph cluster25572 { label="WholeStageCodegen (1)"; 11434 [labelType="html" label="MapPartitionsRDD [11434] run at <unknown>:0"]; } subgraph cluster25586 { label="WholeStageCodegen (1)"; 11436 [labelType="html" label="MapPartitionsRDD [11436] toJavaRDD at <unknown>:0"]; } subgraph cluster25585 { label="Filter"; 11437 [labelType="html" label="MapPartitionsRDD [11437] toJavaRDD at <unknown>:0"]; } subgraph cluster25584 { label="Project"; 11438 [labelType="html" label="MapPartitionsRDD [11438] toJavaRDD at <unknown>:0"]; } subgraph cluster25581 { label="WholeStageCodegen (2)"; 11439 [labelType="html" label="MapPartitionsRDD [11439] toJavaRDD at <unknown>:0"]; } subgraph cluster25580 { label="Project"; 11440 [labelType="html" label="MapPartitionsRDD [11440] toJavaRDD at <unknown>:0"]; } subgraph cluster25579 { label="DeserializeToObject"; 11441 [labelType="html" label="MapPartitionsRDD [11441] toJavaRDD at <unknown>:0"]; } subgraph cluster25578 { label="MapPartitions"; 11442 [labelType="html" label="MapPartitionsRDD [11442] toJavaRDD at <unknown>:0"]; } subgraph cluster25588 { label="mapPartitions"; 11444 [labelType="html" label="MapPartitionsRDD [11444] toJavaRDD at <unknown>:0"]; } } 11431->11432; 11432->11433; 11433->11434; 11434->11435; 11435->11436; 11436->11437; 11437->11438; 11438->11439; 11439->11440; 11440->11441; 11441->11442; 11442->11443; 11443->11444; 11444->11445; }

Event Timeline

Enable zooming