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

digraph G { subgraph clusterstage_1278 { label="Stage 1278"; 13423 [labelType="html" label="SQLExecutionRDD [13423] run at <unknown>:0"]; 13431 [labelType="html" label="SQLExecutionRDD [13431] toJavaRDD at <unknown>:0"]; 13433 [labelType="html" label="PythonRDD [13433] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30038 { label="MicroBatchScan"; 13419 [labelType="html" label="DataSourceRDD [13419] run at <unknown>:0"]; 13420 [labelType="html" label="MapPartitionsRDD [13420] run at <unknown>:0"]; } subgraph cluster30037 { label="Project"; 13421 [labelType="html" label="MapPartitionsRDD [13421] run at <unknown>:0"]; } subgraph cluster30033 { label="WholeStageCodegen (1)"; 13422 [labelType="html" label="MapPartitionsRDD [13422] run at <unknown>:0"]; } subgraph cluster30047 { label="WholeStageCodegen (1)"; 13424 [labelType="html" label="MapPartitionsRDD [13424] toJavaRDD at <unknown>:0"]; } subgraph cluster30046 { label="Filter"; 13425 [labelType="html" label="MapPartitionsRDD [13425] toJavaRDD at <unknown>:0"]; } subgraph cluster30045 { label="Project"; 13426 [labelType="html" label="MapPartitionsRDD [13426] toJavaRDD at <unknown>:0"]; } subgraph cluster30042 { label="WholeStageCodegen (2)"; 13427 [labelType="html" label="MapPartitionsRDD [13427] toJavaRDD at <unknown>:0"]; } subgraph cluster30041 { label="Project"; 13428 [labelType="html" label="MapPartitionsRDD [13428] toJavaRDD at <unknown>:0"]; } subgraph cluster30040 { label="DeserializeToObject"; 13429 [labelType="html" label="MapPartitionsRDD [13429] toJavaRDD at <unknown>:0"]; } subgraph cluster30039 { label="MapPartitions"; 13430 [labelType="html" label="MapPartitionsRDD [13430] toJavaRDD at <unknown>:0"]; } subgraph cluster30049 { label="mapPartitions"; 13432 [labelType="html" label="MapPartitionsRDD [13432] toJavaRDD at <unknown>:0"]; } } 13419->13420; 13420->13421; 13421->13422; 13422->13423; 13423->13424; 13424->13425; 13425->13426; 13426->13427; 13427->13428; 13428->13429; 13429->13430; 13430->13431; 13431->13432; 13432->13433; }

Event Timeline

Enable zooming