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

digraph G { subgraph clusterstage_956 { label="Stage 956"; 10043 [labelType="html" label="SQLExecutionRDD [10043] run at <unknown>:0"]; 10057 [labelType="html" label="SQLExecutionRDD [10057] toJavaRDD at <unknown>:0"]; 10059 [labelType="html" label="PythonRDD [10059] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22467 { label="MicroBatchScan"; 10039 [labelType="html" label="DataSourceRDD [10039] run at <unknown>:0"]; 10040 [labelType="html" label="MapPartitionsRDD [10040] run at <unknown>:0"]; } subgraph cluster22466 { label="Project"; 10041 [labelType="html" label="MapPartitionsRDD [10041] run at <unknown>:0"]; } subgraph cluster22462 { label="WholeStageCodegen (1)"; 10042 [labelType="html" label="MapPartitionsRDD [10042] run at <unknown>:0"]; } subgraph cluster22484 { label="WholeStageCodegen (1)"; 10050 [labelType="html" label="MapPartitionsRDD [10050] toJavaRDD at <unknown>:0"]; } subgraph cluster22483 { label="Filter"; 10051 [labelType="html" label="MapPartitionsRDD [10051] toJavaRDD at <unknown>:0"]; } subgraph cluster22482 { label="Project"; 10052 [labelType="html" label="MapPartitionsRDD [10052] toJavaRDD at <unknown>:0"]; } subgraph cluster22479 { label="WholeStageCodegen (2)"; 10053 [labelType="html" label="MapPartitionsRDD [10053] toJavaRDD at <unknown>:0"]; } subgraph cluster22478 { label="Project"; 10054 [labelType="html" label="MapPartitionsRDD [10054] toJavaRDD at <unknown>:0"]; } subgraph cluster22477 { label="DeserializeToObject"; 10055 [labelType="html" label="MapPartitionsRDD [10055] toJavaRDD at <unknown>:0"]; } subgraph cluster22476 { label="MapPartitions"; 10056 [labelType="html" label="MapPartitionsRDD [10056] toJavaRDD at <unknown>:0"]; } subgraph cluster22486 { label="mapPartitions"; 10058 [labelType="html" label="MapPartitionsRDD [10058] toJavaRDD at <unknown>:0"]; } } 10039->10040; 10040->10041; 10041->10042; 10042->10043; 10043->10050; 10050->10051; 10051->10052; 10052->10053; 10053->10054; 10054->10055; 10055->10056; 10056->10057; 10057->10058; 10058->10059; }

Event Timeline

Enable zooming