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

digraph G { subgraph clusterstage_1291 { label="Stage 1291"; 13552 [labelType="html" label="SQLExecutionRDD [13552] run at <unknown>:0"]; 13563 [labelType="html" label="SQLExecutionRDD [13563] toJavaRDD at <unknown>:0"]; 13565 [labelType="html" label="PythonRDD [13565] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30326 { label="MicroBatchScan"; 13545 [labelType="html" label="DataSourceRDD [13545] run at <unknown>:0"]; 13547 [labelType="html" label="MapPartitionsRDD [13547] run at <unknown>:0"]; } subgraph cluster30325 { label="Project"; 13548 [labelType="html" label="MapPartitionsRDD [13548] run at <unknown>:0"]; } subgraph cluster30315 { label="WholeStageCodegen (1)"; 13551 [labelType="html" label="MapPartitionsRDD [13551] run at <unknown>:0"]; } subgraph cluster30337 { label="WholeStageCodegen (1)"; 13556 [labelType="html" label="MapPartitionsRDD [13556] toJavaRDD at <unknown>:0"]; } subgraph cluster30336 { label="Filter"; 13557 [labelType="html" label="MapPartitionsRDD [13557] toJavaRDD at <unknown>:0"]; } subgraph cluster30335 { label="Project"; 13558 [labelType="html" label="MapPartitionsRDD [13558] toJavaRDD at <unknown>:0"]; } subgraph cluster30332 { label="WholeStageCodegen (2)"; 13559 [labelType="html" label="MapPartitionsRDD [13559] toJavaRDD at <unknown>:0"]; } subgraph cluster30331 { label="Project"; 13560 [labelType="html" label="MapPartitionsRDD [13560] toJavaRDD at <unknown>:0"]; } subgraph cluster30330 { label="DeserializeToObject"; 13561 [labelType="html" label="MapPartitionsRDD [13561] toJavaRDD at <unknown>:0"]; } subgraph cluster30329 { label="MapPartitions"; 13562 [labelType="html" label="MapPartitionsRDD [13562] toJavaRDD at <unknown>:0"]; } subgraph cluster30339 { label="mapPartitions"; 13564 [labelType="html" label="MapPartitionsRDD [13564] toJavaRDD at <unknown>:0"]; } } 13545->13547; 13547->13548; 13548->13551; 13551->13552; 13552->13556; 13556->13557; 13557->13558; 13558->13559; 13559->13560; 13560->13561; 13561->13562; 13562->13563; 13563->13564; 13564->13565; }

Event Timeline

Enable zooming