0002469: routing.largest.gap.size is limited to an integer sized value,

but should be a long.
JumpMind · Dec 17, 2015 · 6637765 · 6637765
1 parent e9c3e45
commit 6637765
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapDetector.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapDetector.java
@@ -93,7 +93,7 @@ public void beforeRouting() {
             final int dataIdIncrementBy = parameterService
                     .getInt(ParameterConstants.DATA_ID_INCREMENT_BY);
             final long maxDataToSelect = parameterService
-                    .getInt(ParameterConstants.ROUTING_LARGEST_GAP_SIZE);
+                    .getLong(ParameterConstants.ROUTING_LARGEST_GAP_SIZE);
             long databaseTime = symmetricDialect.getDatabaseTime();
             int idsFilled = 0;
             int newGapsInserted = 0;

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -1385,7 +1385,7 @@ public DataGap mapRow(Row rs) {
 
     public List<DataGap> findDataGaps() {
         final long maxDataToSelect = parameterService
-                .getInt(ParameterConstants.ROUTING_LARGEST_GAP_SIZE);
+                .getLong(ParameterConstants.ROUTING_LARGEST_GAP_SIZE);
         List<DataGap> gaps = findDataGapsByStatus(DataGap.Status.GP);
         boolean lastGapExists = false;
         long maxDataEventId = 0;