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

digraph G { subgraph clusterstage_1359 { label="Stage 1359"; 14263 [labelType="html" label="SQLExecutionRDD [14263] run at <unknown>:0"]; 14277 [labelType="html" label="SQLExecutionRDD [14277] toJavaRDD at <unknown>:0"]; 14279 [labelType="html" label="PythonRDD [14279] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31918 { label="MicroBatchScan"; 14259 [labelType="html" label="DataSourceRDD [14259] run at <unknown>:0"]; 14260 [labelType="html" label="MapPartitionsRDD [14260] run at <unknown>:0"]; } subgraph cluster31917 { label="Project"; 14261 [labelType="html" label="MapPartitionsRDD [14261] run at <unknown>:0"]; } subgraph cluster31913 { label="WholeStageCodegen (1)"; 14262 [labelType="html" label="MapPartitionsRDD [14262] run at <unknown>:0"]; } subgraph cluster31935 { label="WholeStageCodegen (1)"; 14267 [labelType="html" label="MapPartitionsRDD [14267] toJavaRDD at <unknown>:0"]; } subgraph cluster31934 { label="Filter"; 14271 [labelType="html" label="MapPartitionsRDD [14271] toJavaRDD at <unknown>:0"]; } subgraph cluster31933 { label="Project"; 14272 [labelType="html" label="MapPartitionsRDD [14272] toJavaRDD at <unknown>:0"]; } subgraph cluster31930 { label="WholeStageCodegen (2)"; 14273 [labelType="html" label="MapPartitionsRDD [14273] toJavaRDD at <unknown>:0"]; } subgraph cluster31929 { label="Project"; 14274 [labelType="html" label="MapPartitionsRDD [14274] toJavaRDD at <unknown>:0"]; } subgraph cluster31928 { label="DeserializeToObject"; 14275 [labelType="html" label="MapPartitionsRDD [14275] toJavaRDD at <unknown>:0"]; } subgraph cluster31927 { label="MapPartitions"; 14276 [labelType="html" label="MapPartitionsRDD [14276] toJavaRDD at <unknown>:0"]; } subgraph cluster31937 { label="mapPartitions"; 14278 [labelType="html" label="MapPartitionsRDD [14278] toJavaRDD at <unknown>:0"]; } } 14259->14260; 14260->14261; 14261->14262; 14262->14263; 14263->14267; 14267->14271; 14271->14272; 14272->14273; 14273->14274; 14274->14275; 14275->14276; 14276->14277; 14277->14278; 14278->14279; }

Event Timeline

Enable zooming