Re: Couchbase as persistent store

[Igor Sapego]

You are welcome )

Best Regards,
Igor

On Fri, Oct 21, 2016 at 10:39 AM, kvipin  wrote:

> Igor, thanks a lot for confirming that everything is working fine from
> Apache-Ignite side. That helped me focus into my code only, which was
> really
> a problematic piece.
>
> The biggest problem was that I didn't have exception handling in my code
> hence I was not getting any clue. Once I added exception handling,
> everything was out in open.
>
> First problem was that I had "storeKeepBinary" property enabled through my
> configuration file, which was creating problem while typecasting record
> back
> to TestTable object before constructing json document from it. Second
> problem was that bytes and timestamp java datatypes couldn't directly be
> stored in json object, hence I stored them as string data.
>
> Following is the relevant portion of working code:
>
> ...
> // This mehtod is called whenever "putAll(...)" methods are called
> on IgniteCache.
> @Override public void writeAll(Collection> entries) throws CacheWriterException {
> Bucket conn = connection();
> // Syntax of MERGE statement is database specific and
> should
> be adopted for your database.
> // If your database does not support MERGE statement then
> use sequentially update, insert statements.
> for (Cache.Entry entry
> : entries) {
> try {
> *TestTable val = entry.getValue();* // type
> casting error if "storeKeepBinary" property enabled.
>
> conn.insert(JsonDocument.create(entry.getKey().toString(),
> JsonObject.create().put("tid", val.getTid()).put("idint",
> val.getIdint()).put("idbigint", val.getIdbigint()).put("idchar",
> val.getIdchar()).put("idbinary",
> *val.getIdbinary()*.toString()).put("idvarbinary",
> *val.getIdvarbinary()*.toString()).put("idvarchar",
> val.getIdvarchar()).put("idts", val.getIdts().toString(; // bytes
> couldn't be stored in json object. applied toString on them to make it work
> } catch (Exception e) {
> System.out.println("There was an error
> inserting record: " + e.getMessage());
> }
> }
> }
> ...
>
> Now things work fine for me.
>
> Special thanks to Igor and Val for giving your precious time, things
> would've been much more difficult without your kind support.
>
>
>
> --
> View this message in context: http://apache-ignite-users.
> 70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8396.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>

Re: Couchbase as persistent store

[kvipin]

Igor, thanks a lot for confirming that everything is working fine from
Apache-Ignite side. That helped me focus into my code only, which was really
a problematic piece.

The biggest problem was that I didn't have exception handling in my code
hence I was not getting any clue. Once I added exception handling,
everything was out in open.

First problem was that I had "storeKeepBinary" property enabled through my
configuration file, which was creating problem while typecasting record back
to TestTable object before constructing json document from it. Second
problem was that bytes and timestamp java datatypes couldn't directly be
stored in json object, hence I stored them as string data.

Following is the relevant portion of working code:

...
// This mehtod is called whenever "putAll(...)" methods are called
on IgniteCache.
@Override public void writeAll(Collection> entries) throws CacheWriterException {
Bucket conn = connection();
// Syntax of MERGE statement is database specific and should
be adopted for your database.
// If your database does not support MERGE statement then
use sequentially update, insert statements.
for (Cache.Entry entry
: entries) {
try {
*TestTable val = entry.getValue();* // type
casting error if "storeKeepBinary" property enabled.
   
conn.insert(JsonDocument.create(entry.getKey().toString(),
JsonObject.create().put("tid", val.getTid()).put("idint",
val.getIdint()).put("idbigint", val.getIdbigint()).put("idchar",
val.getIdchar()).put("idbinary",
*val.getIdbinary()*.toString()).put("idvarbinary",
*val.getIdvarbinary()*.toString()).put("idvarchar",
val.getIdvarchar()).put("idts", val.getIdts().toString(; // bytes
couldn't be stored in json object. applied toString on them to make it work
} catch (Exception e) {
System.out.println("There was an error
inserting record: " + e.getMessage());
}
}
}
...

Now things work fine for me.

Special thanks to Igor and Val for giving your precious time, things
would've been much more difficult without your kind support.



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8396.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Couchbase as persistent store

[Igor Sapego]

I've checked the command you provided.

It works, though it really does not add any objects to DB. However,
I've added some prints to TestTableStore#writeAll() and I can see that
all 100 entires are passed to it to be written. It seems that there is
some issue with your implementation of this function or with my
DB configuration -  by some reason it does not write any records to
database. Anyway, Ignite seems to be working just fine in my case.

Best Regards,
Igor

On Thu, Oct 20, 2016 at 10:21 AM, kvipin  wrote:

> Hi Igor,
>
> does write-through works for you? following is the sample command line:
>
> $ ./tester -c config/test-tool-client.xml -o 1 -l 1 -i 1 -n 100  // insert
> (-o 1) 100 records(-n 100) with tid 1 (-i 1) once(-l 1).
>
> above command line will insert records into ignite server node successfully
> which I'm expecting them to persist to couchbase node.
>
> read-through is working for me but write-through is not working.
>
> I will check about "8080 TCP port is already in use" and come back.
>
> thanks,
>
>
>
> --
> View this message in context: http://apache-ignite-users.
> 70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8368.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>

Re: Couchbase as persistent store

[Igor Sapego]

Could it be that your 8080 TCP port is already in use?

Best Regards,
Igor

On Wed, Oct 19, 2016 at 4:33 PM, Igor Sapego  wrote:

> Hi,
>
> I tried your example and it works for me. Could it be that there is an
> issue with you network configuration?
>
> Best Regards,
> Igor
>
> On Tue, Oct 18, 2016 at 9:48 PM, kvipin  wrote:
>
>> Hi Val,
>>
>> Please find the attached sample code tarball.
>> apache-ignite-tester-cs-5.xz
>> > apache-ignite-tester-cs-5.xz>
>>
>>
>> build:
>> $ tar -xvf apache-ignite-tester-cs-5.xz
>> $ cd apache-ignite-tester-cs-5
>> apache-ignite-tester-cs-5]$ ./configure
>> apache-ignite-tester-cs-5]$ make   // build nodemgr (server node) and
>> tester
>> (client node) program;
>> apache-ignite-tester-cs-5]$ cd src
>> src]$ make pstorecb   // package TestTableStore implementation. uses
>> couchbase java client sdk.
>>
>> run:
>> src]$ ./nodemgr -c config/test-tool-server.xml   // server node
>> src]$ ./tester -c config/test-tool-client.xml -o 11 -l 1 -i 100 -n 10   //
>> Select all(-o 11),  10 entries(-n 10) with tid between 90 (value for
>> option
>> i - value for option n) and 100 (-i 100) one iteration(-l 1)
>>
>> src]$ ./tester -h   // for more options
>>
>> thanks & regards,
>>
>>
>>
>> --
>> View this message in context: http://apache-ignite-users.705
>> 18.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8350.html
>> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>>
>
>

Re: Couchbase as persistent store

[Igor Sapego]

Hi,

I tried your example and it works for me. Could it be that there is an
issue with you network configuration?

Best Regards,
Igor

On Tue, Oct 18, 2016 at 9:48 PM, kvipin  wrote:

> Hi Val,
>
> Please find the attached sample code tarball.
> apache-ignite-tester-cs-5.xz
>  n8350/apache-ignite-tester-cs-5.xz>
>
>
> build:
> $ tar -xvf apache-ignite-tester-cs-5.xz
> $ cd apache-ignite-tester-cs-5
> apache-ignite-tester-cs-5]$ ./configure
> apache-ignite-tester-cs-5]$ make   // build nodemgr (server node) and
> tester
> (client node) program;
> apache-ignite-tester-cs-5]$ cd src
> src]$ make pstorecb   // package TestTableStore implementation. uses
> couchbase java client sdk.
>
> run:
> src]$ ./nodemgr -c config/test-tool-server.xml   // server node
> src]$ ./tester -c config/test-tool-client.xml -o 11 -l 1 -i 100 -n 10   //
> Select all(-o 11),  10 entries(-n 10) with tid between 90 (value for option
> i - value for option n) and 100 (-i 100) one iteration(-l 1)
>
> src]$ ./tester -h   // for more options
>
> thanks & regards,
>
>
>
> --
> View this message in context: http://apache-ignite-users.
> 70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8350.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>

