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

digraph G { subgraph clusterstage_895 { label="Stage 895"; 9413 [labelType="html" label="SQLExecutionRDD [9413] run at <unknown>:0"]; 9421 [labelType="html" label="SQLExecutionRDD [9421] toJavaRDD at <unknown>:0"]; 9423 [labelType="html" label="PythonRDD [9423] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21057 { label="MicroBatchScan"; 9409 [labelType="html" label="DataSourceRDD [9409] run at <unknown>:0"]; 9410 [labelType="html" label="MapPartitionsRDD [9410] run at <unknown>:0"]; } subgraph cluster21056 { label="Project"; 9411 [labelType="html" label="MapPartitionsRDD [9411] run at <unknown>:0"]; } subgraph cluster21052 { label="WholeStageCodegen (1)"; 9412 [labelType="html" label="MapPartitionsRDD [9412] run at <unknown>:0"]; } subgraph cluster21066 { label="WholeStageCodegen (1)"; 9414 [labelType="html" label="MapPartitionsRDD [9414] toJavaRDD at <unknown>:0"]; } subgraph cluster21065 { label="Filter"; 9415 [labelType="html" label="MapPartitionsRDD [9415] toJavaRDD at <unknown>:0"]; } subgraph cluster21064 { label="Project"; 9416 [labelType="html" label="MapPartitionsRDD [9416] toJavaRDD at <unknown>:0"]; } subgraph cluster21061 { label="WholeStageCodegen (2)"; 9417 [labelType="html" label="MapPartitionsRDD [9417] toJavaRDD at <unknown>:0"]; } subgraph cluster21060 { label="Project"; 9418 [labelType="html" label="MapPartitionsRDD [9418] toJavaRDD at <unknown>:0"]; } subgraph cluster21059 { label="DeserializeToObject"; 9419 [labelType="html" label="MapPartitionsRDD [9419] toJavaRDD at <unknown>:0"]; } subgraph cluster21058 { label="MapPartitions"; 9420 [labelType="html" label="MapPartitionsRDD [9420] toJavaRDD at <unknown>:0"]; } subgraph cluster21068 { label="mapPartitions"; 9422 [labelType="html" label="MapPartitionsRDD [9422] toJavaRDD at <unknown>:0"]; } } 9409->9410; 9410->9411; 9411->9412; 9412->9413; 9413->9414; 9414->9415; 9415->9416; 9416->9417; 9417->9418; 9418->9419; 9419->9420; 9420->9421; 9421->9422; 9422->9423; }

Event Timeline

Enable zooming