diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java index 6479fda2b3..b1ec38deaf 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheAbstractJdbcStore.java @@ -680,7 +680,6 @@ public abstract class CacheAbstractJdbcStore implements CacheStore, @Override public void loadCache(final IgniteBiInClosure clo, @Nullable Object... args) throws CacheLoaderException { ExecutorService pool = null; - int fetchSize = dialect.getFetchSize(); String cacheName = session().cacheName(); @@ -775,7 +774,7 @@ public abstract class CacheAbstractJdbcStore implements CacheStore, for (int i = 0; i < keyCnt; i++) upperBound[i] = rs.getObject(i + 1); - futs.add(pool.submit(loadCacheRange(em, clo, null, upperBound, fetchSize))); + futs.add(pool.submit(loadCacheRange(em, clo, null, upperBound, 0))); while (rs.next()) { Object[] lowerBound = upperBound; @@ -785,10 +784,10 @@ public abstract class CacheAbstractJdbcStore implements CacheStore, for (int i = 0; i < keyCnt; i++) upperBound[i] = rs.getObject(i + 1); - futs.add(pool.submit(loadCacheRange(em, clo, lowerBound, upperBound, fetchSize))); + futs.add(pool.submit(loadCacheRange(em, clo, lowerBound, upperBound, 0))); } - futs.add(pool.submit(loadCacheRange(em, clo, upperBound, null, fetchSize))); + futs.add(pool.submit(loadCacheRange(em, clo, upperBound, null, 0))); continue; }