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

digraph G { subgraph clusterstage_411 { label="Stage 411"; 4309 [labelType="html" label="SQLExecutionRDD [4309] run at <unknown>:0"]; 4323 [labelType="html" label="SQLExecutionRDD [4323] toJavaRDD at <unknown>:0"]; 4325 [labelType="html" label="PythonRDD [4325] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster9640 { label="MicroBatchScan"; 4305 [labelType="html" label="DataSourceRDD [4305] run at <unknown>:0"]; 4306 [labelType="html" label="MapPartitionsRDD [4306] run at <unknown>:0"]; } subgraph cluster9639 { label="Project"; 4307 [labelType="html" label="MapPartitionsRDD [4307] run at <unknown>:0"]; } subgraph cluster9635 { label="WholeStageCodegen (1)"; 4308 [labelType="html" label="MapPartitionsRDD [4308] run at <unknown>:0"]; } subgraph cluster9657 { label="WholeStageCodegen (1)"; 4316 [labelType="html" label="MapPartitionsRDD [4316] toJavaRDD at <unknown>:0"]; } subgraph cluster9656 { label="Filter"; 4317 [labelType="html" label="MapPartitionsRDD [4317] toJavaRDD at <unknown>:0"]; } subgraph cluster9655 { label="Project"; 4318 [labelType="html" label="MapPartitionsRDD [4318] toJavaRDD at <unknown>:0"]; } subgraph cluster9652 { label="WholeStageCodegen (2)"; 4319 [labelType="html" label="MapPartitionsRDD [4319] toJavaRDD at <unknown>:0"]; } subgraph cluster9651 { label="Project"; 4320 [labelType="html" label="MapPartitionsRDD [4320] toJavaRDD at <unknown>:0"]; } subgraph cluster9650 { label="DeserializeToObject"; 4321 [labelType="html" label="MapPartitionsRDD [4321] toJavaRDD at <unknown>:0"]; } subgraph cluster9649 { label="MapPartitions"; 4322 [labelType="html" label="MapPartitionsRDD [4322] toJavaRDD at <unknown>:0"]; } subgraph cluster9659 { label="mapPartitions"; 4324 [labelType="html" label="MapPartitionsRDD [4324] toJavaRDD at <unknown>:0"]; } } 4305->4306; 4306->4307; 4307->4308; 4308->4309; 4309->4316; 4316->4317; 4317->4318; 4318->4319; 4319->4320; 4320->4321; 4321->4322; 4322->4323; 4323->4324; 4324->4325; }

Event Timeline

Enable zooming