You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by Nikolai Tikhonov <nt...@apache.org> on 2016/12/02 11:35:30 UTC
Re: Cluster can not let more than one client to do continuous queries
Hi,
You start grid with disabled peer class loading <property
name="peerClassLoadingEnabled" value="false" />. In this case you need to
deploy CacheEntryEventFilterFactory class on all nodes in topology. Please,
make sure that all nodes contain this jar with the factory in classpath or
set peerClassLoadingEnabled to true.
On Mon, Nov 28, 2016 at 10:47 AM, ght230 <gh...@163.com> wrote:
> I had modified the ignite config as following, but it did not work.
>
> <beans xmlns="http://www.springframework.org/schema/beans"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd">
> <bean id="ignite.cfg"
> class="org.apache.ignite.configuration.IgniteConfiguration">
> <property name="peerClassLoadingEnabled" value="false" />
> <property name="networkTimeout" value="300000" />
> <property name="cacheConfiguration">
> <list>
> <bean class="org.apache.ignite.
> configuration.CacheConfiguration">
> <property name="name"
> value="querycache" />
> </bean>
> </list>
> </property>
> <property name="localIpStartsWith" value="192.168.37" />
> <property name="failureDetectionTimeout" value="20000" />
>
> <property name="communicationSpi">
> <bean
> class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi">
> <property name="localPort" value="47100" />
> <property name="localPortRange" value="20"
> />
> <property name="directBuffer"
> value="false" />
> <property name="socketWriteTimeout"
> value="5000" />
> <property name="ackSendThreshold"
> value="32" />
> <property name="socketReceiveBuffer"
> value="#{64 * 1024}" />
> <property name="socketSendBuffer"
> value="#{64 * 1024}" />
> <property name="sharedMemoryPort"
> value="48100" />
> <property name="selectorsCount"
> value="256" />
> <property name="connectTimeout"
> value="10000" />
> <property name="reconnectCount" value="20"
> />
> <property name="messageQueueLimit"
> value="2048" />
> <property name="slowClientQueueLimit"
> value="0" />
> </bean>
> </property>
> <property name="eventStorageSpi">
> <bean
> class="org.apache.ignite.spi.eventstorage.memory.MemoryEventStorageSpi">
> <property name="expireCount" value="10000"
> />
> </bean>
> </property>
> <property name="discoverySpi">
> <bean class="org.apache.ignite.spi.
> discovery.tcp.TcpDiscoverySpi">
> <property name="localPort" value="47500"/>
> <property name="localPortRange"
> value="20"/>
> <property name="ackTimeout" value="10000"
> />
>
> <property name="networkTimeout"
> value="30000" />
> <property name="reconnectCount" value="20"
> />
> <property name="threadPriority" value="3"
> />
> <property name="socketTimeout"
> value="30000" />
> <property name="maxMissedHeartbeats"
> value="5" />
> <property name="maxMissedClientHeartbeats"
> value="10" />
> <property name="ipFinder">
>
>
> <bean
> class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.
> TcpDiscoveryVmIpFinder">
>
> <property name="addresses">
> <list>
> <value>
> 192.168.37.103:47500..47520</value>
> </list>
> </property>
> </bean>
> </property>
> </bean>
> </property>
> </bean>
> </beans>
>
>
> Following is the log of the second client:
> [14:34:28,565][WARN ][pub-#26%null%][GridDiagnostic] Initial heap size is
> 126MB (should be no less than 512MB, use -Xms512m -Xmx512m).
> [14:34:30,308][INFO ][main][IgniteKernal] Non-loopback local IPs:
> 192.168.37.103, 2001:0:b499:3d88:3016:3975:3f57:da98,
> fe80:0:0:0:3016:3975:3f57:da98%13, fe80:0:0:0:602e:de10:7049:3e4%14,
> fe80:0:0:0:615f:2201:b3fc:7555%19, fe80:0:0:0:e805:e97b:b4ab:3310%17
> [14:34:30,308][INFO ][main][IgniteKernal] Enabled local MACs:
> 00000000000000E0, 00FF3E61AAFB, 54EE758A7FE6, C8FF2861A4FB
> [14:34:30,308][INFO ][main][IgniteKernal] Set
> localHost@IgniteConfiguration='192.168.37.103' because of
> localIpStartsWith='192.168.37' match.
> [14:34:30,308][INFO ][main][IgniteKernal] Set
> localAddress@TcpCommunicationSpi='192.168.37.103' because of
> localIpStartsWith='192.168.37' match.
> [14:34:30,308][INFO ][main][IgniteKernal] Set
> localAddress@TcpDiscoverySpi='192.168.37.103' because of
> localIpStartsWith='192.168.37' match.
> [14:34:30,351][INFO ][main][IgnitePluginProcessor] Configured plugins:
> [14:34:30,351][INFO ][main][IgnitePluginProcessor] ^-- None
> [14:34:30,351][INFO ][main][IgnitePluginProcessor]
> [14:34:30,392][WARN ][main][TcpCommunicationSpi] Failure detection timeout
> will be ignored (one of SPI parameters has been set explicitly)
> [14:34:32,074][INFO ][main][TcpCommunicationSpi] Successfully bound to TCP
> port [port=47102, locHost=/192.168.37.103]
> [14:34:32,120][WARN ][main][NoopCheckpointSpi] Checkpoints are disabled (to
> enable configure any GridCheckpointSpi implementation)
> [14:34:32,176][WARN ][main][GridCollisionManager] Collision resolution is
> disabled (all jobs will be activated upon arrival).
> [14:34:32,182][WARN ][main][NoopSwapSpaceSpi] Swap space is disabled. To
> enable use FileSwapSpaceSpi.
> [14:34:32,184][INFO ][main][IgniteKernal] Security status
> [authentication=off, tls/ssl=off]
> [14:34:32,814][INFO ][main][GridTcpRestProtocol] Command protocol
> successfully started [name=TCP binary, host=/192.168.37.103, port=11213]
> [14:34:32,861][WARN ][main][TcpDiscoverySpi] Failure detection timeout will
> be ignored (one of SPI parameters has been set explicitly)
> [14:35:10,391][INFO
> ][tcp-client-disco-msg-worker-#4%null%][CacheContinuousQueryHandler]
> handleClientDisconnectedException for cacheName[ignite-marshaller-
> sys-cache]
> allowReconnect=true, reconnectTimeout=180000, allowHalt=true
>
> At the same time of 14:35:10, the log of server as following:
> [14:35:10,293][INFO
> ][tcp-disco-msg-worker-#2%null%][CacheContinuousQueryHandler]
> handleClientDisconnectedException for cacheName[ignite-marshaller-
> sys-cache]
> allowReconnect=true, reconnectTimeout=180000, allowHalt=true
> [14:35:10,293][INFO
> ][tcp-disco-msg-worker-#2%null%][CacheContinuousQueryHandler]
> handleClientDisconnectedException for cacheName[ignite-sys-cache]
> allowReconnect=true, reconnectTimeout=180000, allowHalt=true
> [14:35:10,293][INFO
> ][tcp-disco-msg-worker-#2%null%][CacheContinuousQueryHandler]
> handleClientDisconnectedException for cacheName[ignite-sys-cache]
> allowReconnect=true, reconnectTimeout=180000, allowHalt=true
> [14:35:10,300][INFO ][disco-event-worker-#302%null%][GridDiscoveryManager]
> Added new node to topology: TcpDiscoveryNode
> [id=758817f7-ea2c-49c3-8665-a58fa25f3f0d, nodeName=null,
> addrs=[192.168.37.103], sockAddrs=[linmm-PC/192.168.37.103:0], discPort=0,
> order=3, intOrder=3, lastExchangeTime=1480314910272, loc=false,
> ver=1.6.8#19700101-sha1:00000000, isClient=true]
> [14:35:10,301][INFO ][disco-event-worker-#302%null%][GridDiscoveryManager]
> Topology snapshot [ver=3, servers=1, clients=2, CPUs=4, heap=5.3GB]
> [14:35:10,341][INFO
> ][exchange-worker-#307%null%][GridCachePartitionExchangeManager] Skipping
> rebalancing (nothing scheduled) [top=AffinityTopologyVersion [topVer=3,
> minorTopVer=0], evt=NODE_JOINED, node=758817f7-ea2c-49c3-8665-
> a58fa25f3f0d]
>
>
>
> --
> View this message in context: http://apache-ignite-users.
> 70518.x6.nabble.com/Cluster-can-not-let-more-than-one-
> client-to-do-continuous-queries-tp9124p9209.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>