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

digraph G { subgraph clusterstage_1760 { label="Stage 1760"; 18484 [labelType="html" label="SQLExecutionRDD [18484] run at <unknown>:0"]; 18492 [labelType="html" label="SQLExecutionRDD [18492] toJavaRDD at <unknown>:0"]; 18494 [labelType="html" label="PythonRDD [18494] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41365 { label="MicroBatchScan"; 18480 [labelType="html" label="DataSourceRDD [18480] run at <unknown>:0"]; 18481 [labelType="html" label="MapPartitionsRDD [18481] run at <unknown>:0"]; } subgraph cluster41364 { label="Project"; 18482 [labelType="html" label="MapPartitionsRDD [18482] run at <unknown>:0"]; } subgraph cluster41360 { label="WholeStageCodegen (1)"; 18483 [labelType="html" label="MapPartitionsRDD [18483] run at <unknown>:0"]; } subgraph cluster41374 { label="WholeStageCodegen (1)"; 18485 [labelType="html" label="MapPartitionsRDD [18485] toJavaRDD at <unknown>:0"]; } subgraph cluster41373 { label="Filter"; 18486 [labelType="html" label="MapPartitionsRDD [18486] toJavaRDD at <unknown>:0"]; } subgraph cluster41372 { label="Project"; 18487 [labelType="html" label="MapPartitionsRDD [18487] toJavaRDD at <unknown>:0"]; } subgraph cluster41369 { label="WholeStageCodegen (2)"; 18488 [labelType="html" label="MapPartitionsRDD [18488] toJavaRDD at <unknown>:0"]; } subgraph cluster41368 { label="Project"; 18489 [labelType="html" label="MapPartitionsRDD [18489] toJavaRDD at <unknown>:0"]; } subgraph cluster41367 { label="DeserializeToObject"; 18490 [labelType="html" label="MapPartitionsRDD [18490] toJavaRDD at <unknown>:0"]; } subgraph cluster41366 { label="MapPartitions"; 18491 [labelType="html" label="MapPartitionsRDD [18491] toJavaRDD at <unknown>:0"]; } subgraph cluster41382 { label="mapPartitions"; 18493 [labelType="html" label="MapPartitionsRDD [18493] toJavaRDD at <unknown>:0"]; } } 18480->18481; 18481->18482; 18482->18483; 18483->18484; 18484->18485; 18485->18486; 18486->18487; 18487->18488; 18488->18489; 18489->18490; 18490->18491; 18491->18492; 18492->18493; 18493->18494; }

Event Timeline

Enable zooming