Repository: ignite Updated Branches: refs/heads/ignite-5075-cc 3122352ca -> 83083534e
cc Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/83083534 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/83083534 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/83083534 Branch: refs/heads/ignite-5075-cc Commit: 83083534ec9fcc3d09f4c74abe4fb9fa971f9d8e Parents: 3122352 Author: sboikov <[email protected]> Authored: Wed May 24 15:04:14 2017 +0300 Committer: sboikov <[email protected]> Committed: Wed May 24 15:04:14 2017 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryEventBuffer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/83083534/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java index 7ddea92..711d20b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEventBuffer.java @@ -23,6 +23,7 @@ import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentSkipListMap; import java.util.concurrent.atomic.AtomicReference; +import org.apache.ignite.IgniteSystemProperties; import org.jetbrains.annotations.Nullable; /** @@ -30,7 +31,8 @@ import org.jetbrains.annotations.Nullable; */ public class CacheContinuousQueryEventBuffer { /** */ - private static final int BUF_SIZE = 5; + private static final int BUF_SIZE = + IgniteSystemProperties.getInteger("IGNITE_CONTINUOUS_QUERY_SERVER_BUFFER_SIZE", 5); /** */ private AtomicReference<Batch> curBatch = new AtomicReference<>();
