DataHubScheduler - Details for Job 24274

Status: SUCCEEDED
Submitted: 2026/10/18 10:50:21
Duration: 96 ms
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_34020 { label="Stage 34020"; 149620 [labelType="html" label="JDBCRDD [149620] cache at <unknown>:0"]; subgraph cluster361579 { label="WholeStageCodegen (1)"; 149673 [labelType="html" label="MapPartitionsRDD [149673] javaToPython at <unknown>:0"]; } subgraph cluster361578 { label="AdaptiveSparkPlan"; 149674 [labelType="html" label="MapPartitionsRDD [149674] javaToPython at <unknown>:0"]; 149675 [labelType="html" label="*(1) Scan JDBCRelation((\nSELECT ms.supplier_id, ms.supplier_uid, ms.supplier_name, ms.country, ms.state, ms.city,\n ms.is_nominated,\n CONVERT(VARCHAR(10), ms.association_accepted_date, 23) AS master_first_created_date\nFROM vw_Master_Supplier ms\nWHERE ms.brand_context_id = '6ad063ee7c692062b1d40711' AND ms.supplier_status = 'Active'\n) AS t) [numPartitions=1] [supplier_id#14299767] PushedFilters: [], ReadSchema: struct<supplier_id:string>\n [149675] [Cached] javaToPython at <unknown>:0"]; } subgraph cluster361589 { label="InMemoryTableScan"; 149679 [labelType="html" label="MapPartitionsRDD [149679] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 149680 [labelType="html" label="MapPartitionsRDD [149680] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; 149681 [labelType="html" label="MapPartitionsRDD [149681] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster361584 { label="WholeStageCodegen (1)"; 149682 [labelType="html" label="MapPartitionsRDD [149682] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } subgraph cluster361583 { label="BroadcastExchange"; 149683 [labelType="html" label="MapPartitionsRDD [149683] $anonfun$withThreadLocalCaptured$1 at <unknown>:0"]; } } 149620->149673; 149673->149674; 149674->149675; 149675->149679; 149679->149680; 149680->149681; 149681->149682; 149682->149683; }

149675

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
34020	MemgraphDeclaredBatch-6ad063ee7c692062b1d40711_0	$anonfun$withThreadLocalCaptured$1 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$1(SQLExecution.scala:219) java.base/java.util.concurrent.FutureTask.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/10/18 10:50:21	14 ms	1/1	496.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

34020

MemgraphDeclaredBatch-6ad063ee7c692062b1d40711_0

$anonfun$withThreadLocalCaptured$1 at <unknown>:0 +details

org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$1(SQLExecution.scala:219)
java.base/java.util.concurrent.FutureTask.run(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
java.base/java.lang.Thread.run(Unknown Source)

2026/10/18 10:50:21

14 ms

1/1

496.0 B

Page: