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

digraph G { subgraph clusterstage_17 { label="Stage 17"; 178 [labelType="html" label="SQLExecutionRDD [178] run at <unknown>:0"]; 186 [labelType="html" label="SQLExecutionRDD [186] toJavaRDD at NativeMethodAccessorImpl.java:0"]; 188 [labelType="html" label="PythonRDD [188] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster389 { label="MicroBatchScan"; 174 [labelType="html" label="DataSourceRDD [174] run at <unknown>:0"]; 175 [labelType="html" label="MapPartitionsRDD [175] run at <unknown>:0"]; } subgraph cluster388 { label="Project"; 176 [labelType="html" label="MapPartitionsRDD [176] run at <unknown>:0"]; } subgraph cluster384 { label="WholeStageCodegen (1)"; 177 [labelType="html" label="MapPartitionsRDD [177] run at <unknown>:0"]; } subgraph cluster398 { label="WholeStageCodegen (1)"; 179 [labelType="html" label="MapPartitionsRDD [179] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster397 { label="Filter"; 180 [labelType="html" label="MapPartitionsRDD [180] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster396 { label="Project"; 181 [labelType="html" label="MapPartitionsRDD [181] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster393 { label="WholeStageCodegen (2)"; 182 [labelType="html" label="MapPartitionsRDD [182] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster392 { label="Project"; 183 [labelType="html" label="MapPartitionsRDD [183] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster391 { label="DeserializeToObject"; 184 [labelType="html" label="MapPartitionsRDD [184] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster390 { label="MapPartitions"; 185 [labelType="html" label="MapPartitionsRDD [185] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } subgraph cluster400 { label="mapPartitions"; 187 [labelType="html" label="MapPartitionsRDD [187] toJavaRDD at NativeMethodAccessorImpl.java:0"]; } } 174->175; 175->176; 176->177; 177->178; 178->179; 179->180; 180->181; 181->182; 182->183; 183->184; 184->185; 185->186; 186->187; 187->188; }

Event Timeline

Enable zooming