在分区模式下首次执行选择查询需要10分钟以上 具有两个节点的点火集群

问题描述

我创建了具有两个节点的群集（一个在本地系统上，另一个在另一台计算机上）。创建新表后，我们将首次执行select查询，这将花费太多时间来获取数据。 （将近10分钟以上） 请找到附件我的服务器x​​ml配置，下面是客户端配置类。任何解决此问题的建议，谢谢。

下面的客户端节点：-

public static synchronized void init() {
             try {
                    Ignition.setClientMode(true);

                    DataStorageConfiguration storageCfg = new DataStorageConfiguration();
                    storageCfg.setWalMode(WALMode.BACKGROUND);

                    IgniteConfiguration cfg = new IgniteConfiguration();
                    cfg.setDataStorageConfiguration(storageCfg);
                    // Ignite Cluster changes
                    cfg.setPeerClassLoadingEnabled(true);
                    cfg.setRebalanceThreadPoolSize(4);
                    
                    TcpdiscoverySpi discoverySpi = new TcpdiscoverySpi();
                    TcpdiscoveryVmIpFinder ipFinder = new TcpdiscoveryVmIpFinder();                  
                    ipFinder.setAddresses( Arrays.asList("XXX.XX.XX.XX:47500","XX.XX.XX.XX:47500"));
                    
                    
                    discoverySpi.setLocalPort(47500);
          

                                                         discoverySpi.setIpFinder(ipFinder).setJoinTimeout(30000);

                    TcpCommunicationSpi commSpi = new TcpCommunicationSpi();
             
                                                         commSpi.setConnectTimeout(30000).setLocalPort(48110);

                    // this timeout is used to reconnect client to server if server has
                    // Failed/restarted
                  
             cfg.setClientFailureDetectionTimeout(43200000);

                    cfg.setdiscoverySpi(discoverySpi);
                    cfg.setCommunicationSpi(commSpi);

                    ignite = Ignition.start(cfg);
                    ignite.cluster().active(true);

                   ignite.cluster().baselineAutoAdjustEnabled(true);
                   ignite.cluster().baselineAutoAdjustTimeout(0);
                  
                     } catch (Exception e) {
                    logger.error("Error in starting ignite cluster",e);
             }
       }

服务器的XML配置

<bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
    <property name="peerClassLoadingEnabled" value="true"/> 
    <property name="dataStorageConfiguration">
                        <bean class="org.apache.ignite.configuration.DataStorageConfiguration">
                                <property name="defaultDataRegionConfiguration">
                                        <bean class="org.apache.ignite.configuration.DataRegionConfiguration">
                                                   <property name="persistenceEnabled" value="true" />
                                                <property name="maxSize" value="#{1L * 1024 * 1024 * 1024}"/>
                                                <property name="initialSize" value="#{1L * 1024 * 1024 * 1024}"/>
                                         <property name="metricsEnabled" value="true"/>   
                                        </bean>
                                </property>
                        </bean>
                </property>
               <!-- Explicitly configure TCP discovery SPI to provide list of initial nodes. -->
        <property name="discoverySpi">
            <bean class="org.apache.ignite.spi.discovery.tcp.TcpdiscoverySpi">
                <property name="localPort" value="47500"/>
                <property name="ipFinder">
                <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpdiscoveryVmIpFinder">
                        <property name="addresses">
                            <list>
                                <!-- In distributed environment,replace with actual host IP address. -->
                            <value>XX.XX.XX.XX:47500</value> 
                            <value>XX.XX.XX.XX:47500</value>  
                            </list>
                        </property>
                    </bean>
                </property>
            </bean>
        </property>
        <property name="communicationSpi">
            <bean class="org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi">
                <property name="localPort" value="48110"/>
            </bean>
        </property>
        <property name="clientConnectorConfiguration">
                        <bean class="org.apache.ignite.configuration.ClientConnectorConfiguration">
                          <property name="port" value="10801"/>
                        </bean>
        </property>
     </bean>
</beans>

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）