diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromTableSource.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromTableSource.java
index 3f1d0402b7..e559df3c94 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromTableSource.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromTableSource.java
@@ -167,7 +167,8 @@ protected CsvData selectNext() {
                 if (overrideSelectSql != null && overrideSelectSql.trim().toUpperCase().startsWith("WHERE")) {
                     overrideSelectSql = overrideSelectSql.trim().substring(5);
                 }
-                if (parameterService.is(ParameterConstants.INITIAL_LOAD_RECURSION_SELF_FK) && overrideSelectSql.equals(Constants.ALWAYS_TRUE_CONDITION)) {
+                if (parameterService.is(ParameterConstants.INITIAL_LOAD_RECURSION_SELF_FK) && (StringUtils.isBlank(overrideSelectSql) ||
+                        Constants.ALWAYS_TRUE_CONDITION.equals(overrideSelectSql))) {
                     ForeignKey fk = sourceTable.getSelfReferencingForeignKey();
                     if (fk != null) {
                         Reference[] refs = fk.getReferences();