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

digraph G { subgraph clusterstage_1335 { label="Stage 1335"; 14011 [labelType="html" label="SQLExecutionRDD [14011] run at <unknown>:0"]; 14025 [labelType="html" label="SQLExecutionRDD [14025] toJavaRDD at <unknown>:0"]; 14027 [labelType="html" label="PythonRDD [14027] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31354 { label="MicroBatchScan"; 14007 [labelType="html" label="DataSourceRDD [14007] run at <unknown>:0"]; 14008 [labelType="html" label="MapPartitionsRDD [14008] run at <unknown>:0"]; } subgraph cluster31353 { label="Project"; 14009 [labelType="html" label="MapPartitionsRDD [14009] run at <unknown>:0"]; } subgraph cluster31349 { label="WholeStageCodegen (1)"; 14010 [labelType="html" label="MapPartitionsRDD [14010] run at <unknown>:0"]; } subgraph cluster31371 { label="WholeStageCodegen (1)"; 14018 [labelType="html" label="MapPartitionsRDD [14018] toJavaRDD at <unknown>:0"]; } subgraph cluster31370 { label="Filter"; 14019 [labelType="html" label="MapPartitionsRDD [14019] toJavaRDD at <unknown>:0"]; } subgraph cluster31369 { label="Project"; 14020 [labelType="html" label="MapPartitionsRDD [14020] toJavaRDD at <unknown>:0"]; } subgraph cluster31366 { label="WholeStageCodegen (2)"; 14021 [labelType="html" label="MapPartitionsRDD [14021] toJavaRDD at <unknown>:0"]; } subgraph cluster31365 { label="Project"; 14022 [labelType="html" label="MapPartitionsRDD [14022] toJavaRDD at <unknown>:0"]; } subgraph cluster31364 { label="DeserializeToObject"; 14023 [labelType="html" label="MapPartitionsRDD [14023] toJavaRDD at <unknown>:0"]; } subgraph cluster31363 { label="MapPartitions"; 14024 [labelType="html" label="MapPartitionsRDD [14024] toJavaRDD at <unknown>:0"]; } subgraph cluster31373 { label="mapPartitions"; 14026 [labelType="html" label="MapPartitionsRDD [14026] toJavaRDD at <unknown>:0"]; } } 14007->14008; 14008->14009; 14009->14010; 14010->14011; 14011->14018; 14018->14019; 14019->14020; 14020->14021; 14021->14022; 14022->14023; 14023->14024; 14024->14025; 14025->14026; 14026->14027; }

Event Timeline

Enable zooming