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

digraph G { subgraph clusterstage_1340 { label="Stage 1340"; 14074 [labelType="html" label="SQLExecutionRDD [14074] run at <unknown>:0"]; 14082 [labelType="html" label="SQLExecutionRDD [14082] toJavaRDD at <unknown>:0"]; 14084 [labelType="html" label="PythonRDD [14084] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31495 { label="MicroBatchScan"; 14070 [labelType="html" label="DataSourceRDD [14070] run at <unknown>:0"]; 14071 [labelType="html" label="MapPartitionsRDD [14071] run at <unknown>:0"]; } subgraph cluster31494 { label="Project"; 14072 [labelType="html" label="MapPartitionsRDD [14072] run at <unknown>:0"]; } subgraph cluster31490 { label="WholeStageCodegen (1)"; 14073 [labelType="html" label="MapPartitionsRDD [14073] run at <unknown>:0"]; } subgraph cluster31504 { label="WholeStageCodegen (1)"; 14075 [labelType="html" label="MapPartitionsRDD [14075] toJavaRDD at <unknown>:0"]; } subgraph cluster31503 { label="Filter"; 14076 [labelType="html" label="MapPartitionsRDD [14076] toJavaRDD at <unknown>:0"]; } subgraph cluster31502 { label="Project"; 14077 [labelType="html" label="MapPartitionsRDD [14077] toJavaRDD at <unknown>:0"]; } subgraph cluster31499 { label="WholeStageCodegen (2)"; 14078 [labelType="html" label="MapPartitionsRDD [14078] toJavaRDD at <unknown>:0"]; } subgraph cluster31498 { label="Project"; 14079 [labelType="html" label="MapPartitionsRDD [14079] toJavaRDD at <unknown>:0"]; } subgraph cluster31497 { label="DeserializeToObject"; 14080 [labelType="html" label="MapPartitionsRDD [14080] toJavaRDD at <unknown>:0"]; } subgraph cluster31496 { label="MapPartitions"; 14081 [labelType="html" label="MapPartitionsRDD [14081] toJavaRDD at <unknown>:0"]; } subgraph cluster31506 { label="mapPartitions"; 14083 [labelType="html" label="MapPartitionsRDD [14083] toJavaRDD at <unknown>:0"]; } } 14070->14071; 14071->14072; 14072->14073; 14073->14074; 14074->14075; 14075->14076; 14076->14077; 14077->14078; 14078->14079; 14079->14080; 14080->14081; 14081->14082; 14082->14083; 14083->14084; }

Event Timeline

Enable zooming