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

digraph G { subgraph clusterstage_1575 { label="Stage 1575"; 16553 [labelType="html" label="SQLExecutionRDD [16553] run at <unknown>:0"]; 16561 [labelType="html" label="SQLExecutionRDD [16561] toJavaRDD at <unknown>:0"]; 16563 [labelType="html" label="PythonRDD [16563] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37037 { label="MicroBatchScan"; 16549 [labelType="html" label="DataSourceRDD [16549] run at <unknown>:0"]; 16550 [labelType="html" label="MapPartitionsRDD [16550] run at <unknown>:0"]; } subgraph cluster37036 { label="Project"; 16551 [labelType="html" label="MapPartitionsRDD [16551] run at <unknown>:0"]; } subgraph cluster37032 { label="WholeStageCodegen (1)"; 16552 [labelType="html" label="MapPartitionsRDD [16552] run at <unknown>:0"]; } subgraph cluster37046 { label="WholeStageCodegen (1)"; 16554 [labelType="html" label="MapPartitionsRDD [16554] toJavaRDD at <unknown>:0"]; } subgraph cluster37045 { label="Filter"; 16555 [labelType="html" label="MapPartitionsRDD [16555] toJavaRDD at <unknown>:0"]; } subgraph cluster37044 { label="Project"; 16556 [labelType="html" label="MapPartitionsRDD [16556] toJavaRDD at <unknown>:0"]; } subgraph cluster37041 { label="WholeStageCodegen (2)"; 16557 [labelType="html" label="MapPartitionsRDD [16557] toJavaRDD at <unknown>:0"]; } subgraph cluster37040 { label="Project"; 16558 [labelType="html" label="MapPartitionsRDD [16558] toJavaRDD at <unknown>:0"]; } subgraph cluster37039 { label="DeserializeToObject"; 16559 [labelType="html" label="MapPartitionsRDD [16559] toJavaRDD at <unknown>:0"]; } subgraph cluster37038 { label="MapPartitions"; 16560 [labelType="html" label="MapPartitionsRDD [16560] toJavaRDD at <unknown>:0"]; } subgraph cluster37048 { label="mapPartitions"; 16562 [labelType="html" label="MapPartitionsRDD [16562] toJavaRDD at <unknown>:0"]; } } 16549->16550; 16550->16551; 16551->16552; 16552->16553; 16553->16554; 16554->16555; 16555->16556; 16556->16557; 16557->16558; 16558->16559; 16559->16560; 16560->16561; 16561->16562; 16562->16563; }

Event Timeline

Enable zooming