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

digraph G { subgraph clusterstage_1431 { label="Stage 1431"; 15041 [labelType="html" label="SQLExecutionRDD [15041] run at <unknown>:0"]; 15049 [labelType="html" label="SQLExecutionRDD [15049] toJavaRDD at <unknown>:0"]; 15051 [labelType="html" label="PythonRDD [15051] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33653 { label="MicroBatchScan"; 15037 [labelType="html" label="DataSourceRDD [15037] run at <unknown>:0"]; 15038 [labelType="html" label="MapPartitionsRDD [15038] run at <unknown>:0"]; } subgraph cluster33652 { label="Project"; 15039 [labelType="html" label="MapPartitionsRDD [15039] run at <unknown>:0"]; } subgraph cluster33648 { label="WholeStageCodegen (1)"; 15040 [labelType="html" label="MapPartitionsRDD [15040] run at <unknown>:0"]; } subgraph cluster33662 { label="WholeStageCodegen (1)"; 15042 [labelType="html" label="MapPartitionsRDD [15042] toJavaRDD at <unknown>:0"]; } subgraph cluster33661 { label="Filter"; 15043 [labelType="html" label="MapPartitionsRDD [15043] toJavaRDD at <unknown>:0"]; } subgraph cluster33660 { label="Project"; 15044 [labelType="html" label="MapPartitionsRDD [15044] toJavaRDD at <unknown>:0"]; } subgraph cluster33657 { label="WholeStageCodegen (2)"; 15045 [labelType="html" label="MapPartitionsRDD [15045] toJavaRDD at <unknown>:0"]; } subgraph cluster33656 { label="Project"; 15046 [labelType="html" label="MapPartitionsRDD [15046] toJavaRDD at <unknown>:0"]; } subgraph cluster33655 { label="DeserializeToObject"; 15047 [labelType="html" label="MapPartitionsRDD [15047] toJavaRDD at <unknown>:0"]; } subgraph cluster33654 { label="MapPartitions"; 15048 [labelType="html" label="MapPartitionsRDD [15048] toJavaRDD at <unknown>:0"]; } subgraph cluster33664 { label="mapPartitions"; 15050 [labelType="html" label="MapPartitionsRDD [15050] toJavaRDD at <unknown>:0"]; } } 15037->15038; 15038->15039; 15039->15040; 15040->15041; 15041->15042; 15042->15043; 15043->15044; 15044->15045; 15045->15046; 15046->15047; 15047->15048; 15048->15049; 15049->15050; 15050->15051; }

Event Timeline

Enable zooming