Question

S&P GLOBAL
IN
Last activity: 31 May 2022 6:21 EDT
We are experiencing slowness while login, observed kafka timeout exceptions, does anyone have idea
2022-05-31 00:02:16,274 GMT*8*EXCP0001*0*0*acm-pega-backend-1*NA*NA*BK0QIUOBQ4VNWS5T66IP6KIUL86NPBCSBA*NA*PegaSample*null*c5f8d11e1c6712b822be592273fd678f*N*0*pyBIIncrementalIndexer*8129*DataFlow-Service-PickingupRun-pyBIIncrementalIndexer_Input:104, Access group: [PRPC:AsyncProcessor], PartitionsEQUALS[18,19,2,3,4]*STANDARD*com.pega.dsm.dnode.impl.dataflow.listener.RetryLoggerListener*NA*NA*NA*NA*NA****NA*NA*NA*NA*NA*NA*initial Executable;0 additional frames in stack;*NA*[MSG][[pyBIIncrementalIndexer] Preparing retry 231.
2022-05-31 00:02:16,274 GMT*8*EXCP0001*0*0*acm-pega-backend-1*NA*NA*BK0QIUOBQ4VNWS5T66IP6KIUL86NPBCSBA*NA*PegaSample*null*c5f8d11e1c6712b822be592273fd678f*N*0*pyBIIncrementalIndexer*8129*DataFlow-Service-PickingupRun-pyBIIncrementalIndexer_Input:104, Access group: [PRPC:AsyncProcessor], PartitionsEQUALS[18,19,2,3,4]*STANDARD*com.pega.dsm.dnode.impl.dataflow.listener.RetryLoggerListener*NA*NA*NA*NA*NA****NA*NA*NA*NA*NA*NA*initial Executable;0 additional frames in stack;*NA*[MSG][[pyBIIncrementalIndexer] Preparing retry 231. Next attempt in 2m on data flow [pyBIIncrementalIndexer] on stage [InputStage] with affected partitions: [18, 19, 2, 3, 4]][STACK][java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Stream SPI error<CR> at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)<CR> at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)<CR> at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:783)<CR> at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792)<CR> at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153)<CR> at com.pega.fnx.stream.spi.impl.metric.StreamSPIMetricsProxy.execute(StreamSPIMetricsProxy.java:41)<CR> at com.pega.fnx.stream.spi.impl.StreamSP.execute(StreamSP.java:55)<CR> at com.pega.fnx.stream.spi.loader.SPIProxy.execute(SPIProxy.java:48)<CR> at com.pega.platform.stream.StreamSPIStateValidator.execute(StreamSPIStateValidator.java:67)<CR> at com.pega.platform.stream.StreamSPIRequestValidator.execute(StreamSPIRequestValidator.java:57)<CR> at com.pega.fnx.stream.api.OffsetFetcher.getStartingOffsets(OffsetFetcher.java:37)<CR> at com.pega.fnx.stream.api.Subscription.getStartingOffsets(Subscription.java:130)<CR> at com.pega.fnx.stream.api.Subscription.pollingSubscriber(Subscription.java:50)<CR> at com.pega.dsm.dnode.impl.dataset.stream.StreamBrowseOperation.processRecords(StreamBrowseOperation.java:131)<CR> at com.pega.dsm.dnode.impl.dataset.stream.StreamBrowseOperation.access$000(StreamBrowseOperation.java:61)<CR> at com.pega.dsm.dnode.impl.dataset.stream.StreamBrowseOperation$1.emit(StreamBrowseOperation.java:107)<CR> at com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:353)<CR> at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:55)<CR> at com.pega.dsm.dnode.impl.dataflow.resilience.retry.RetryableBrowse$RetryableEmitter.produceRecords(RetryableBrowse.java:145)<CR> at com.pega.dsm.dnode.impl.dataflow.resilience.retry.RetryableBrowse$RetryableEmitter.emit(RetryableBrowse.java:111)<CR> at com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:353)<CR> at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:55)<CR> at com.pega.dsm.dnode.impl.stream.DataObservableImpl$3.emit(DataObservableImpl.java:176)<CR> at com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:353)<CR> at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:55)<CR> at com.pega.dsm.dnode.api.dataflow.DataFlow$3.run(DataFlow.java:432)<CR> at com.pega.dsm.dnode.api.dataflow.DataFlow$3.run(DataFlow.java:425)<CR> at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67)<CR> at com.pega.dsm.dnode.impl.dataflow.DataFlowThreadContext.lambda$submitInput$3(DataFlowThreadContext.java:228)<CR> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)<CR> at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108)<CR> at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)<CR> at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:77)<CR> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)<CR> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)<CR> at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:59)<CR> at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:56)<CR> at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67)<CR> at com.pega.dsm.dnode.impl.prpc.PrpcThreadFactory$PrpcThread.run(PrpcThreadFactory.java:124)<CR>Caused by: com.pega.fnx.stream.spi.StreamServiceException: Stream SPI error<CR> at com.pega.fnx.stream.spi.impl.processor.StreamServiceExceptions.translateKafkaException(StreamServiceExceptions.java:62)<CR> at com.pega.fnx.stream.spi.impl.processor.StreamServiceExceptions.translate(StreamServiceExceptions.java:40)<CR> at com.pega.fnx.stream.spi.impl.processor.StreamServiceExceptions.translate(StreamServiceExceptions.java:31)<CR> at com.pega.fnx.stream.spi.impl.processor.GetStartingOffsetsRequestProcessor.execute(GetStartingOffsetsRequestProcessor.java:69)<CR> at com.pega.fnx.stream.spi.impl.processor.GetStartingOffsetsRequestProcessor.execute(GetStartingOffsetsRequestProcessor.java:34)<CR> at com.pega.fnx.stream.spi.impl.StreamSPNative.execute(StreamSPNative.java:61)<CR> ... 34 more<CR>Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition PYBIINCREMENTALINDEXER-18 could be determined<CR>]*
***Edited by Moderator Marije to add Capability tags***