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

digraph G { subgraph clusterstage_1669 { label="Stage 1669"; 17540 [labelType="html" label="SQLExecutionRDD [17540] run at <unknown>:0"]; 17548 [labelType="html" label="SQLExecutionRDD [17548] toJavaRDD at <unknown>:0"]; 17550 [labelType="html" label="PythonRDD [17550] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39246 { label="MicroBatchScan"; 17536 [labelType="html" label="DataSourceRDD [17536] run at <unknown>:0"]; 17537 [labelType="html" label="MapPartitionsRDD [17537] run at <unknown>:0"]; } subgraph cluster39245 { label="Project"; 17538 [labelType="html" label="MapPartitionsRDD [17538] run at <unknown>:0"]; } subgraph cluster39241 { label="WholeStageCodegen (1)"; 17539 [labelType="html" label="MapPartitionsRDD [17539] run at <unknown>:0"]; } subgraph cluster39255 { label="WholeStageCodegen (1)"; 17541 [labelType="html" label="MapPartitionsRDD [17541] toJavaRDD at <unknown>:0"]; } subgraph cluster39254 { label="Filter"; 17542 [labelType="html" label="MapPartitionsRDD [17542] toJavaRDD at <unknown>:0"]; } subgraph cluster39253 { label="Project"; 17543 [labelType="html" label="MapPartitionsRDD [17543] toJavaRDD at <unknown>:0"]; } subgraph cluster39250 { label="WholeStageCodegen (2)"; 17544 [labelType="html" label="MapPartitionsRDD [17544] toJavaRDD at <unknown>:0"]; } subgraph cluster39249 { label="Project"; 17545 [labelType="html" label="MapPartitionsRDD [17545] toJavaRDD at <unknown>:0"]; } subgraph cluster39248 { label="DeserializeToObject"; 17546 [labelType="html" label="MapPartitionsRDD [17546] toJavaRDD at <unknown>:0"]; } subgraph cluster39247 { label="MapPartitions"; 17547 [labelType="html" label="MapPartitionsRDD [17547] toJavaRDD at <unknown>:0"]; } subgraph cluster39257 { label="mapPartitions"; 17549 [labelType="html" label="MapPartitionsRDD [17549] toJavaRDD at <unknown>:0"]; } } 17536->17537; 17537->17538; 17538->17539; 17539->17540; 17540->17541; 17541->17542; 17542->17543; 17543->17544; 17544->17545; 17545->17546; 17546->17547; 17547->17548; 17548->17549; 17549->17550; }

Event Timeline

Enable zooming