Re: Couchbase as persistent store

[kvipin]

Hi Val,

Please find the attached sample code tarball.
apache-ignite-tester-cs-5.xz

  


build:
$ tar -xvf apache-ignite-tester-cs-5.xz
$ cd apache-ignite-tester-cs-5
apache-ignite-tester-cs-5]$ ./configure
apache-ignite-tester-cs-5]$ make   // build nodemgr (server node) and tester
(client node) program;
apache-ignite-tester-cs-5]$ cd src
src]$ make pstorecb   // package TestTableStore implementation. uses
couchbase java client sdk.

run:
src]$ ./nodemgr -c config/test-tool-server.xml   // server node
src]$ ./tester -c config/test-tool-client.xml -o 11 -l 1 -i 100 -n 10   //
Select all(-o 11),  10 entries(-n 10) with tid between 90 (value for option
i - value for option n) and 100 (-i 100) one iteration(-l 1)

src]$ ./tester -h   // for more options

thanks & regards,



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8350.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Couchbase as persistent store

[vkulichenko]

Hi,

Can you provide a small project that will reproduce the issue?

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8280.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Couchbase as persistent store

[kvipin]

any clue guys?


thanks,



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8267.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Couchbase as persistent store

[kvipin]

No Val, in fact it doesn't even seem to open the bucket/connection also.
Following is the *output of server node:*

