Summary

A report definition is present in a data flow as a secondary source to compose a shape. A criteria to match Vehicle ID (VEH_ID) is present in the compose. The compose generates a query with a Where clause as below if a matching  VEH_ID is present in the secondary source:

Performing query: SELECT "PC0"."VEH_ID" AS "VEH_ID" , "PC0"."USED_QTY" AS "USED_QTY" , "PC0"."CHANNEL_TYP_CD" AS "CHANNEL_TYP_CD" , "ONS_SVC"."SVC_CD" AS "SVC_CD" , "PC0"."SVC_ID" AS "SVC_ID" FROM PEGTEST.ONS_VEH_SVC_CHANNEL "PC0" INNER JOIN PEGTEST.ONS_SVC "ONS_SVC" ON ( ( "PC0"."SVC_ID" = "ONS_SVC"."ID" ) ) WHERE ( ( ( "PC0"."VEH_ID" = ? ) ) ) ORDER BY 3 ASC, 4 ASC

Pega generates incorrect query if a matching VEH_ID is not present in the secondary source. The compose pulls all records from the table into the memory crashing the JVM. The query generated in-case of VEH_ID that does not match is as below:
  
Performing query: SELECT "PC0"."VEH_ID" AS "VEH_ID" , "PC0"."USED_QTY" AS "USED_QTY" , "PC0"."CHANNEL_TYP_CD" AS "CHANNEL_TYP_CD" , "ONS_SVC"."SVC_CD" AS "SVC_CD" , "PC0"."SVC_ID" AS "SVC_ID" FROM PEGTEST.ONS_VEH_SVC_CHANNEL "PC0" INNER JOIN PEGTEST.ONS_SVC "ONS_SVC" ON ( ( "PC0"."SVC_ID" = "ONS_SVC"."ID" ) ) ORDER BY 3 ASC, 4 ASC

Where condition is not present in the above queries for the failed scenarios.

Error Messages

Steps to Reproduce

1. Create contacts table with two columns (contactid and contactname)
2. Add four records:
   (1,'C1'),(2,'C2'),(3,'C3'),(4,'C4')
3. Create a Pega class and map it to the table
4. Create 'AllContactsRD' report definition
5. Create 'AllContacts' database dataset
6. Create the below dataflow:
   AllContacts>Compose with AllContactsRD>Abstract
7. Run the dataflow for the contactid that does not match

Root Cause

Resolution