Skip to content

Commit db562e2

Browse files
authored
Update SalesforceSplitUtil.java
1 parent 675b0ce commit db562e2

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

src/main/java/io/cdap/plugin/salesforce/plugin/source/batch/util/SalesforceSplitUtil.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -280,7 +280,7 @@ public static boolean isPkChunkingSupported(String sobjectName) {
280280
public static boolean shouldAutoDetectPKChunk(String query, AuthenticatorCredentials credentials, long threshold) {
281281
try {
282282
String sObjectName = SObjectDescriptor.fromQuery(query).getName();
283-
if (!isPkChunkingSupported(sObjectName)) {
283+
if (!isPkChunkingSupported(sObjectName.toLowerCase())) {
284284
LOG.debug("PK Chunking auto-decision: object '{}' is not supported for PK chunking", sObjectName);
285285
return false;
286286
}
@@ -300,7 +300,7 @@ public static boolean shouldAutoDetectPKChunk(String query, AuthenticatorCredent
300300
return true;
301301
} catch (Exception e) {
302302
LOG.warn("PK Chunking auto-decision: unexpected error, falling back to default PK chunking", e);
303-
return false;
303+
return true;
304304
}
305305
}
306306

0 commit comments

Comments
 (0)