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

digraph G { subgraph clusterstage_811 { label="Stage 811"; 8509 [labelType="html" label="SQLExecutionRDD [8509] run at <unknown>:0"]; 8523 [labelType="html" label="SQLExecutionRDD [8523] toJavaRDD at <unknown>:0"]; 8525 [labelType="html" label="PythonRDD [8525] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19040 { label="MicroBatchScan"; 8505 [labelType="html" label="DataSourceRDD [8505] run at <unknown>:0"]; 8506 [labelType="html" label="MapPartitionsRDD [8506] run at <unknown>:0"]; } subgraph cluster19039 { label="Project"; 8507 [labelType="html" label="MapPartitionsRDD [8507] run at <unknown>:0"]; } subgraph cluster19035 { label="WholeStageCodegen (1)"; 8508 [labelType="html" label="MapPartitionsRDD [8508] run at <unknown>:0"]; } subgraph cluster19057 { label="WholeStageCodegen (1)"; 8516 [labelType="html" label="MapPartitionsRDD [8516] toJavaRDD at <unknown>:0"]; } subgraph cluster19056 { label="Filter"; 8517 [labelType="html" label="MapPartitionsRDD [8517] toJavaRDD at <unknown>:0"]; } subgraph cluster19055 { label="Project"; 8518 [labelType="html" label="MapPartitionsRDD [8518] toJavaRDD at <unknown>:0"]; } subgraph cluster19052 { label="WholeStageCodegen (2)"; 8519 [labelType="html" label="MapPartitionsRDD [8519] toJavaRDD at <unknown>:0"]; } subgraph cluster19051 { label="Project"; 8520 [labelType="html" label="MapPartitionsRDD [8520] toJavaRDD at <unknown>:0"]; } subgraph cluster19050 { label="DeserializeToObject"; 8521 [labelType="html" label="MapPartitionsRDD [8521] toJavaRDD at <unknown>:0"]; } subgraph cluster19049 { label="MapPartitions"; 8522 [labelType="html" label="MapPartitionsRDD [8522] toJavaRDD at <unknown>:0"]; } subgraph cluster19059 { label="mapPartitions"; 8524 [labelType="html" label="MapPartitionsRDD [8524] toJavaRDD at <unknown>:0"]; } } 8505->8506; 8506->8507; 8507->8508; 8508->8509; 8509->8516; 8516->8517; 8517->8518; 8518->8519; 8519->8520; 8520->8521; 8521->8522; 8522->8523; 8523->8524; 8524->8525; }

Event Timeline

Enable zooming