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

digraph G { subgraph clusterstage_1476 { label="Stage 1476"; 15502 [labelType="html" label="SQLExecutionRDD [15502] run at <unknown>:0"]; 15510 [labelType="html" label="SQLExecutionRDD [15510] toJavaRDD at <unknown>:0"]; 15512 [labelType="html" label="PythonRDD [15512] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster34691 { label="MicroBatchScan"; 15498 [labelType="html" label="DataSourceRDD [15498] run at <unknown>:0"]; 15499 [labelType="html" label="MapPartitionsRDD [15499] run at <unknown>:0"]; } subgraph cluster34690 { label="Project"; 15500 [labelType="html" label="MapPartitionsRDD [15500] run at <unknown>:0"]; } subgraph cluster34686 { label="WholeStageCodegen (1)"; 15501 [labelType="html" label="MapPartitionsRDD [15501] run at <unknown>:0"]; } subgraph cluster34700 { label="WholeStageCodegen (1)"; 15503 [labelType="html" label="MapPartitionsRDD [15503] toJavaRDD at <unknown>:0"]; } subgraph cluster34699 { label="Filter"; 15504 [labelType="html" label="MapPartitionsRDD [15504] toJavaRDD at <unknown>:0"]; } subgraph cluster34698 { label="Project"; 15505 [labelType="html" label="MapPartitionsRDD [15505] toJavaRDD at <unknown>:0"]; } subgraph cluster34695 { label="WholeStageCodegen (2)"; 15506 [labelType="html" label="MapPartitionsRDD [15506] toJavaRDD at <unknown>:0"]; } subgraph cluster34694 { label="Project"; 15507 [labelType="html" label="MapPartitionsRDD [15507] toJavaRDD at <unknown>:0"]; } subgraph cluster34693 { label="DeserializeToObject"; 15508 [labelType="html" label="MapPartitionsRDD [15508] toJavaRDD at <unknown>:0"]; } subgraph cluster34692 { label="MapPartitions"; 15509 [labelType="html" label="MapPartitionsRDD [15509] toJavaRDD at <unknown>:0"]; } subgraph cluster34702 { label="mapPartitions"; 15511 [labelType="html" label="MapPartitionsRDD [15511] toJavaRDD at <unknown>:0"]; } } 15498->15499; 15499->15500; 15500->15501; 15501->15502; 15502->15503; 15503->15504; 15504->15505; 15505->15506; 15506->15507; 15507->15508; 15508->15509; 15509->15510; 15510->15511; 15511->15512; }

Event Timeline

Enable zooming