|
21681
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/02 00:08:49
|
4.0 min
|
|
[47682]
|
Job aborted due to stage failure: Task 0 in stage 121729.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121729.0 (TID 21706146) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121729.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121729.0 (TID 21706146) (10.96.33.53 executor 5): 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:
|
|
|
21670
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/02 00:03:30
|
1.1 min
|
|
[47662]
|
Job 47662 cancelled because killed via the Web UI |
|
|
21659
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/02 00:00:30
|
45 s
|
|
[47642]
|
Job 47642 cancelled because killed via the Web UI |
|
|
21648
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 23:41:13
|
4.0 min
|
|
[47622]
|
Job aborted due to stage failure: Task 0 in stage 121600.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121600.0 (TID 21672035) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121600.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121600.0 (TID 21672035) (10.96.20.124 executor 7): 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:
|
|
|
21637
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 23:26:56
|
4.0 min
|
|
[47602]
|
Job aborted due to stage failure: Task 0 in stage 121557.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121557.0 (TID 21660663) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121557.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121557.0 (TID 21660663) (10.96.0.101 executor 6): 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:
|
|
|
21626
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 23:14:42
|
4.0 min
|
|
[47582]
|
Job aborted due to stage failure: Task 0 in stage 121514.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121514.0 (TID 21649291) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121514.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121514.0 (TID 21649291) (10.96.0.101 executor 6): 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:
|
|
|
21615
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 23:06:28
|
4.0 min
|
|
[47562]
|
Job aborted due to stage failure: Task 0 in stage 121471.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121471.0 (TID 21637919) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121471.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121471.0 (TID 21637919) (10.96.20.124 executor 7): 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:
|
|
|
21604
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 23:00:14
|
4.0 min
|
|
[47542]
|
Job aborted due to stage failure: Task 0 in stage 121428.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121428.0 (TID 21626547) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121428.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121428.0 (TID 21626547) (10.96.33.53 executor 5): 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:
|
|
|
21593
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 22:41:15
|
4.0 min
|
|
[47522]
|
Job aborted due to stage failure: Task 0 in stage 121385.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121385.0 (TID 21615175) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121385.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121385.0 (TID 21615175) (10.96.20.124 executor 7): 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:
|
|
|
21582
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 22:27:01
|
4.0 min
|
|
[47502]
|
Job aborted due to stage failure: Task 0 in stage 121342.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121342.0 (TID 21603803) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121342.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121342.0 (TID 21603803) (10.96.33.53 executor 5): 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:
|
|
|
21571
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 22:14:42
|
4.0 min
|
|
[47482]
|
Job aborted due to stage failure: Task 0 in stage 121299.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121299.0 (TID 21592431) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121299.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121299.0 (TID 21592431) (10.96.20.124 executor 7): 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:
|
|
|
21560
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 22:06:28
|
4.0 min
|
|
[47462]
|
Job aborted due to stage failure: Task 0 in stage 121256.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121256.0 (TID 21581059) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121256.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121256.0 (TID 21581059) (10.96.16.73 executor 8): 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:
|
|
|
21549
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 22:00:14
|
4.0 min
|
|
[47442]
|
Job aborted due to stage failure: Task 0 in stage 121213.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121213.0 (TID 21569687) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121213.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121213.0 (TID 21569687) (10.96.20.124 executor 7): 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:
|
|
|
21538
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 21:54:56
|
4.0 min
|
|
[47422]
|
Job aborted due to stage failure: Task 0 in stage 121170.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121170.0 (TID 21558315) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121170.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121170.0 (TID 21558315) (10.96.16.73 executor 8): 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:
|
|
|
21527
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 21:40:41
|
4.0 min
|
|
[47402]
|
Job aborted due to stage failure: Task 0 in stage 121127.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121127.0 (TID 21546943) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121127.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121127.0 (TID 21546943) (10.96.0.101 executor 6): 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:
|
|
|
21516
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 21:28:27
|
4.0 min
|
|
[47382]
|
Job aborted due to stage failure: Task 0 in stage 121084.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121084.0 (TID 21535571) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121084.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121084.0 (TID 21535571) (10.96.33.53 executor 5): 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:
|
|
|
21505
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 21:20:14
|
4.0 min
|
|
[47362]
|
Job aborted due to stage failure: Task 0 in stage 121041.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121041.0 (TID 21524199) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 121041.0 failed 4 times, most recent failure: Lost task 0.3 in stage 121041.0 (TID 21524199) (10.96.16.73 executor 8): 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:
|
|
|
21494
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 21:15:13
|
2.8 min
|
|
[47342]
|
Job 47342 cancelled because killed via the Web UI |
|
|
21483
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 21:08:35
|
4.2 min
|
|
[47322]
|
Job aborted due to stage failure: Task 0 in stage 120955.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120955.0 (TID 21501456) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120955.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120955.0 (TID 21501456) (10.96.16.73 executor 8): 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:
|
|
|
21472
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 20:54:20
|
4.0 min
|
|
[47302]
|
Job aborted due to stage failure: Task 0 in stage 120912.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120912.0 (TID 21490084) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120912.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120912.0 (TID 21490084) (10.96.16.73 executor 8): 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:
|
|
|
21461
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 20:44:45
|
1.3 min
|
|
[47282]
|
Job 47282 cancelled because killed via the Web UI |
|
|
21450
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 20:36:30
|
4.0 min
|
|
[47262]
|
Job aborted due to stage failure: Task 0 in stage 120826.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120826.0 (TID 21467342) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120826.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120826.0 (TID 21467342) (10.96.33.53 executor 5): 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:
|
|
|
21439
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 20:30:13
|
4.0 min
|
|
[47242]
|
Job aborted due to stage failure: Task 0 in stage 120783.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120783.0 (TID 21455970) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120783.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120783.0 (TID 21455970) (10.96.16.73 executor 8): 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:
|
|
|
21428
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 20:21:55
|
4.0 min
|
|
[47222]
|
Job aborted due to stage failure: Task 0 in stage 120740.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120740.0 (TID 21444598) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120740.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120740.0 (TID 21444598) (10.96.16.73 executor 8): 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:
|
|
|
21417
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 20:10:56
|
46 s
|
|
[47202]
|
Job 47202 cancelled because killed via the Web UI |
|
|
21406
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 19:59:43
|
3.0 min
|
|
[47182]
|
Job 47182 cancelled because killed via the Web UI |
|
|
21395
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 19:51:28
|
4.0 min
|
|
[47162]
|
Job aborted due to stage failure: Task 0 in stage 120611.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120611.0 (TID 21410486) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120611.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120611.0 (TID 21410486) (10.96.16.73 executor 8): 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:
|
|
|
21384
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 19:45:14
|
4.0 min
|
|
[47142]
|
Job aborted due to stage failure: Task 0 in stage 120568.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120568.0 (TID 21399114) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120568.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120568.0 (TID 21399114) (10.96.33.53 executor 5): 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:
|
|
|
21373
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 19:26:09
|
4.0 min
|
|
[47122]
|
Job aborted due to stage failure: Task 0 in stage 120525.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120525.0 (TID 21387742) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120525.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120525.0 (TID 21387742) (10.96.0.101 executor 6): 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:
|
|
|
21362
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 19:11:55
|
4.0 min
|
|
[47102]
|
Job aborted due to stage failure: Task 0 in stage 120482.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120482.0 (TID 21376370) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120482.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120482.0 (TID 21376370) (10.96.33.53 executor 5): 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:
|
|
|
21351
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 18:59:41
|
4.0 min
|
|
[47082]
|
Job aborted due to stage failure: Task 0 in stage 120439.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120439.0 (TID 21364998) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120439.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120439.0 (TID 21364998) (10.96.20.124 executor 7): 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:
|
|
|
21340
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 18:51:27
|
4.0 min
|
|
[47062]
|
Job aborted due to stage failure: Task 0 in stage 120396.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120396.0 (TID 21353626) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120396.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120396.0 (TID 21353626) (10.96.0.101 executor 6): 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:
|
|
|
21329
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 18:45:13
|
4.0 min
|
|
[47042]
|
Job aborted due to stage failure: Task 0 in stage 120353.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120353.0 (TID 21342254) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120353.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120353.0 (TID 21342254) (10.96.20.124 executor 7): 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:
|
|
|
21318
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 18:34:43
|
4.0 min
|
|
[47022]
|
Job aborted due to stage failure: Task 0 in stage 120310.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120310.0 (TID 21330882) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120310.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120310.0 (TID 21330882) (10.96.33.53 executor 5): 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:
|
|
|
21307
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 18:20:30
|
4.0 min
|
|
[47002]
|
Job aborted due to stage failure: Task 0 in stage 120267.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120267.0 (TID 21319510) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120267.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120267.0 (TID 21319510) (10.96.20.124 executor 7): 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:
|
|
|
21296
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 18:08:16
|
4.0 min
|
|
[46982]
|
Job aborted due to stage failure: Task 0 in stage 120224.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120224.0 (TID 21308138) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120224.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120224.0 (TID 21308138) (10.96.16.73 executor 8): 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:
|
|
|
21285
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 18:03:11
|
52 s
|
|
[46962]
|
Job 46962 cancelled because killed via the Web UI |
|
|
21274
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 18:00:13
|
45 s
|
|
[46942]
|
Job 46942 cancelled because killed via the Web UI |
|
|
21263
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 17:41:09
|
4.0 min
|
|
[46922]
|
Job aborted due to stage failure: Task 0 in stage 120095.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120095.0 (TID 21274028) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120095.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120095.0 (TID 21274028) (10.96.20.124 executor 7): 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:
|
|
|
21252
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 17:26:55
|
4.0 min
|
|
[46902]
|
Job aborted due to stage failure: Task 0 in stage 120052.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120052.0 (TID 21262656) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120052.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120052.0 (TID 21262656) (10.96.20.124 executor 7): 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:
|
|
|
21241
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 17:14:41
|
4.0 min
|
|
[46882]
|
Job aborted due to stage failure: Task 0 in stage 120009.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120009.0 (TID 21251284) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 120009.0 failed 4 times, most recent failure: Lost task 0.3 in stage 120009.0 (TID 21251284) (10.96.0.101 executor 6): 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:
|
|
|
21230
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 17:06:28
|
4.0 min
|
|
[46862]
|
Job aborted due to stage failure: Task 0 in stage 119966.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119966.0 (TID 21239912) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119966.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119966.0 (TID 21239912) (10.96.20.124 executor 7): 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:
|
|
|
21219
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 17:00:14
|
4.0 min
|
|
[46842]
|
Job aborted due to stage failure: Task 0 in stage 119923.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119923.0 (TID 21228540) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119923.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119923.0 (TID 21228540) (10.96.33.53 executor 5): 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:
|
|
|
21208
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 16:53:12
|
4.0 min
|
|
[46822]
|
Job aborted due to stage failure: Task 0 in stage 119880.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119880.0 (TID 21217168) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119880.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119880.0 (TID 21217168) (10.96.16.73 executor 8): 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:
|
|
|
21197
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 16:38:58
|
4.0 min
|
|
[46802]
|
Job aborted due to stage failure: Task 0 in stage 119837.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119837.0 (TID 21205796) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119837.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119837.0 (TID 21205796) (10.96.33.53 executor 5): 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:
|
|
|
21186
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 16:26:44
|
4.0 min
|
|
[46782]
|
Job aborted due to stage failure: Task 0 in stage 119794.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119794.0 (TID 21194424) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119794.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119794.0 (TID 21194424) (10.96.33.53 executor 5): 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:
|
|
|
21175
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 16:18:30
|
4.0 min
|
|
[46762]
|
Job aborted due to stage failure: Task 0 in stage 119751.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119751.0 (TID 21183052) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119751.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119751.0 (TID 21183052) (10.96.33.53 executor 5): 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:
|
|
|
21164
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 16:15:17
|
60 s
|
|
[46742]
|
Job 46742 cancelled because killed via the Web UI |
|
|
21153
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 16:11:13
|
47 s
|
|
[46722]
|
Job 46722 cancelled because killed via the Web UI |
|
|
21142
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 15:56:58
|
4.0 min
|
|
[46702]
|
Job aborted due to stage failure: Task 0 in stage 119622.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119622.0 (TID 21148942) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119622.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119622.0 (TID 21148942) (10.96.33.53 executor 5): 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:
|
|
|
21131
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 15:44:44
|
4.0 min
|
|
[46682]
|
Job aborted due to stage failure: Task 0 in stage 119579.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119579.0 (TID 21137570) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119579.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119579.0 (TID 21137570) (10.96.20.124 executor 7): 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:
|
|
|
21120
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 15:36:30
|
4.0 min
|
|
[46662]
|
Job aborted due to stage failure: Task 0 in stage 119536.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119536.0 (TID 21126198) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119536.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119536.0 (TID 21126198) (10.96.16.73 executor 8): 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:
|
|
|
21109
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 15:30:16
|
4.0 min
|
|
[46642]
|
Job aborted due to stage failure: Task 0 in stage 119493.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119493.0 (TID 21114826) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119493.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119493.0 (TID 21114826) (10.96.33.53 executor 5): 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:
|
|
|
21098
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 15:26:09
|
3.3 min
|
|
[46622]
|
Job 46622 cancelled because killed via the Web UI |
|
|
21087
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 15:11:55
|
4.0 min
|
|
[46602]
|
Job aborted due to stage failure: Task 0 in stage 119407.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119407.0 (TID 21092082) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119407.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119407.0 (TID 21092082) (10.96.33.53 executor 5): 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:
|
|
|
21076
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 14:59:41
|
4.0 min
|
|
[46582]
|
Job aborted due to stage failure: Task 0 in stage 119364.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119364.0 (TID 21080710) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119364.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119364.0 (TID 21080710) (10.96.16.73 executor 8): 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:
|
|
|
21065
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 14:51:28
|
4.0 min
|
|
[46562]
|
Job aborted due to stage failure: Task 0 in stage 119321.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119321.0 (TID 21069338) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119321.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119321.0 (TID 21069338) (10.96.16.73 executor 8): 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:
|
|
|
21054
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 14:45:15
|
4.0 min
|
|
[46542]
|
Job aborted due to stage failure: Task 0 in stage 119278.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119278.0 (TID 21057966) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119278.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119278.0 (TID 21057966) (10.96.20.124 executor 7): 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:
|
|
|
21043
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 14:26:09
|
4.0 min
|
|
[46522]
|
Job aborted due to stage failure: Task 0 in stage 119235.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119235.0 (TID 21046594) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119235.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119235.0 (TID 21046594) (10.96.33.53 executor 5): 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:
|
|
|
21032
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 14:11:55
|
4.0 min
|
|
[46502]
|
Job aborted due to stage failure: Task 0 in stage 119192.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119192.0 (TID 21035222) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119192.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119192.0 (TID 21035222) (10.96.33.53 executor 5): 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:
|
|
|
21021
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 13:59:40
|
4.0 min
|
|
[46482]
|
Job aborted due to stage failure: Task 0 in stage 119149.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119149.0 (TID 21023850) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119149.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119149.0 (TID 21023850) (10.96.0.101 executor 6): 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:
|
|
|
21010
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 13:51:27
|
4.0 min
|
|
[46462]
|
Job aborted due to stage failure: Task 0 in stage 119106.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119106.0 (TID 21012478) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119106.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119106.0 (TID 21012478) (10.96.33.53 executor 5): 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:
|
|
|
20999
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 13:45:13
|
4.0 min
|
|
[46442]
|
Job aborted due to stage failure: Task 0 in stage 119063.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119063.0 (TID 21001106) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119063.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119063.0 (TID 21001106) (10.96.0.101 executor 6): 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:
|
|
|
20988
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 13:39:07
|
4.0 min
|
|
[46422]
|
Job aborted due to stage failure: Task 0 in stage 119020.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119020.0 (TID 20989734) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 119020.0 failed 4 times, most recent failure: Lost task 0.3 in stage 119020.0 (TID 20989734) (10.96.0.101 executor 6): 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:
|
|
|
20977
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 13:24:53
|
4.0 min
|
|
[46402]
|
Job aborted due to stage failure: Task 0 in stage 118977.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118977.0 (TID 20978362) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118977.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118977.0 (TID 20978362) (10.96.20.124 executor 7): 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:
|
|
|
20966
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 13:14:41
|
2.0 min
|
|
[46382]
|
Job 46382 cancelled because killed via the Web UI |
|
|
20955
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 13:06:27
|
4.0 min
|
|
[46362]
|
Job aborted due to stage failure: Task 0 in stage 118891.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118891.0 (TID 20955620) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118891.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118891.0 (TID 20955620) (10.96.0.101 executor 6): 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:
|
|
|
20944
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 13:00:13
|
4.0 min
|
|
[46342]
|
Job aborted due to stage failure: Task 0 in stage 118848.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118848.0 (TID 20944248) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118848.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118848.0 (TID 20944248) (10.96.0.101 executor 6): 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:
|
|
|
20933
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 12:53:00
|
4.0 min
|
|
[46322]
|
Job aborted due to stage failure: Task 0 in stage 118805.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118805.0 (TID 20932876) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118805.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118805.0 (TID 20932876) (10.96.33.53 executor 5): 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:
|
|
|
20922
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 12:42:00
|
46 s
|
|
[46302]
|
Job 46302 cancelled because killed via the Web UI |
|
|
20911
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 12:29:42
|
4.0 min
|
|
[46282]
|
Job aborted due to stage failure: Task 0 in stage 118719.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118719.0 (TID 20910135) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118719.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118719.0 (TID 20910135) (10.96.16.73 executor 8): 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:
|
|
|
20900
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 12:21:28
|
4.0 min
|
|
[46262]
|
Job aborted due to stage failure: Task 0 in stage 118676.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118676.0 (TID 20898763) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118676.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118676.0 (TID 20898763) (10.96.20.124 executor 7): 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:
|
|
|
20889
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 12:15:13
|
4.0 min
|
|
[46242]
|
Job aborted due to stage failure: Task 0 in stage 118633.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118633.0 (TID 20887391) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118633.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118633.0 (TID 20887391) (10.96.20.124 executor 7): 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:
|
|
|
20878
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 12:08:48
|
4.0 min
|
|
[46222]
|
Job aborted due to stage failure: Task 0 in stage 118590.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118590.0 (TID 20876019) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118590.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118590.0 (TID 20876019) (10.96.33.53 executor 5): 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:
|
|
|
20867
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 11:54:33
|
4.0 min
|
|
[46202]
|
Job aborted due to stage failure: Task 0 in stage 118547.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118547.0 (TID 20864647) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118547.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118547.0 (TID 20864647) (10.96.16.73 executor 8): 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:
|
|
|
20856
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 11:42:19
|
4.0 min
|
|
[46182]
|
Job aborted due to stage failure: Task 0 in stage 118504.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118504.0 (TID 20853275) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118504.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118504.0 (TID 20853275) (10.96.16.73 executor 8): 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:
|
|
|
20845
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 11:36:27
|
1.7 min
|
|
[46162]
|
Job 46162 cancelled because killed via the Web UI |
|
|
20834
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 11:30:14
|
4.0 min
|
|
[46142]
|
Job aborted due to stage failure: Task 0 in stage 118418.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118418.0 (TID 20830533) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118418.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118418.0 (TID 20830533) (10.96.16.73 executor 8): 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:
|
|
|
20823
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 11:22:53
|
4.0 min
|
|
[46122]
|
Job aborted due to stage failure: Task 0 in stage 118375.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118375.0 (TID 20819161) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118375.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118375.0 (TID 20819161) (10.96.16.73 executor 8): 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:
|
|
|
20812
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 11:11:56
|
43 s
|
|
[46102]
|
Job 46102 cancelled because killed via the Web UI |
|
|
20801
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 10:59:42
|
4.0 min
|
|
[46082]
|
Job aborted due to stage failure: Task 0 in stage 118289.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118289.0 (TID 20796420) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118289.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118289.0 (TID 20796420) (10.96.16.73 executor 8): 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:
|
|
|
20790
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 10:51:28
|
4.0 min
|
|
[46062]
|
Job aborted due to stage failure: Task 0 in stage 118246.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118246.0 (TID 20785048) (10.96.16.73 executor 8): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118246.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118246.0 (TID 20785048) (10.96.16.73 executor 8): 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:
|
|
|
20779
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 10:45:14
|
4.0 min
|
|
[46042]
|
Job aborted due to stage failure: Task 0 in stage 118203.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118203.0 (TID 20773676) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118203.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118203.0 (TID 20773676) (10.96.33.53 executor 5): 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:
|
|
|
20768
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 10:38:08
|
4.0 min
|
|
[46022]
|
Job aborted due to stage failure: Task 0 in stage 118160.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118160.0 (TID 20762304) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118160.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118160.0 (TID 20762304) (10.96.33.53 executor 5): 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:
|
|
|
20757
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 10:23:54
|
4.0 min
|
|
[46002]
|
Job aborted due to stage failure: Task 0 in stage 118117.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118117.0 (TID 20750932) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118117.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118117.0 (TID 20750932) (10.96.0.101 executor 6): 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:
|
|
|
20746
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 10:11:40
|
4.0 min
|
|
[45982]
|
Job aborted due to stage failure: Task 0 in stage 118074.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118074.0 (TID 20739560) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 118074.0 failed 4 times, most recent failure: Lost task 0.3 in stage 118074.0 (TID 20739560) (10.96.0.101 executor 6): 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:
|
|
|
20735
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 10:06:30
|
57 s
|
|
[45962]
|
Job 45962 cancelled because killed via the Web UI |
|
|
20724
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 10:00:15
|
4.0 min
|
|
[45942]
|
Job aborted due to stage failure: Task 0 in stage 117988.0 failed 4 times, most recent failure: Lost task 0.3 in stage 117988.0 (TID 20716819) (10.96.33.53 executor 5): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 117988.0 failed 4 times, most recent failure: Lost task 0.3 in stage 117988.0 (TID 20716819) (10.96.33.53 executor 5): 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:
|
|
|
20713
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 09:41:06
|
4.0 min
|
|
[45922]
|
Job aborted due to stage failure: Task 0 in stage 117945.0 failed 4 times, most recent failure: Lost task 0.3 in stage 117945.0 (TID 20705447) (10.96.20.124 executor 7): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 117945.0 failed 4 times, most recent failure: Lost task 0.3 in stage 117945.0 (TID 20705447) (10.96.20.124 executor 7): 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:
|
|
|
20702
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 09:26:59
|
3.9 min
|
|
[45902]
|
Job 45902 cancelled because killed via the Web UI |
|
|
20691
|
save at ApplicationUtils.java:269
+details
save at ApplicationUtils.java:269
org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:251)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.utils.ApplicationUtils.publishToBtpKafka(ApplicationUtils.java:269)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.publishSituations(SituationsUtil.java:129)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.lambda$processAndPublishSituations$2(SituationsUtil.java:98)
java.base/java.util.ArrayList.forEach(Unknown Source)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.extractionutils.SituationsUtil.processAndPublishSituations(SituationsUtil.java:89)
com.sap.s4hana.eureka.business.crpwrkloaddetermination.temporal.activity.NotifyWorkloadDetServiceReplRunFinishedActivityImpl.notifyReplRunFinished(NotifyWorkloadDetServiceReplRunFinishedActivityImpl.java:73)
jdk.internal.reflect.GeneratedMethodAccessor504.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)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
|
2026/05/01 09:14:45
|
4.0 min
|
|
[45882]
|
Job aborted due to stage failure: Task 0 in stage 117859.0 failed 4 times, most recent failure: Lost task 0.3 in stage 117859.0 (TID 20682703) (10.96.0.101 executor 6): org.apache.kafka.common.errors.TimeoutException: Topic SituationsTopic not present in metadata after 60000 ms.
+details
Job aborted due to stage failure: Task 0 in stage 117859.0 failed 4 times, most recent failure: Lost task 0.3 in stage 117859.0 (TID 20682703) (10.96.0.101 executor 6): 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:
|
|