Hi All, When executing Data Flow getting the following exception in one of the work pool classes. The similar Data Flow works in another work pool class in the same application.

The application has two work pools. Only one work pool class is having the following issue.

com.pega.dsm.dnode.api.DNodeException: Could not perform database dataset operation on ZZZ-XXXX-YYY-Work

java.lang.IllegalStateException: com.pega.dsm.dnode.api.DNodeException: Could not perform database dataset operation on ZZZ-XXXX-YYY-Work
	at com.pega.dsm.dnode.impl.stream.DataObservableImpl$ObservableIterator.hasNext(DataObservableImpl.java:198)
	at com.pega.dsm.dnode.impl.stream.DataObservableImpl$ObservableIterator.next(DataObservableImpl.java:229)
	at com.pega.dsm.dnode.impl.stream.DataObservableImpl.first(DataObservableImpl.java:154)
	at com.pega.dsm.dnode.api.dataflow.DataFlow.getNumberOfExpectedRecords(DataFlow.java:795)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.PartitionCreator.createFor(PartitionCreator.java:78)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.PartitionCreator.access$000(PartitionCreator.java:45)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.PartitionCreator$1.run(PartitionCreator.java:62)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.PartitionCreator$1.run(PartitionCreator.java:59)
	at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67)
	at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper$2.run(ServiceHelper.java:291)
	at com.pega.pegarules.session.internal.PRSessionProviderImpl.performTargetActionWithLock(PRSessionProviderImpl.java:1380)
	at com.pega.pegarules.session.internal.PRSessionProviderImpl.doWithRequestorLocked(PRSessionProviderImpl.java:1123)
	at com.pega.pegarules.session.internal.PRSessionProviderImpl.doWithRequestorLocked(PRSessionProviderImpl.java:930)
	at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper.executeInPrpcContextInternal(ServiceHelper.java:284)
	at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper.executeInPrpcContext(ServiceHelper.java:146)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.PartitionCreator.createFor(PartitionCreator.java:59)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.RunInitializationTask.preparePartitions(RunInitializationTask.java:204)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.RunInitializationTask.asyncExecution(RunInitializationTask.java:130)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.AsyncAssignedTask$1.run(AsyncAssignedTask.java:69)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.AsyncAssignedTask$1.run(AsyncAssignedTask.java:58)
	at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67)
	at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper.executeInPrpcContextInternal(ServiceHelper.java:301)
	at com.pega.dsm.dnode.impl.prpc.service.ServiceHelper.executeInPrpcContext(ServiceHelper.java:146)
	at com.pega.dsm.dnode.impl.dataflow.service.servicepulse.AsyncAssignedTask.lambda$tryToExecuteInLock$0(AsyncAssignedTask.java:58)
	at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:108)
	at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:41)
	at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:77)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:59)
	at com.pega.dsm.dnode.util.PrpcRunnable$1.run(PrpcRunnable.java:56)
	at com.pega.dsm.dnode.util.PrpcRunnable.execute(PrpcRunnable.java:67)
	at com.pega.dsm.dnode.impl.prpc.PrpcThreadFactory$PrpcThread.run(PrpcThreadFactory.java:124)
Caused by: com.pega.dsm.dnode.api.DNodeException: Could not perform database dataset operation on ZZZ-XXXX-YYY-Work
	at com.pega.dsm.dnode.impl.dataset.database.DatabaseOperationsUtil.lambda$observableForDatabaseOperation$0(DatabaseOperationsUtil.java:78)
	at com.pega.dsm.dnode.impl.stream.DataObservableImpl$SafeDataSubscriber.subscribe(DataObservableImpl.java:353)
	at com.pega.dsm.dnode.impl.stream.DataObservableImpl.subscribe(DataObservableImpl.java:55)
	at com.pega.dsm.dnode.impl.stream.DataObservableImpl$ObservableIterator.(DataObservableImpl.java:191)
	at com.pega.dsm.dnode.impl.stream.DataObservableImpl.iterator(DataObservableImpl.java:149)
	... 31 more
Caused by: java.lang.NullPointerException
	at java.base/java.util.TreeMap.getEntry(TreeMap.java:345)
	at java.base/java.util.TreeMap.get(TreeMap.java:277)
	at com.pega.pegarules.data.internal.store.TableInformationImpl.getColumn(TableInformationImpl.java:309)
	at com.pega.pegarules.data.internal.sqlapi.resolve.NativeSQLAPIResolver.setColumnTypeForField(NativeSQLAPIResolver.java:395)
	at com.pega.pegarules.data.internal.sqlapi.resolve.NativeSQLAPIResolver.resolveFilters(NativeSQLAPIResolver.java:757)
	at com.pega.pegarules.data.internal.sqlapi.resolve.NativeSQLAPIResolver.resolve(NativeSQLAPIResolver.java:139)
	at com.pega.dsm.dnode.util.NativeSQLBatchReader.(NativeSQLBatchReader.java:94)
	at com.pega.dsm.dnode.util.NativeSQLBatchReader.(NativeSQLBatchReader.java:98)
	at com.pega.dsm.dnode.impl.dataset.database.DatabaseGetNumberOfRecordsOperation$1.executeExposedLogic(DatabaseGetNumberOfRecordsOperation.java:76)
	at com.pega.dsm.dnode.impl.dataset.database.DatabaseOperationsUtil.lambda$observableForDatabaseOperation$0(DatabaseOperationsUtil.java:73)
	... 35 more