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

digraph G { subgraph clusterstage_204 { label="Stage 204"; 2146 [labelType="html" label="SQLExecutionRDD [2146] run at <unknown>:0"]; 2154 [labelType="html" label="SQLExecutionRDD [2154] toJavaRDD at <unknown>:0"]; 2156 [labelType="html" label="PythonRDD [2156] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster4799 { label="MicroBatchScan"; 2142 [labelType="html" label="DataSourceRDD [2142] run at <unknown>:0"]; 2143 [labelType="html" label="MapPartitionsRDD [2143] run at <unknown>:0"]; } subgraph cluster4798 { label="Project"; 2144 [labelType="html" label="MapPartitionsRDD [2144] run at <unknown>:0"]; } subgraph cluster4794 { label="WholeStageCodegen (1)"; 2145 [labelType="html" label="MapPartitionsRDD [2145] run at <unknown>:0"]; } subgraph cluster4808 { label="WholeStageCodegen (1)"; 2147 [labelType="html" label="MapPartitionsRDD [2147] toJavaRDD at <unknown>:0"]; } subgraph cluster4807 { label="Filter"; 2148 [labelType="html" label="MapPartitionsRDD [2148] toJavaRDD at <unknown>:0"]; } subgraph cluster4806 { label="Project"; 2149 [labelType="html" label="MapPartitionsRDD [2149] toJavaRDD at <unknown>:0"]; } subgraph cluster4803 { label="WholeStageCodegen (2)"; 2150 [labelType="html" label="MapPartitionsRDD [2150] toJavaRDD at <unknown>:0"]; } subgraph cluster4802 { label="Project"; 2151 [labelType="html" label="MapPartitionsRDD [2151] toJavaRDD at <unknown>:0"]; } subgraph cluster4801 { label="DeserializeToObject"; 2152 [labelType="html" label="MapPartitionsRDD [2152] toJavaRDD at <unknown>:0"]; } subgraph cluster4800 { label="MapPartitions"; 2153 [labelType="html" label="MapPartitionsRDD [2153] toJavaRDD at <unknown>:0"]; } subgraph cluster4810 { label="mapPartitions"; 2155 [labelType="html" label="MapPartitionsRDD [2155] toJavaRDD at <unknown>:0"]; } } 2142->2143; 2143->2144; 2144->2145; 2145->2146; 2146->2147; 2147->2148; 2148->2149; 2149->2150; 2150->2151; 2151->2152; 2152->2153; 2153->2154; 2154->2155; 2155->2156; }

Event Timeline

Enable zooming