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

digraph G { subgraph clusterstage_31 { label="Stage 31"; 319 [labelType="html" label="SQLExecutionRDD [319] run at <unknown>:0"]; 333 [labelType="html" label="SQLExecutionRDD [333] toJavaRDD at NativeMethodAccessorImpl.java:0"]; 335 [labelType="html" label="PythonRDD [335] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster710 { label="MicroBatchScan"; 315 [labelType="html" label="DataSourceRDD [315] run at <unknown>:0"]; 316 [labelType="html" label="MapPartitionsRDD [316] run at <unknown>:0"]; } subgraph cluster709 { label="Project"; 317 [labelType="html" label="MapPartitionsRDD [317] run at <unknown>:0"]; } subgraph cluster705 { label="WholeStageCodegen (1)"; 318 [labelType="html" label="MapPartitionsRDD [318] run at <unknown>:0"]; } subgraph cluster727 { label="WholeStageCodegen (1)"; 326 [labelType="html" label="MapPartitionsRDD [326] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster726 { label="Filter"; 327 [labelType="html" label="MapPartitionsRDD [327] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster725 { label="Project"; 328 [labelType="html" label="MapPartitionsRDD [328] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster722 { label="WholeStageCodegen (2)"; 329 [labelType="html" label="MapPartitionsRDD [329] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster721 { label="Project"; 330 [labelType="html" label="MapPartitionsRDD [330] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster720 { label="DeserializeToObject"; 331 [labelType="html" label="MapPartitionsRDD [331] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster719 { label="MapPartitions"; 332 [labelType="html" label="MapPartitionsRDD [332] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster729 { label="mapPartitions"; 334 [labelType="html" label="MapPartitionsRDD [334] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } } 315->316; 316->317; 317->318; 318->319; 319->326; 326->327; 327->328; 328->329; 329->330; 330->331; 331->332; 332->333; 333->334; 334->335; }

Event Timeline

Enable zooming