$ ./nodemgr -c config/test-tool-server.xml
log4j:WARN No appenders could be found for logger
(org.springframework.core.env.StandardEnvironment).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
more info.
[12:34:48]__   
[12:34:48]   /  _/ ___/ |/ /  _/_  __/ __/ 
[12:34:48]  _/ // (7 7// /  / / / _/   
[12:34:48] /___/\___/_/|_/___/ /_/ /___/  
[12:34:48] 
[12:34:48] ver. 1.6.0#20160518-sha1:0b22c45b
[12:34:48] 2016 Copyright(C) Apache Software Foundation
[12:34:48] 
[12:34:48] Ignite documentation: http://ignite.apache.org
[12:34:48] 
[12:34:48] Quiet mode.
[12:34:48]   ^-- Logging to file
'/home/ignite1/project/apacheIgnite/apache-ignite-fabric-1.6.0-bin/work/log/ignite-f5b19499.0.log'
[12:34:48]   ^-- To see **FULL** console log here add -DIGNITE_QUIET=false
or "-v" to ignite.{sh|bat}
[12:34:48] 
[12:34:48] OS: Linux 3.10.0-327.28.2.el7.x86_64 amd64
[12:34:48] VM information: Java(TM) SE Runtime Environment 1.8.0_92-b14
Oracle Corporation Java HotSpot(TM) 64-Bit Server VM 25.92-b14
[12:34:53] Configured plugins:
[12:34:53]   ^-- None
[12:34:53] 
[12:34:53] Security status [authentication=off, tls/ssl=off]
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/home/ignite1/project/apacheIgnite/apache-ignite-fabric-1.6.0-bin/libs/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in
[jar:file:/home/ignite1/project/apacheIgnite/apache-ignite-fabric-1.6.0-bin/libs/ignite-rest-http/slf4j-log4j12-1.7.7.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an
explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.SimpleLoggerFactory]
[main] INFO org.eclipse.jetty.util.log - Logging initialized @6684ms
[main] INFO org.eclipse.jetty.server.Server - jetty-9.2.11.v20150529
[main] INFO org.eclipse.jetty.server.ServerConnector - Started
ServerConnector@2e5624e2{HTTP/1.1}{0.0.0.0:8080}
[main] INFO org.eclipse.jetty.server.Server - Started @6745ms
[12:34:55] Performance suggestions for grid  (fix if possible)
[12:34:55] To disable, set -DIGNITE_PERFORMANCE_SUGGESTIONS_DISABLED=true
[12:34:55]   ^-- Disable peer class loading (set 'peerClassLoadingEnabled'
to false)
[12:34:55]   ^-- Enable ATOMIC mode if not using transactions (set
'atomicityMode' to ATOMIC)
[12:34:55]   ^-- Disable fully synchronous writes (set
'writeSynchronizationMode' to PRIMARY_SYNC or FULL_ASYNC)
[12:34:55]   ^-- Enable write-behind to persistent store (set
'writeBehindEnabled' to true)
[12:34:55] 
[12:34:55] To start Console Management & Monitoring run
ignitevisorcmd.{sh|bat}
[12:34:55] 
[12:34:55] Ignite node started OK (id=f5b19499)
[12:34:55] Topology snapshot [ver=1, servers=1, clients=0, CPUs=32,
heap=0.5GB]
[12:35:05] New version is available at ignite.apache.org: 1.7.0
[12:35:10] Topology snapshot [ver=2, servers=1, clients=1, CPUs=32,
heap=1.0GB]
[12:36:57] Topology snapshot [ver=3, servers=1, clients=0, CPUs=32,
heap=0.5GB]


Data has been successfully sent to ignite server node from client node, but
it hasn't been written to persistent-store. Following is the *output from
client node which queries the server node for data and it gets it
successfully*:

