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

digraph G { subgraph clusterstage_1336 { label="Stage 1336"; 14032 [labelType="html" label="SQLExecutionRDD [14032] run at <unknown>:0"]; 14040 [labelType="html" label="SQLExecutionRDD [14040] toJavaRDD at <unknown>:0"]; 14042 [labelType="html" label="PythonRDD [14042] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31401 { label="MicroBatchScan"; 14028 [labelType="html" label="DataSourceRDD [14028] run at <unknown>:0"]; 14029 [labelType="html" label="MapPartitionsRDD [14029] run at <unknown>:0"]; } subgraph cluster31400 { label="Project"; 14030 [labelType="html" label="MapPartitionsRDD [14030] run at <unknown>:0"]; } subgraph cluster31396 { label="WholeStageCodegen (1)"; 14031 [labelType="html" label="MapPartitionsRDD [14031] run at <unknown>:0"]; } subgraph cluster31410 { label="WholeStageCodegen (1)"; 14033 [labelType="html" label="MapPartitionsRDD [14033] toJavaRDD at <unknown>:0"]; } subgraph cluster31409 { label="Filter"; 14034 [labelType="html" label="MapPartitionsRDD [14034] toJavaRDD at <unknown>:0"]; } subgraph cluster31408 { label="Project"; 14035 [labelType="html" label="MapPartitionsRDD [14035] toJavaRDD at <unknown>:0"]; } subgraph cluster31405 { label="WholeStageCodegen (2)"; 14036 [labelType="html" label="MapPartitionsRDD [14036] toJavaRDD at <unknown>:0"]; } subgraph cluster31404 { label="Project"; 14037 [labelType="html" label="MapPartitionsRDD [14037] toJavaRDD at <unknown>:0"]; } subgraph cluster31403 { label="DeserializeToObject"; 14038 [labelType="html" label="MapPartitionsRDD [14038] toJavaRDD at <unknown>:0"]; } subgraph cluster31402 { label="MapPartitions"; 14039 [labelType="html" label="MapPartitionsRDD [14039] toJavaRDD at <unknown>:0"]; } subgraph cluster31412 { label="mapPartitions"; 14041 [labelType="html" label="MapPartitionsRDD [14041] toJavaRDD at <unknown>:0"]; } } 14028->14029; 14029->14030; 14030->14031; 14031->14032; 14032->14033; 14033->14034; 14034->14035; 14035->14036; 14036->14037; 14037->14038; 14038->14039; 14039->14040; 14040->14041; 14041->14042; }

Event Timeline

Enable zooming