Yes, after starting server node and cluster active and then only pulling
cache.size.

Krishna, attached server log also, please refer if required.

Regards,
Ganguly

On Wed, May 17, 2023 at 1:45 AM Gianluca Bonetti <gianluca.bone...@gmail.com>
wrote:

> Hello
>
> You start a client node, do you start a server node too?
>
> Cheers
> Gianluca
>
> On Mon, 15 May 2023 at 13:26, Krishna.Mulumudi.ril.com via user <
> user@ignite.apache.org> wrote:
>
>> It’s persisting data after reboot and able to retrieve inserted records
>> from cache. Only problem is, cache.size getting reset to zero after first
>> restart of the cluster.
>>
>>
>>
>> Please find output of requested commands and code snippet for getting
>> cache.size .
>>
>> ############################################
>>
>>
>>
>> [tibusr@******~]$ df
>>
>> Filesystem                1K-blocks     Used Available Use% Mounted on
>>
>> devtmpfs                    7812268        0   7812268   0% /dev
>>
>> tmpfs                       7823392        4   7823388   1% /dev/shm
>>
>> tmpfs                       7823392   795764   7027628  11% /run
>>
>> tmpfs                       7823392        0   7823392   0% /sys/fs/cgroup
>>
>> /dev/mapper/vg_os-lv_root 103080888 47604952  50216672  49% /
>>
>> /dev/sda2                    999320   106456    824052  12% /boot
>>
>> /dev/mapper/vg_os-lv_app  103080888 22497672  75323952  23% /app
>>
>> tmpfs                       1564680        0   1564680   0% /run/user/1002
>>
>> tmpfs                       1564680        0   1564680   0% /run/user/7071
>>
>> [tibusr@****** ~]$ lsattr /app
>>
>> -------------e-- /app/snapshots1
>>
>> -------------e-- /app/datastore1
>>
>> -------------e-- /app/logs
>>
>> [tibusr@******~]$ lsattr /app/datastore1
>>
>> -------------e-- /app/datastore1/archive
>>
>> -------------e-- /app/datastore1/data
>>
>> -------------e-- /app/datastore1/wal
>>
>> -------------e-- /app/datastore1/metadataWorkDir
>>
>> [tibusr@******~]$
>>
>>
>>
>> ###################################### JAVA CODE Snippet to get cache
>> size ########################################
>>
>>
>>
>> /**
>>
>> *
>>
>>  */
>>
>> package com.jio.digitalapi.edif.util.operations;
>>
>>
>>
>> import java.util.Arrays;
>>
>> import java.util.Properties;
>>
>> import java.util.UUID;
>>
>>
>>
>> import org.apache.ignite.Ignite;
>>
>> import org.apache.ignite.IgniteCache;
>>
>> import org.apache.ignite.Ignition;
>>
>> import org.apache.ignite.cache.CachePeekMode;
>>
>> import org.apache.ignite.configuration.BinaryConfiguration;
>>
>> import org.apache.ignite.configuration.IgniteConfiguration;
>>
>> import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
>>
>> import
>> org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
>>
>>
>>
>>
>>
>> import com.jio.digitalapi.jtl.edif.model.JtlCustomer;
>>
>>
>>
>> import javax.swing.*;
>>
>>
>>
>> /**
>>
>> * @author Gangaiah Gundeboina
>>
>> *
>>
>> */
>>
>> public class CacheSizes {
>>
>>
>>
>>               public static <K, V> void main(String[] args) {
>>
>>
>>
>>                              String igniteNodeIpAddress = "IPADDRESS";
>>
>>
>>
>>                              String igniteInstanceName = null;
>>
>>                              try {
>>
>>                                            String[] ipAddrArray =
>> igniteNodeIpAddress.split(",", -1);
>>
>>
>> System.setProperty("java.net.preferIPv4Stack", "true");
>>
>>                                            IgniteConfiguration cfg = new
>> IgniteConfiguration();
>>
>>
>> cfg.setPeerClassLoadingEnabled(true);
>>
>>                                            cfg.setClientMode(true);
>>
>>                                            String random =
>> (UUID.randomUUID().getMostSignificantBits() + "").toString().replace("-",
>> "");
>>
>>                                            String igniteFullInstaneName =
>> igniteInstanceName + random;
>>
>>
>> cfg.setIgniteInstanceName(igniteFullInstaneName);
>>
>>                                            cfg.setDiscoverySpi((new
>> TcpDiscoverySpi().setJoinTimeout(2400000)
>>
>>
>> .setIpFinder((new
>> TcpDiscoveryVmIpFinder()).setAddresses(Arrays.asList(ipAddrArray)))));
>>
>>                                            Ignite ignite =
>> Ignition.start(cfg);
>>
>>                                            IgniteCache<String,
>> JtlCustomer> cache =
>> ignite.cache("JtlCustomerCache");
>>
>>
>> System.out.println("PRIMARY:"+Integer.valueOf(cache.size(new
>> CachePeekMode[]{CachePeekMode.PRIMARY})).toString());
>>
>>
>>                              } catch (Exception e) {
>>
>>                                            e.printStackTrace();
>>
>>                                            System.exit(0);
>>
>>                              }
>>
>>                              System.exit(0);
>>
>>
>>
>>               }
>>
>>
>>
>> }
>>
>> ##############################################################
>>
>>
>>
>>
>> "*Confidentiality Warning*: This message and any attachments are
>> intended only for the use of the intended recipient(s), are confidential
>> and may be privileged. If you are not the intended recipient, you are
>> hereby notified that any review, re-transmission, conversion to hard copy,
>> copying, circulation or other use of this message and any attachments is
>> strictly prohibited. If you are not the intended recipient, please notify
>> the sender immediately by return email and delete this message and any
>> attachments from your system.
>>
>> *Virus Warning:* Although the company has taken reasonable precautions
>> to ensure no viruses are present in this email. The company cannot accept
>> responsibility for any loss or damage arising from the use of this email or
>> attachment."
>>
>

Reply via email to