WriteAll() method on insert statement execute from sqlline

[siva]

Hi,
I am using .net core Application for Ignite client and server,Ignite V2.7.6.

Table and indexes created through QueryEntity from Model class.

So same table i am using with 3rd party thin client to put data into cache.

e.g:
----
public interface ICustomCacheStore
    {
    }

public class Person:ICustomCacheStore{
        [QuerySqlField]
        public String Id { get; set; }
        [QuerySqlField]
        public String Name { get; set; }
        ...
}

var personObject = new Person(){
Id=123,
Name=Ram
};

cache.putAsync("Person",personObject);

On putAsync writeAll through write behind enable calling
here is the writeAll() method implementation.

 public void WriteAll(IEnumerable<KeyValuePair&lt;string,
ICustomCacheStore>> entries){
 //parse incoming entries and insert into sql server code
 ....
 ...
 //successfully insertion happening
 }
 
but some other table created through create command.
e.g:
CREATE TABLE IF NOT EXISTS
"C091E548-B45A-49B4-B8EC-2CB5E27C7AF6".EntitiesPulsarTest(EntityId
varchar,EntityType varchar,EntityInfoJson varchar,TenantName
varchar,TenantId varchar,Fabric varchar,EntityName varchar,SequenceNumber
Double) WITH "template=partitioned,backups=0";

 
but on insert statement execute from sqlline inside WriteAll() method
getting the following exception:
public void WriteAll(IEnumerable<KeyValuePair&lt;string, ICustomCacheStore>>
entries)
        {
                List<KeyValuePair&lt;string, ICustomCacheStore>> entityList =
entries.ToList();//here getting an exception
                foreach (var recordEntry in entityList)
                {
                                ...
                                ...
                                ...
                                }
                }

Unknown pair [platformId=1, typeId=1505474372]

class org.apache.ignite.binary.BinaryObjectException: Unknown pair
[platformId=1, typeId=1505474372]
        at
org.apache.ignite.internal.processors.platform.binary.PlatformBinaryProcessor.processInStreamOutStream(PlatformBinaryProcessor.java:126)
        at
org.apache.ignite.internal.processors.platform.PlatformTargetProxyImpl.inStreamOutStream(PlatformTargetProxyImpl.java:136)
        at
org.apache.ignite.internal.processors.platform.callback.PlatformCallbackUtils.inLongOutLong(Native
Method)
        at
org.apache.ignite.internal.processors.platform.callback.PlatformCallbackGateway.cacheStoreInvoke(PlatformCallbackGateway.java:80)
        at
org.apache.ignite.internal.processors.platform.dotnet.PlatformDotNetCacheStore.doInvoke(PlatformDotNetCacheStore.java:480)
        at
org.apache.ignite.internal.processors.platform.dotnet.PlatformDotNetCacheStore.writeAll(PlatformDotNetCacheStore.java:277)
        at
org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore.updateStore(GridCacheWriteBehindStore.java:816)
        at
org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore.applyBatch(GridCacheWriteBehindStore.java:726)
        at
org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore.access$2400(GridCacheWriteBehindStore.java:76)
        at
org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore$Flusher.flushCacheCoalescing(GridCacheWriteBehindStore.java:1147)
        at
org.apache.ignite.internal.processors.cache.store.GridCacheWriteBehindStore$Flusher.body(GridCacheWriteBehindStore.java:1018)
        at
org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:120)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException: Unknown pair [platformId=1,
typeId=1505474372]
        at
org.apache.ignite.internal.MarshallerContextImpl.getClassName(MarshallerContextImpl.java:394)
        at
org.apache.ignite.internal.processors.platform.binary.PlatformBinaryProcessor.processInStreamOutStream(PlatformBinaryProcessor.java:121)
        ... 12 more
        
        
So how to receive as key value pair result as same working like putAsync
cache.

Receive WriteAll(IEnumerable<KeyValuePair&lt;string, ICustomCacheStore>>
entries) method acceptable format data where table created through query, on
insert statement execute from sqlline?




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/