Aaron, let me forward this to DEV:
Ignite DEV community,
I tried to confirm setLocal(true) semantics for ContinuousQuery and I have
got not what I expected. I found that executing a ContinuousQuery with
setLocal(true):
- Still executes initial query remotely
- Listens for modifications locally
I expected that initial query shall also be local.
Is this by design or a bug?
On Fri, Oct 13, 2017 at 3:45 PM, aa...@tophold.com <aa...@tophold.com>
wrote:
> hi All,
>
> Regards ContinuousQuery, I notice there is a #setLocal will this meaning
> CQ only query against local cache? while this query only have
> #setRemoteFilterFactory
> method.
>
> So the question is will my CQ's local listener only receive event updates
> from local cache or entire cluster?
>
> Also the SqlFieldsQuery, we use this to batch update entries in cache, the
> frequent may be once several seconds.
>
> The entry may be updated real time, sometime the data may inconsistent
> seem, will there any lock/transaction control of this?
>
> We use the JDBC as back-end storage; and notice if we run the instance
> for several days, the memory usage keep increase, the performance downgrade
> very badly,
>
> And eventually can not be used, from log we receive the ignite node stop
> event, but the memory not be reclaimed until we kill the JVM finally.
>
> Our cache defined as:
>
> <property name="cacheMode" value="PARTITIONED"/>
> <property name="atomicityMode" value="ATOMIC"/>
> <property name="readFromBackup" value="true"/>
> <property name="backups" value="1"/>
>
> <property name="readThrough" value="true"/>
> <property name="writeThrough" value="true"/>
> <property name="writeBehindEnabled" value="true"/>
> <property name="writeBehindBatchSize" value="1024"/>
> <property name="writeBehindFlushThreadCount" value="1"/>
>
>
> <property name="storeKeepBinary" value="false"/>
> <property name="onheapCacheEnabled" value="true"/>
> <property name="memoryPolicyName" value="Asset_Region"/>
>
> <property name="evictionPolicy">
> <bean class="org.apache.ignite.cache.eviction.lru.LruEvictionPolicy">
> <property name="maxSize" value="#{50000}"/>
> </bean>
> </property>
>
> <property name="nearConfiguration">
> <bean class="org.apache.ignite.configuration.NearCacheConfiguration">
> <property name="nearEvictionPolicy">
> <bean
> class="org.apache.ignite.cache.eviction.lru.LruEvictionPolicy">
> <property name="maxSize" value="3000"/>
> </bean>
> </property>
> <property name="nearStartSize" value="500"/>
> </bean>
> </property>
>
> <property name="cacheStoreFactory" ref="storeagefactory"/>
>
> <bean class="org.apache.ignite.configuration.MemoryPolicyConfiguration">
> <property name="name" value="Asset_Region"/>
> <property name="initialSize" value="#{2L * 1024L * 1024L * 1024L}"/>
> <property name="maxSize" value="#{2L * 1024L * 1024L * 1024L}"/>
> <property name="pageEvictionMode" value="RANDOM_2_LRU"/>
> </bean>
>
>
> Thanks for your time!
>
> Regards
> Aaron
> ------------------------------
> aa...@tophold.com
>
--
Best regards,
Alexey
