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

digraph G { subgraph clusterstage_626 { label="Stage 626"; 6578 [labelType="html" label="SQLExecutionRDD [6578] run at <unknown>:0"]; 6592 [labelType="html" label="SQLExecutionRDD [6592] toJavaRDD at <unknown>:0"]; 6594 [labelType="html" label="PythonRDD [6594] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14712 { label="MicroBatchScan"; 6574 [labelType="html" label="DataSourceRDD [6574] run at <unknown>:0"]; 6575 [labelType="html" label="MapPartitionsRDD [6575] run at <unknown>:0"]; } subgraph cluster14711 { label="Project"; 6576 [labelType="html" label="MapPartitionsRDD [6576] run at <unknown>:0"]; } subgraph cluster14707 { label="WholeStageCodegen (1)"; 6577 [labelType="html" label="MapPartitionsRDD [6577] run at <unknown>:0"]; } subgraph cluster14729 { label="WholeStageCodegen (1)"; 6585 [labelType="html" label="MapPartitionsRDD [6585] toJavaRDD at <unknown>:0"]; } subgraph cluster14728 { label="Filter"; 6586 [labelType="html" label="MapPartitionsRDD [6586] toJavaRDD at <unknown>:0"]; } subgraph cluster14727 { label="Project"; 6587 [labelType="html" label="MapPartitionsRDD [6587] toJavaRDD at <unknown>:0"]; } subgraph cluster14724 { label="WholeStageCodegen (2)"; 6588 [labelType="html" label="MapPartitionsRDD [6588] toJavaRDD at <unknown>:0"]; } subgraph cluster14723 { label="Project"; 6589 [labelType="html" label="MapPartitionsRDD [6589] toJavaRDD at <unknown>:0"]; } subgraph cluster14722 { label="DeserializeToObject"; 6590 [labelType="html" label="MapPartitionsRDD [6590] toJavaRDD at <unknown>:0"]; } subgraph cluster14721 { label="MapPartitions"; 6591 [labelType="html" label="MapPartitionsRDD [6591] toJavaRDD at <unknown>:0"]; } subgraph cluster14731 { label="mapPartitions"; 6593 [labelType="html" label="MapPartitionsRDD [6593] toJavaRDD at <unknown>:0"]; } } 6574->6575; 6575->6576; 6576->6577; 6577->6578; 6578->6585; 6585->6586; 6586->6587; 6587->6588; 6588->6589; 6589->6590; 6590->6591; 6591->6592; 6592->6593; 6593->6594; }

Event Timeline

Enable zooming