$ ./tester -c config/test-tool-client.xml -o 11 -l 3 -s 1 -i 992 -n 2
log4j:WARN No appenders could be found for logger
(org.springframework.core.env.StandardEnvironment).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
more info.
[12:44:11]__   
[12:44:11]   /  _/ ___/ |/ /  _/_  __/ __/ 
[12:44:11]  _/ // (7 7// /  / / / _/   
[12:44:11] /___/\___/_/|_/___/ /_/ /___/  
[12:44:11] 
[12:44:11] ver. 1.6.0#20160518-sha1:0b22c45b
[12:44:11] 2016 Copyright(C) Apache Software Foundation
[12:44:11] 
[12:44:11] Ignite documentation: http://ignite.apache.org
[12:44:11] 
[12:44:11] Quiet mode.
[12:44:11]   ^-- Logging to file
'/home/ignite1/project/apacheIgnite/apache-ignite-fabric-1.6.0-bin/work/log/ignite-11ad75b2.0.log'
[12:44:11]   ^-- To see **FULL** console log here add -DIGNITE_QUIET=false
or "-v" to ignite.{sh|bat}
[12:44:11] 
[12:44:11] OS: Linux 3.10.0-327.28.2.el7.x86_64 amd64
[12:44:11] VM information: Java(TM) SE Runtime Environment 1.8.0_92-b14
Oracle Corporation Java HotSpot(TM) 64-Bit Server VM 25.92-b14
[12:44:16] Configured plugins:
[12:44:16]   ^-- None
[12:44:16] 
[12:44:17] Security status [authentication=off, tls/ssl=off]
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/home/ignite1/project/apacheIgnite/apache-ignite-fabric-1.6.0-bin/libs/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in

Re: Couchbase as persistent store

[vkulichenko]

You have write behind enabled. This means that the data will be flushed
eventually. Does it work if you disable write behind (in this case the store
will be updated synchronously with the cache update)?

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8089.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Couchbase as persistent store

[kvipin]

Val,

I'm not getting any error or exception that's what makes it difficult to
figure out whats going on. But I do see Apache Ignite opening couchbase
bucket successfully, which is equivalent to connection establishment. But
after that no activity server side and client side every thing seems to be
working fine.

Following is the output from Server node:

