crp-order-quantity-kpi-service - Details for Job 189

Status: FAILED
Submitted: 2026/04/20 06:17:36
Duration: 8.1 min
Associated SQL Query: 68
Job Group: 36e0914c-7e4e-3a52-bc93-e306e07299ba
Skipped Stages: 10
Failed Stages: 1

Enable zooming

digraph G { id="graph_533"; subgraph graph_stage_533 { id="graph_stage_533"; isCluster="true"; label="Stage 533 (skipped)"; subgraph cluster_2367 { id="cluster_2367"; isCluster="true"; label="Scan parquet "; 814 [id="node_814" labelType="html" label="FileScanRDD [814] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 816 [id="node_816" labelType="html" label="MapPartitionsRDD [816] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2356 { id="cluster_2356"; isCluster="true"; label="WholeStageCodegen (5)"; 822 [id="node_822" labelType="html" label="MapPartitionsRDD [822] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2355 { id="cluster_2355"; isCluster="true"; label="Exchange"; 825 [id="node_825" labelType="html" label="MapPartitionsRDD [825] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 826 [id="node_826" labelType="html" label="MapPartitionsRDD [826] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 814->816; 816->822; 822->825; 825->826; }

digraph G { id="graph_534"; subgraph graph_stage_534 { id="graph_stage_534"; isCluster="true"; label="Stage 534 (skipped)"; subgraph cluster_2398 { id="cluster_2398"; isCluster="true"; label="Exchange"; 853 [id="node_853" labelType="html" label="ShuffledRowRDD [853] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2394 { id="cluster_2394"; isCluster="true"; label="WholeStageCodegen (6)"; 854 [id="node_854" labelType="html" label="MapPartitionsRDD [854] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2393 { id="cluster_2393"; isCluster="true"; label="Exchange"; 855 [id="node_855" labelType="html" label="MapPartitionsRDD [855] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 853->854; 854->855; }

826,853

digraph G { id="graph_535"; subgraph graph_stage_535 { id="graph_stage_535"; isCluster="true"; label="Stage 535 (skipped)"; subgraph cluster_2369 { id="cluster_2369"; isCluster="true"; label="Scan parquet "; 827 [id="node_827" labelType="html" label="FileScanRDD [827] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 828 [id="node_828" labelType="html" label="MapPartitionsRDD [828] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2350 { id="cluster_2350"; isCluster="true"; label="WholeStageCodegen (3)"; 829 [id="node_829" labelType="html" label="MapPartitionsRDD [829] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2349 { id="cluster_2349"; isCluster="true"; label="Exchange"; 830 [id="node_830" labelType="html" label="MapPartitionsRDD [830] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 831 [id="node_831" labelType="html" label="MapPartitionsRDD [831] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 827->828; 828->829; 829->830; 830->831; }

digraph G { id="graph_536"; subgraph graph_stage_536 { id="graph_stage_536"; isCluster="true"; label="Stage 536 (skipped)"; subgraph cluster_2361 { id="cluster_2361"; isCluster="true"; label="Scan parquet "; 813 [id="node_813" labelType="html" label="FileScanRDD [813] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 815 [id="node_815" labelType="html" label="MapPartitionsRDD [815] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2337 { id="cluster_2337"; isCluster="true"; label="WholeStageCodegen (1)"; 819 [id="node_819" labelType="html" label="MapPartitionsRDD [819] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2336 { id="cluster_2336"; isCluster="true"; label="Exchange"; 823 [id="node_823" labelType="html" label="MapPartitionsRDD [823] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 813->815; 815->819; 819->823; }

digraph G { id="graph_537"; subgraph graph_stage_537 { id="graph_stage_537"; isCluster="true"; label="Stage 537 (skipped)"; subgraph cluster_2363 { id="cluster_2363"; isCluster="true"; label="Scan parquet "; 810 [id="node_810" labelType="html" label="FileScanRDD [810] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 812 [id="node_812" labelType="html" label="MapPartitionsRDD [812] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2344 { id="cluster_2344"; isCluster="true"; label="WholeStageCodegen (2)"; 817 [id="node_817" labelType="html" label="MapPartitionsRDD [817] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2343 { id="cluster_2343"; isCluster="true"; label="Exchange"; 821 [id="node_821" labelType="html" label="MapPartitionsRDD [821] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 824 [id="node_824" labelType="html" label="MapPartitionsRDD [824] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 810->812; 812->817; 817->821; 821->824; }

digraph G { id="graph_538"; subgraph graph_stage_538 { id="graph_stage_538"; isCluster="true"; label="Stage 538 (skipped)"; subgraph cluster_2405 { id="cluster_2405"; isCluster="true"; label="Exchange"; 856 [id="node_856" labelType="html" label="ShuffledRowRDD [856] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2401 { id="cluster_2401"; isCluster="true"; label="WholeStageCodegen (7)"; 857 [id="node_857" labelType="html" label="MapPartitionsRDD [857] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2400 { id="cluster_2400"; isCluster="true"; label="Exchange"; 858 [id="node_858" labelType="html" label="MapPartitionsRDD [858] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 856->857; 857->858; }

824,856

digraph G { id="graph_539"; subgraph graph_stage_539 { id="graph_stage_539"; isCluster="true"; label="Stage 539 (skipped)"; subgraph cluster_2381 { id="cluster_2381"; isCluster="true"; label="Exchange"; 834 [id="node_834" labelType="html" label="ShuffledRowRDD [834] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2379 { id="cluster_2379"; isCluster="true"; label="Exchange"; 835 [id="node_835" labelType="html" label="MapPartitionsRDD [835] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 834->835; }

823,834

digraph G { id="graph_540"; subgraph graph_stage_540 { id="graph_stage_540"; isCluster="true"; label="Stage 540 (skipped)"; subgraph cluster_2619 { id="cluster_2619"; isCluster="true"; label="Exchange"; 964 [id="node_964" labelType="html" label="ShuffledRowRDD [964] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2615 { id="cluster_2615"; isCluster="true"; label="WholeStageCodegen (8)"; 965 [id="node_965" labelType="html" label="MapPartitionsRDD [965] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2625 { id="cluster_2625"; isCluster="true"; label="Exchange"; 966 [id="node_966" labelType="html" label="ShuffledRowRDD [966] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2621 { id="cluster_2621"; isCluster="true"; label="WholeStageCodegen (9)"; 967 [id="node_967" labelType="html" label="MapPartitionsRDD [967] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2611 { id="cluster_2611"; isCluster="true"; label="WholeStageCodegen (10)"; 968 [id="node_968" labelType="html" label="ZippedPartitionsRDD2 [968] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 969 [id="node_969" labelType="html" label="MapPartitionsRDD [969] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2610 { id="cluster_2610"; isCluster="true"; label="Exchange"; 970 [id="node_970" labelType="html" label="MapPartitionsRDD [970] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 964->965; 966->967; 965->968; 967->968; 968->969; 969->970; }

835,964

858,966

digraph G { id="graph_541"; subgraph graph_stage_541 { id="graph_stage_541"; isCluster="true"; label="Stage 541 (skipped)"; subgraph cluster_2377 { id="cluster_2377"; isCluster="true"; label="Exchange"; 832 [id="node_832" labelType="html" label="ShuffledRowRDD [832] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2375 { id="cluster_2375"; isCluster="true"; label="Exchange"; 833 [id="node_833" labelType="html" label="MapPartitionsRDD [833] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 832->833; }

831,832

digraph G { id="graph_542"; subgraph graph_stage_542 { id="graph_stage_542"; isCluster="true"; label="Stage 542 (skipped)"; subgraph cluster_2805 { id="cluster_2805"; isCluster="true"; label="Exchange"; 1022 [id="node_1022" labelType="html" label="ShuffledRowRDD [1022] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2801 { id="cluster_2801"; isCluster="true"; label="WholeStageCodegen (11)"; 1023 [id="node_1023" labelType="html" label="MapPartitionsRDD [1023] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2811 { id="cluster_2811"; isCluster="true"; label="Exchange"; 1024 [id="node_1024" labelType="html" label="ShuffledRowRDD [1024] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2807 { id="cluster_2807"; isCluster="true"; label="WholeStageCodegen (12)"; 1025 [id="node_1025" labelType="html" label="MapPartitionsRDD [1025] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2798 { id="cluster_2798"; isCluster="true"; label="WholeStageCodegen (13)"; 1026 [id="node_1026" labelType="html" label="ZippedPartitionsRDD2 [1026] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1027 [id="node_1027" labelType="html" label="MapPartitionsRDD [1027] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2797 { id="cluster_2797"; isCluster="true"; label="Project"; 1028 [id="node_1028" labelType="html" label="MapPartitionsRDD [1028] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2784 { id="cluster_2784"; isCluster="true"; label="WholeStageCodegen (14)"; 1029 [id="node_1029" labelType="html" label="MapPartitionsRDD [1029] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2783 { id="cluster_2783"; isCluster="true"; label="Exchange"; 1030 [id="node_1030" labelType="html" label="MapPartitionsRDD [1030] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1022->1023; 1024->1025; 1023->1026; 1025->1026; 1026->1027; 1027->1028; 1028->1029; 1029->1030; }

970,1022

833,1024

digraph G { id="graph_543"; subgraph graph_stage_543 { id="graph_stage_543"; isCluster="true"; label="Stage 543"; 1037 [id="node_1037" labelType="html" label="SQLExecutionRDD [1037] [Unordered] save at KafkaAdapter.java:134}"]; subgraph cluster_2820 { id="cluster_2820"; isCluster="true"; label="Exchange"; 1031 [id="node_1031" labelType="html" label="ShuffledRowRDD [1031] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2816 { id="cluster_2816"; isCluster="true"; label="WholeStageCodegen (15)"; 1032 [id="node_1032" labelType="html" label="MapPartitionsRDD [1032] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2826 { id="cluster_2826"; isCluster="true"; label="Exchange"; 1033 [id="node_1033" labelType="html" label="ShuffledRowRDD [1033] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2822 { id="cluster_2822"; isCluster="true"; label="WholeStageCodegen (16)"; 1034 [id="node_1034" labelType="html" label="MapPartitionsRDD [1034] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2812 { id="cluster_2812"; isCluster="true"; label="WholeStageCodegen (17)"; 1035 [id="node_1035" labelType="html" label="ZippedPartitionsRDD2 [1035] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1036 [id="node_1036" labelType="html" label="MapPartitionsRDD [1036] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1031->1032; 1033->1034; 1032->1035; 1034->1035; 1035->1036; 1036->1037; }

1030,1031

855,1033

Skipped Stages (10)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
542	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37
541	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37
540	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37
539	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37
538	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37
537	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37
536	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37
535	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/2
534	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37
533	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.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)	Unknown	Unknown	0/37

Page:

Failed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write	Failure Reason
543	tenants-pool-506	replenishmentRunId = 10000000004 tenantId = 8793759653749352888 activityType = BufferDataSnapShot activityId = 36e0914c-7e4e-3a52-bc93-e306e07299ba workflowType = KpiPrepareDataSnapshotWorkflow workflowId = b49fb3c6-88b3-3c61-97e8-cbe3f98f9409 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD save at KafkaAdapter.java:134 +details org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.KafkaAdapter.publishMessageToBTPKafka(KafkaAdapter.java:134) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.KafkaAdapter.publishInsights(KafkaAdapter.java:60) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.InsightHandlerDataAccessImpl.publishInsights(InsightHandlerDataAccessImpl.java:47) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.insights.InsightHandlerImpl.publish(InsightHandlerImpl.java:46) java.base/java.lang.Iterable.forEach(Unknown Source) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:63) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:44) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)	2026/04/20 06:17:36	8.1 min	0/37 (123 failed) (20 killed: Stage cancelled: Job aborted due to stage failure: Task 6 in stage 543.0 failed 8 times, most recent failure: Lost task 6.7 in stage 543.0 (TID 6682) (10.96.31.75 executor 3): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms. Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Driver stacktrace:)			3.7 GiB		Job aborted due to stage failure: Task 6 in stage 543.0 failed 8 times, most recent failure: Lost task 6.7 in stage 543.0 (TID 6682) (10.96.31.75 executor 3): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms. +details Job aborted due to stage failure: Task 6 in stage 543.0 failed 8 times, most recent failure: Lost task 6.7 in stage 543.0 (TID 6682) (10.96.31.75 executor 3): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms. Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Driver stacktrace:

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

Failure Reason

543

tenants-pool-506

replenishmentRunId = 10000000004 tenantId = 8793759653749352888 activityType = BufferDataSnapShot activityId = 36e0914c-7e4e-3a52-bc93-e306e07299ba workflowType = KpiPrepareDataSnapshotWorkflow workflowId = b49fb3c6-88b3-3c61-97e8-cbe3f98f9409 attempt = 1 cornerstoneTenantId = 8445 marketUnit = 10000_OP_PERF scenario = STANDARD save at KafkaAdapter.java:134 +details

org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:126)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.KafkaAdapter.publishMessageToBTPKafka(KafkaAdapter.java:134)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.KafkaAdapter.publishInsights(KafkaAdapter.java:60)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.InsightHandlerDataAccessImpl.publishInsights(InsightHandlerDataAccessImpl.java:47)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.insights.InsightHandlerImpl.publish(InsightHandlerImpl.java:46)
java.base/java.lang.Iterable.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.datasnapshot.DataSnapshotGenerationImpl.prepareDataSnapshot(DataSnapshotGenerationImpl.java:63)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.CreateDataSnapshotForShardActivityImpl.bufferDataSnapShot(CreateDataSnapshotForShardActivityImpl.java:44)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44)
io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23)
io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88)
io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76)

2026/04/20 06:17:36

8.1 min

0/37 (123 failed) (20 killed: Stage cancelled: Job aborted due to stage failure: Task 6 in stage 543.0 failed 8 times, most recent failure: Lost task 6.7 in stage 543.0 (TID 6682) (10.96.31.75 executor 3): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms. Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Driver stacktrace:)

3.7 GiB

Job aborted due to stage failure: Task 6 in stage 543.0 failed 8 times, most recent failure: Lost task 6.7 in stage 543.0 (TID 6682) (10.96.31.75 executor 3): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms. +details

Job aborted due to stage failure: Task 6 in stage 543.0 failed 8 times, most recent failure: Lost task 6.7 in stage 543.0 (TID 6682) (10.96.31.75 executor 3): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.

Driver stacktrace:

Page: