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

digraph G { subgraph clusterstage_2017 { label="Stage 2017"; 21194 [labelType="html" label="SQLExecutionRDD [21194] run at <unknown>:0"]; 21202 [labelType="html" label="SQLExecutionRDD [21202] toJavaRDD at <unknown>:0"]; 21204 [labelType="html" label="PythonRDD [21204] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47424 { label="MicroBatchScan"; 21190 [labelType="html" label="DataSourceRDD [21190] run at <unknown>:0"]; 21191 [labelType="html" label="MapPartitionsRDD [21191] run at <unknown>:0"]; } subgraph cluster47423 { label="Project"; 21192 [labelType="html" label="MapPartitionsRDD [21192] run at <unknown>:0"]; } subgraph cluster47419 { label="WholeStageCodegen (1)"; 21193 [labelType="html" label="MapPartitionsRDD [21193] run at <unknown>:0"]; } subgraph cluster47433 { label="WholeStageCodegen (1)"; 21195 [labelType="html" label="MapPartitionsRDD [21195] toJavaRDD at <unknown>:0"]; } subgraph cluster47432 { label="Filter"; 21196 [labelType="html" label="MapPartitionsRDD [21196] toJavaRDD at <unknown>:0"]; } subgraph cluster47431 { label="Project"; 21197 [labelType="html" label="MapPartitionsRDD [21197] toJavaRDD at <unknown>:0"]; } subgraph cluster47428 { label="WholeStageCodegen (2)"; 21198 [labelType="html" label="MapPartitionsRDD [21198] toJavaRDD at <unknown>:0"]; } subgraph cluster47427 { label="Project"; 21199 [labelType="html" label="MapPartitionsRDD [21199] toJavaRDD at <unknown>:0"]; } subgraph cluster47426 { label="DeserializeToObject"; 21200 [labelType="html" label="MapPartitionsRDD [21200] toJavaRDD at <unknown>:0"]; } subgraph cluster47425 { label="MapPartitions"; 21201 [labelType="html" label="MapPartitionsRDD [21201] toJavaRDD at <unknown>:0"]; } subgraph cluster47435 { label="mapPartitions"; 21203 [labelType="html" label="MapPartitionsRDD [21203] toJavaRDD at <unknown>:0"]; } } 21190->21191; 21191->21192; 21192->21193; 21193->21194; 21194->21195; 21195->21196; 21196->21197; 21197->21198; 21198->21199; 21199->21200; 21200->21201; 21201->21202; 21202->21203; 21203->21204; }

Event Timeline

Enable zooming