$ ./nodemgr -c config/test-tool-server.xml
log4j:WARN No appenders could be found for logger
(org.springframework.core.env.StandardEnvironment).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for
more info.
[07:04:36]__   
[07:04:36]   /  _/ ___/ |/ /  _/_  __/ __/ 
[07:04:36]  _/ // (7 7// /  / / / _/   
[07:04:36] /___/\___/_/|_/___/ /_/ /___/  
[07:04:36] 
[07:04:36] ver. 1.6.0#20160518-sha1:0b22c45b
[07:04:36] 2016 Copyright(C) Apache Software Foundation
[07:04:36] 
[07:04:36] Ignite documentation: http://ignite.apache.org
[07:04:36] 
[07:04:36] Quiet mode.
[07:04:36]   ^-- Logging to file
'/home/ignite1/project/apacheIgnite/apache-ignite-fabric-1.6.0-bin/work/log/ignite-a5293357.0.log'
[07:04:36]   ^-- To see **FULL** console log here add -DIGNITE_QUIET=false
or "-v" to ignite.{sh|bat}
[07:04:36] 
[07:04:36] OS: Linux 3.10.0-327.28.2.el7.x86_64 amd64
[07:04:36] VM information: Java(TM) SE Runtime Environment 1.8.0_92-b14
Oracle Corporation Java HotSpot(TM) 64-Bit Server VM 25.92-b14
[07:04:41] Configured plugins:
[07:04:41]   ^-- None
[07:04:41] 
[07:04:42] Security status [authentication=off, tls/ssl=off]
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/home/ignite1/project/apacheIgnite/apache-ignite-fabric-1.6.0-bin/libs/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in
[jar:file:/home/ignite1/project/apacheIgnite/apache-ignite-fabric-1.6.0-bin/libs/ignite-rest-http/slf4j-log4j12-1.7.7.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an
explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.SimpleLoggerFactory]
[main] INFO org.eclipse.jetty.util.log - Logging initialized @6767ms
[main] INFO org.eclipse.jetty.server.Server - jetty-9.2.11.v20150529
[main] INFO org.eclipse.jetty.server.ServerConnector - Started
ServerConnector@24d09c1{HTTP/1.1}{0.0.0.0:8080}
[main] INFO org.eclipse.jetty.server.Server - Started @6818ms
[07:04:44] Performance suggestions for grid  (fix if possible)
[07:04:44] To disable, set -DIGNITE_PERFORMANCE_SUGGESTIONS_DISABLED=true
[07:04:44]   ^-- Disable peer class loading (set 'peerClassLoadingEnabled'
to false)
[07:04:44]   ^-- Enable ATOMIC mode if not using transactions (set
'atomicityMode' to ATOMIC)
[07:04:44]   ^-- Disable fully synchronous writes (set
'writeSynchronizationMode' to PRIMARY_SYNC or FULL_ASYNC)
[07:04:44] 
[07:04:44] To start Console Management & Monitoring run
ignitevisorcmd.{sh|bat}
[07:04:44] 
[07:04:44] Ignite node started OK (id=a5293357)
[07:04:44] Topology snapshot [ver=1, servers=1, clients=0, CPUs=32,
heap=0.5GB]
[07:04:55] New version is available at ignite.apache.org: 1.7.0
[07:05:46] Topology snapshot [ver=2, servers=1, clients=1, CPUs=32,
heap=1.0GB]
[flusher-0-#148%null%] INFO com.couchbase.client.core.CouchbaseCore -
CouchbaseEnvironment: {sslEnabled=false, sslKeystoreFile='null',
sslKeystorePassword=false, sslKeystore=null, bootstrapHttpEnabled=true,
bootstrapCarrierEnabled=true, bootstrapHttpDirectPort=8091,
bootstrapHttpSslPort=18091, bootstrapCarrierDirectPort=11210,
bootstrapCarrierSslPort=11207, ioPoolSize=32, computationPoolSize=32,
responseBufferSize=16384, requestBufferSize=16384, kvServiceEndpoints=1,
viewServiceEndpoints=1, queryServiceEndpoints=1, searchServiceEndpoints=1,
ioPool=NioEventLoopGroup, coreScheduler=CoreScheduler,
eventBus=DefaultEventBus, packageNameAndVersion=couchbase-java-client/2.3.3
(git: 2.3.3, core: 1.3.3), dcpEnabled=false, retryStrategy=BestEffort,
maxRequestLifetime=75000, retryDelay=ExponentialDelay{growBy 1.0
MICROSECONDS, powers of 2; lower=100, upper=10},
reconnectDelay=ExponentialDelay{growBy 1.0 MILLISECONDS, powers of 2;
lower=32, upper=4096}, observeIntervalDelay=ExponentialDelay{growBy 1.0
MICROSECONDS, powers of 2; lower=10, upper=10}, keepAliveInterval=3,
autoreleaseAfter=2000, bufferPoolingEnabled=true, tcpNodelayEnabled=true,
mutationTokensEnabled=false, socketConnectTimeout=1000,
dcpConnectionBufferSize=20971520, dcpConnectionBufferAckThreshold=0.2,
dcpConnectionName=dcp/core-io, callbacksOnIoPool=false,
disconnectTimeout=25000,
requestBufferWaitStrategy=com.couchbase.client.core.env.DefaultCoreEnvironment$2@6ec6ddb4,
queryTimeout=75000, viewTimeout=75000, kvTimeout=2500, connectTimeout=5000,
dnsSrvEnabled=false}
[cb-io-1-1] INFO com.couchbase.client.core.node.Node - Connected to Node
localhost
[cb-computations-9] INFO
com.couchbase.client.core.config.ConfigurationProvider - 

Re: Couchbase as persistent store

[vkulichenko]

What is the exception now?

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p8065.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Couchbase as persistent store

[kvipin]

Guys,

read-through is working fine for me but write-through is not working. I'm
not getting error/exception either. Following is my configuration file and
relevant code blocks,

*Sever node configuration file:*

$ cat test-tool-server.xml


http://www.springframework.org/schema/beans;
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
   xmlns:util="http://www.springframework.org/schema/util;
   xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util.xsd;>































  

  




































tid
idint

















  

  




































tid
idint
























127.0.0.1:47550..47551









*C++ test program which talks to Apache Ignite*

$ cat main.cc
...
void* Insert_i(void* arg, const std::string& cname) {
std::clog << __func__ << " called." << std::endl;
Cache ttcache = 

Re: Couchbase as persistent store

[kvipin]

Thanks a ton Val, it solved my problem.

regards,



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p7762.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Couchbase as persistent store

[vkulichenko]

Hi Kevin,

It looks like you serialize the instance of the CacheStore, most likely due
to the fact that you use SingletonFactory. Please try to use ClassFactory or
your own factory that will not encapsulate the instance, but will create a
new one in the 'create()' method.

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p7689.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Couchbase as persistent store

[vkulichenko]

Method signatures in your implementations are incorrect. Please pay attention
to generics. The write method, for example, should look like this:

@Override public void write(Cache.Entry
entry) throws CacheWriterException

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Couchbase-as-persistent-store-tp7476p7500.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.