Re: Error and Question about communication between java node and c++ node

2020-04-03 Thread Anthony
It works, thank you so much for your help!

On Fri, Apr 3, 2020 at 8:42 AM Ilya Kasnacheev 
wrote:

> Hello!
>
> Local node's binary configuration is not equal to remote node's binary
> configuration [locNodeId=155424bd-1c8e-48a2-83ff-26aa6cf9e7af,
> rmtNodeId=db4efc6e-44c7-46ce-b7c0-154e387c0448,
> locBinaryCfg={globIdMapper=org.apache.ignite.binary.BinaryBasicIdMapper,
> compactFooter=false, globSerializer=null}, rmtBinaryCfg=null]
>
> As explained in the docs, C++ nodes require compactFooter to be false, so
> it is necessary to include  matching BinaryConfiguration in your Java
> node's IgniteConfiguration. Tune it until the error goes away.
> Please check
> https://apacheignite-cpp.readme.io/docs/cross-platform-interoperability
>
> Regards,
> --
> Ilya Kasnacheev
>
>
> пт, 3 апр. 2020 г. в 17:24, Anthony :
>
>> Attached is the log file from C++Side:
>> [07:20:41,216][WARNING][main][G] Ignite work directory is not provided,
>> automatically resolved to:
>> C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin\work
>> [07:20:41,344][INFO][main][IgniteKernal%myGrid]
>>
>> >>>__  
>> >>>   /  _/ ___/ |/ /  _/_  __/ __/
>> >>>  _/ // (7 7// /  / / / _/
>> >>> /___/\___/_/|_/___/ /_/ /___/
>> >>>
>> >>> ver. 2.8.0#20200226-sha1:341b01df
>> >>> 2020 Copyright(C) Apache Software Foundation
>> >>>
>> >>> Ignite documentation: http://ignite.apache.org
>>
>> [07:20:41,353][INFO][main][IgniteKernal%myGrid] Config URL: n/a
>> [07:20:41,367][INFO][main][IgniteKernal%myGrid] IgniteConfiguration
>> [igniteInstanceName=myGrid, pubPoolSize=8, svcPoolSize=8,
>> callbackPoolSize=8, stripedPoolSize=8, sysPoolSize=8, mgmtPoolSize=4,
>> igfsPoolSize=8, dataStreamerPoolSize=8, utilityCachePoolSize=8,
>> utilityCacheKeepAliveTime=6, p2pPoolSize=2, qryPoolSize=8,
>> sqlQryHistSize=1000, dfltQryTimeout=0,
>> igniteHome=C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin,
>> igniteWorkDir=C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin\work,
>> mbeanSrv=com.sun.jmx.mbeanserver.JmxMBeanServer@5f0fd5a0,
>> nodeId=155424bd-1c8e-48a2-83ff-26aa6cf9e7af, marsh=BinaryMarshaller [],
>> marshLocJobs=false, daemon=false, p2pEnabled=true, netTimeout=5000,
>> netCompressionLevel=1, sndRetryDelay=1000, sndRetryCnt=3,
>> metricsHistSize=1, metricsUpdateFreq=2000,
>> metricsExpTime=9223372036854775807, discoSpi=TcpDiscoverySpi
>> [addrRslvr=null, sockTimeout=0, ackTimeout=0, marsh=null, reconCnt=10,
>> reconDelay=2000, maxAckTimeout=60, soLinger=5, forceSrvMode=false,
>> clientReconnectDisabled=false, internalLsnr=null,
>> skipAddrsRandomization=false], segPlc=STOP, segResolveAttempts=2,
>> waitForSegOnStart=true, allResolversPassReq=true, segChkFreq=1,
>> commSpi=TcpCommunicationSpi [connectGate=null,
>> connPlc=org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$FirstConnectionPolicy@604f2bd2,
>> chConnPlc=null, enableForcibleNodeKill=false,
>> enableTroubleshootingLog=false, locAddr=null, locHost=null, locPort=47100,
>> locPortRange=100, shmemPort=-1, directBuf=true, directSndBuf=false,
>> idleConnTimeout=60, connTimeout=5000, maxConnTimeout=60,
>> reconCnt=10, sockSndBuf=32768, sockRcvBuf=32768, msgQueueLimit=0,
>> slowClientQueueLimit=0, nioSrvr=null, shmemSrv=null,
>> usePairedConnections=false, connectionsPerNode=1, tcpNoDelay=true,
>> filterReachableAddresses=false, ackSndThreshold=32, unackedMsgsBufSize=0,
>> sockWriteTimeout=2000, boundTcpPort=-1, boundTcpShmemPort=-1,
>> selectorsCnt=4, selectorSpins=0, addrRslvr=null,
>> ctxInitLatch=java.util.concurrent.CountDownLatch@1d3ac898[Count = 1],
>> stopping=false, metricsLsnr=null],
>> evtSpi=org.apache.ignite.spi.eventstorage.NoopEventStorageSpi@1b73be9f,
>> colSpi=NoopCollisionSpi [], deploySpi=LocalDeploymentSpi [],
>> indexingSpi=org.apache.ignite.spi.indexing.noop.NoopIndexingSpi@366ac49b,
>> addrRslvr=null,
>> encryptionSpi=org.apache.ignite.spi.encryption.noop.NoopEncryptionSpi@6ad59d92,
>> clientMode=false, rebalanceThreadPoolSize=4, rebalanceTimeout=1,
>> rebalanceBatchesPrefetchCnt=3, rebalanceThrottle=0,
>> rebalanceBatchSize=524288, txCfg=TransactionConfiguration
>> [txSerEnabled=false, dfltIsolation=REPEATABLE_READ,
>> dfltConcurrency=PESSIMISTIC, dfltTxTimeout=0,
>> txTimeoutOnPartitionMapExchange=0, deadlockTimeout=1,
>> pessimisticTxLogSize=0, pessimisticTxLogLinger=1, tmLookupClsName=null,
>> txManagerFactory=null, useJtaSync=false], cacheSanityCheckEnabled=true,
>> discoStartupDelay=6, deployMode=SHARED, p2pMissedCacheSize=100,
>> locHost=null, timeSrvPortBase=31100, timeSrvPortRange=100,
>> failureDetectionTimeout=1, sysWorkerBlockedTimeout=null,
>> clientFailureDetectionTimeout=3, metricsLogFreq=6, hadoopCfg=null,
>> connectorCfg=ConnectorConfiguration [jettyPath=null, host=null, port=11211,
>> noDelay=true, directBuf=false, sndBufSize=32768, rcvBufSize=32768,
>> idleQryCurTimeout=60, 

Re: Error and Question about communication between java node and c++ node

2020-04-03 Thread Ilya Kasnacheev
Hello!

Local node's binary configuration is not equal to remote node's binary
configuration [locNodeId=155424bd-1c8e-48a2-83ff-26aa6cf9e7af,
rmtNodeId=db4efc6e-44c7-46ce-b7c0-154e387c0448,
locBinaryCfg={globIdMapper=org.apache.ignite.binary.BinaryBasicIdMapper,
compactFooter=false, globSerializer=null}, rmtBinaryCfg=null]

As explained in the docs, C++ nodes require compactFooter to be false, so
it is necessary to include  matching BinaryConfiguration in your Java
node's IgniteConfiguration. Tune it until the error goes away.
Please check
https://apacheignite-cpp.readme.io/docs/cross-platform-interoperability

Regards,
-- 
Ilya Kasnacheev


пт, 3 апр. 2020 г. в 17:24, Anthony :

> Attached is the log file from C++Side:
> [07:20:41,216][WARNING][main][G] Ignite work directory is not provided,
> automatically resolved to:
> C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin\work
> [07:20:41,344][INFO][main][IgniteKernal%myGrid]
>
> >>>__  
> >>>   /  _/ ___/ |/ /  _/_  __/ __/
> >>>  _/ // (7 7// /  / / / _/
> >>> /___/\___/_/|_/___/ /_/ /___/
> >>>
> >>> ver. 2.8.0#20200226-sha1:341b01df
> >>> 2020 Copyright(C) Apache Software Foundation
> >>>
> >>> Ignite documentation: http://ignite.apache.org
>
> [07:20:41,353][INFO][main][IgniteKernal%myGrid] Config URL: n/a
> [07:20:41,367][INFO][main][IgniteKernal%myGrid] IgniteConfiguration
> [igniteInstanceName=myGrid, pubPoolSize=8, svcPoolSize=8,
> callbackPoolSize=8, stripedPoolSize=8, sysPoolSize=8, mgmtPoolSize=4,
> igfsPoolSize=8, dataStreamerPoolSize=8, utilityCachePoolSize=8,
> utilityCacheKeepAliveTime=6, p2pPoolSize=2, qryPoolSize=8,
> sqlQryHistSize=1000, dfltQryTimeout=0,
> igniteHome=C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin,
> igniteWorkDir=C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin\work,
> mbeanSrv=com.sun.jmx.mbeanserver.JmxMBeanServer@5f0fd5a0,
> nodeId=155424bd-1c8e-48a2-83ff-26aa6cf9e7af, marsh=BinaryMarshaller [],
> marshLocJobs=false, daemon=false, p2pEnabled=true, netTimeout=5000,
> netCompressionLevel=1, sndRetryDelay=1000, sndRetryCnt=3,
> metricsHistSize=1, metricsUpdateFreq=2000,
> metricsExpTime=9223372036854775807, discoSpi=TcpDiscoverySpi
> [addrRslvr=null, sockTimeout=0, ackTimeout=0, marsh=null, reconCnt=10,
> reconDelay=2000, maxAckTimeout=60, soLinger=5, forceSrvMode=false,
> clientReconnectDisabled=false, internalLsnr=null,
> skipAddrsRandomization=false], segPlc=STOP, segResolveAttempts=2,
> waitForSegOnStart=true, allResolversPassReq=true, segChkFreq=1,
> commSpi=TcpCommunicationSpi [connectGate=null,
> connPlc=org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$FirstConnectionPolicy@604f2bd2,
> chConnPlc=null, enableForcibleNodeKill=false,
> enableTroubleshootingLog=false, locAddr=null, locHost=null, locPort=47100,
> locPortRange=100, shmemPort=-1, directBuf=true, directSndBuf=false,
> idleConnTimeout=60, connTimeout=5000, maxConnTimeout=60,
> reconCnt=10, sockSndBuf=32768, sockRcvBuf=32768, msgQueueLimit=0,
> slowClientQueueLimit=0, nioSrvr=null, shmemSrv=null,
> usePairedConnections=false, connectionsPerNode=1, tcpNoDelay=true,
> filterReachableAddresses=false, ackSndThreshold=32, unackedMsgsBufSize=0,
> sockWriteTimeout=2000, boundTcpPort=-1, boundTcpShmemPort=-1,
> selectorsCnt=4, selectorSpins=0, addrRslvr=null,
> ctxInitLatch=java.util.concurrent.CountDownLatch@1d3ac898[Count = 1],
> stopping=false, metricsLsnr=null],
> evtSpi=org.apache.ignite.spi.eventstorage.NoopEventStorageSpi@1b73be9f,
> colSpi=NoopCollisionSpi [], deploySpi=LocalDeploymentSpi [],
> indexingSpi=org.apache.ignite.spi.indexing.noop.NoopIndexingSpi@366ac49b,
> addrRslvr=null,
> encryptionSpi=org.apache.ignite.spi.encryption.noop.NoopEncryptionSpi@6ad59d92,
> clientMode=false, rebalanceThreadPoolSize=4, rebalanceTimeout=1,
> rebalanceBatchesPrefetchCnt=3, rebalanceThrottle=0,
> rebalanceBatchSize=524288, txCfg=TransactionConfiguration
> [txSerEnabled=false, dfltIsolation=REPEATABLE_READ,
> dfltConcurrency=PESSIMISTIC, dfltTxTimeout=0,
> txTimeoutOnPartitionMapExchange=0, deadlockTimeout=1,
> pessimisticTxLogSize=0, pessimisticTxLogLinger=1, tmLookupClsName=null,
> txManagerFactory=null, useJtaSync=false], cacheSanityCheckEnabled=true,
> discoStartupDelay=6, deployMode=SHARED, p2pMissedCacheSize=100,
> locHost=null, timeSrvPortBase=31100, timeSrvPortRange=100,
> failureDetectionTimeout=1, sysWorkerBlockedTimeout=null,
> clientFailureDetectionTimeout=3, metricsLogFreq=6, hadoopCfg=null,
> connectorCfg=ConnectorConfiguration [jettyPath=null, host=null, port=11211,
> noDelay=true, directBuf=false, sndBufSize=32768, rcvBufSize=32768,
> idleQryCurTimeout=60, idleQryCurCheckFreq=6, sndQueueLimit=0,
> selectorCnt=4, idleTimeout=7000, sslEnabled=false, sslClientAuth=false,
> sslCtxFactory=null, sslFactory=null, portRange=100, threadPoolSize=8,
> 

Re: Error and Question about communication between java node and c++ node

2020-04-03 Thread Anthony
Attached is the log file from C++Side:
[07:20:41,216][WARNING][main][G] Ignite work directory is not provided,
automatically resolved to:
C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin\work
[07:20:41,344][INFO][main][IgniteKernal%myGrid]

>>>__  
>>>   /  _/ ___/ |/ /  _/_  __/ __/
>>>  _/ // (7 7// /  / / / _/
>>> /___/\___/_/|_/___/ /_/ /___/
>>>
>>> ver. 2.8.0#20200226-sha1:341b01df
>>> 2020 Copyright(C) Apache Software Foundation
>>>
>>> Ignite documentation: http://ignite.apache.org

[07:20:41,353][INFO][main][IgniteKernal%myGrid] Config URL: n/a
[07:20:41,367][INFO][main][IgniteKernal%myGrid] IgniteConfiguration
[igniteInstanceName=myGrid, pubPoolSize=8, svcPoolSize=8,
callbackPoolSize=8, stripedPoolSize=8, sysPoolSize=8, mgmtPoolSize=4,
igfsPoolSize=8, dataStreamerPoolSize=8, utilityCachePoolSize=8,
utilityCacheKeepAliveTime=6, p2pPoolSize=2, qryPoolSize=8,
sqlQryHistSize=1000, dfltQryTimeout=0,
igniteHome=C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin,
igniteWorkDir=C:\Users\harte\Desktop\work\apache-ignite-2.8.0-bin-try\apache-ignite-2.8.0-bin\work,
mbeanSrv=com.sun.jmx.mbeanserver.JmxMBeanServer@5f0fd5a0,
nodeId=155424bd-1c8e-48a2-83ff-26aa6cf9e7af, marsh=BinaryMarshaller [],
marshLocJobs=false, daemon=false, p2pEnabled=true, netTimeout=5000,
netCompressionLevel=1, sndRetryDelay=1000, sndRetryCnt=3,
metricsHistSize=1, metricsUpdateFreq=2000,
metricsExpTime=9223372036854775807, discoSpi=TcpDiscoverySpi
[addrRslvr=null, sockTimeout=0, ackTimeout=0, marsh=null, reconCnt=10,
reconDelay=2000, maxAckTimeout=60, soLinger=5, forceSrvMode=false,
clientReconnectDisabled=false, internalLsnr=null,
skipAddrsRandomization=false], segPlc=STOP, segResolveAttempts=2,
waitForSegOnStart=true, allResolversPassReq=true, segChkFreq=1,
commSpi=TcpCommunicationSpi [connectGate=null,
connPlc=org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$FirstConnectionPolicy@604f2bd2,
chConnPlc=null, enableForcibleNodeKill=false,
enableTroubleshootingLog=false, locAddr=null, locHost=null, locPort=47100,
locPortRange=100, shmemPort=-1, directBuf=true, directSndBuf=false,
idleConnTimeout=60, connTimeout=5000, maxConnTimeout=60,
reconCnt=10, sockSndBuf=32768, sockRcvBuf=32768, msgQueueLimit=0,
slowClientQueueLimit=0, nioSrvr=null, shmemSrv=null,
usePairedConnections=false, connectionsPerNode=1, tcpNoDelay=true,
filterReachableAddresses=false, ackSndThreshold=32, unackedMsgsBufSize=0,
sockWriteTimeout=2000, boundTcpPort=-1, boundTcpShmemPort=-1,
selectorsCnt=4, selectorSpins=0, addrRslvr=null,
ctxInitLatch=java.util.concurrent.CountDownLatch@1d3ac898[Count = 1],
stopping=false, metricsLsnr=null],
evtSpi=org.apache.ignite.spi.eventstorage.NoopEventStorageSpi@1b73be9f,
colSpi=NoopCollisionSpi [], deploySpi=LocalDeploymentSpi [],
indexingSpi=org.apache.ignite.spi.indexing.noop.NoopIndexingSpi@366ac49b,
addrRslvr=null,
encryptionSpi=org.apache.ignite.spi.encryption.noop.NoopEncryptionSpi@6ad59d92,
clientMode=false, rebalanceThreadPoolSize=4, rebalanceTimeout=1,
rebalanceBatchesPrefetchCnt=3, rebalanceThrottle=0,
rebalanceBatchSize=524288, txCfg=TransactionConfiguration
[txSerEnabled=false, dfltIsolation=REPEATABLE_READ,
dfltConcurrency=PESSIMISTIC, dfltTxTimeout=0,
txTimeoutOnPartitionMapExchange=0, deadlockTimeout=1,
pessimisticTxLogSize=0, pessimisticTxLogLinger=1, tmLookupClsName=null,
txManagerFactory=null, useJtaSync=false], cacheSanityCheckEnabled=true,
discoStartupDelay=6, deployMode=SHARED, p2pMissedCacheSize=100,
locHost=null, timeSrvPortBase=31100, timeSrvPortRange=100,
failureDetectionTimeout=1, sysWorkerBlockedTimeout=null,
clientFailureDetectionTimeout=3, metricsLogFreq=6, hadoopCfg=null,
connectorCfg=ConnectorConfiguration [jettyPath=null, host=null, port=11211,
noDelay=true, directBuf=false, sndBufSize=32768, rcvBufSize=32768,
idleQryCurTimeout=60, idleQryCurCheckFreq=6, sndQueueLimit=0,
selectorCnt=4, idleTimeout=7000, sslEnabled=false, sslClientAuth=false,
sslCtxFactory=null, sslFactory=null, portRange=100, threadPoolSize=8,
msgInterceptor=null], odbcCfg=null, warmupClos=null,
atomicCfg=AtomicConfiguration [seqReserveSize=1000, cacheMode=PARTITIONED,
backups=1, aff=null, grpName=null], classLdr=null, sslCtxFactory=null,
platformCfg=PlatformConfiguration [], binaryCfg=BinaryConfiguration
[idMapper=BinaryBaseIdMapper [isLowerCase=true],
nameMapper=BinaryBaseNameMapper [isSimpleName=true], serializer=null,
compactFooter=false], memCfg=null, pstCfg=null,
dsCfg=DataStorageConfiguration [sysRegionInitSize=41943040,
sysRegionMaxSize=104857600, pageSize=0, concLvl=0,
dfltDataRegConf=DataRegionConfiguration [name=default, maxSize=3390213324,
initSize=268435456, swapPath=null, pageEvictionMode=DISABLED,
evictionThreshold=0.9, emptyPagesPoolSize=100, metricsEnabled=false,
metricsSubIntervalCount=5, metricsRateTimeInterval=6,
persistenceEnabled=false, 

Re: Error and Question about communication between java node and c++ node

2020-04-02 Thread Evgenii Zhuravlev
Hi,

Can you share full log files?

Evgenii

чт, 2 апр. 2020 г. в 17:40, Anthony :

> Hello,
>
> I am trying to make java node and c++ node communicate with each other. I
> have successfully done it between two c++ node (which is straight forward).
>
> However, when I tried to do a put in java and a get in c++, I got some
> errors. Could anyone have a look? Thanks.
>
> Also, examples of the communication would be helpful!
>
> I first created a node and cache in Java:
> Ignite ignite = Ignition.start();
> IgniteCache caches = ignite.getOrCreateCache("myCache");
>
> And in C++:
>   IgniteConfiguration cfg;
>   Ignite grid = Ignition::Start(cfg);
>// Get cache instance.
>Cache caches = grid.GetCache std::string>("myCache");
>
> Then I got the following error messages on java side:
>
> [2020-04-02 16:10:27,131][ERROR][main][IgniteKernal] Failed to start
> manager: GridManagerAdapter [enabled=true,
> name=o.a.i.i.managers.discovery.GridDiscoveryManager]
> class org.apache.ignite.IgniteCheckedException: Failed to start SPI:
> TcpDiscoverySpi [addrRslvr=null, sockTimeout=5000, ackTimeout=5000,
> marsh=JdkMarshaller
> [clsFilter=org.apache.ignite.marshaller.MarshallerUtils$1@fd9ebde],
> reconCnt=10, reconDelay=2000, maxAckTimeout=60, soLinger=5,
> forceSrvMode=false, clientReconnectDisabled=false, internalLsnr=null,
> skipAddrsRandomization=false]
> at
> org.apache.ignite.internal.managers.GridManagerAdapter.startSpi(GridManagerAdapter.java:300)
> at
> org.apache.ignite.internal.managers.discovery.GridDiscoveryManager.start(GridDiscoveryManager.java:943)
>
>


Error and Question about communication between java node and c++ node

2020-04-02 Thread Anthony
Hello,

I am trying to make java node and c++ node communicate with each other. I
have successfully done it between two c++ node (which is straight forward).

However, when I tried to do a put in java and a get in c++, I got some
errors. Could anyone have a look? Thanks.

Also, examples of the communication would be helpful!

I first created a node and cache in Java:
Ignite ignite = Ignition.start();
IgniteCache caches = ignite.getOrCreateCache("myCache");

And in C++:
  IgniteConfiguration cfg;
  Ignite grid = Ignition::Start(cfg);
   // Get cache instance.
   Cache caches = grid.GetCache("myCache");

Then I got the following error messages on java side:

[2020-04-02 16:10:27,131][ERROR][main][IgniteKernal] Failed to start
manager: GridManagerAdapter [enabled=true,
name=o.a.i.i.managers.discovery.GridDiscoveryManager]
class org.apache.ignite.IgniteCheckedException: Failed to start SPI:
TcpDiscoverySpi [addrRslvr=null, sockTimeout=5000, ackTimeout=5000,
marsh=JdkMarshaller
[clsFilter=org.apache.ignite.marshaller.MarshallerUtils$1@fd9ebde],
reconCnt=10, reconDelay=2000, maxAckTimeout=60, soLinger=5,
forceSrvMode=false, clientReconnectDisabled=false, internalLsnr=null,
skipAddrsRandomization=false]
at
org.apache.ignite.internal.managers.GridManagerAdapter.startSpi(GridManagerAdapter.java:300)
at
org.apache.ignite.internal.managers.discovery.GridDiscoveryManager.start(GridDiscoveryManager.java:943)