Re: write behind is not triggering for created table through query

[Ilya Kasnacheev]

Hello!

Can you show complete cache configuration (template)?

I imagine it's possible that your cache ends up having primitive type as
key, yet you try to use it as binary object in cache store.

Regards,
-- 
Ilya Kasnacheev


пн, 13 янв. 2020 г. в 15:10, siva <siva.ka...@bizruntime.com>:

> Hi,
> Thanks for reply...write behind triggering now.but getting exception in
> writeAll() method.
>
> I have one query on insert what will be the key and value for writeAll()
> method,if i defined or not in create query commond key_type and
> value_type?.is this key_type and value_type needed.?
>
> but in case of cache.putAsync(key,tableModel); working properly.
>
> WriteAll(IEnumerable<KeyValuePair&lt;string, ICustomCacheStore>> entries){
> List<KeyValuePair&lt;string, ICustomCacheStore>> entityList =
> entries.ToList();//on sql insert error
> foreach (var recordEntry in entityList)
>  {
>    ....
>    ....
>  }
> }
>
> *create and insert query*:
> --------------
> 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,PRIMARY KEY(EntityId)) WITH
>
> "template=CacheConfigurationTemplate,backups=0,key_type=TableName,value_type=EntitiesPulsarTest";
>
>
> INSERT INTO
>
> "C091E548-B45A-49B4-B8EC-2CB5E27C7AF6".EntitiesPulsarTest(EntityId,EntityInfoJson,EntityName,EntityType,Fabric,SequenceNumber,TenantId,TenantName)
> VALUES ('0-pulsar', '{}', 'Testing Topic0 Name', 'testpulsarType',
> 'pulsarFabric', 0.0, 'pulsar-123-tenantid', 'pulsar-tenantName');
>
> Exception:
> Apache.Ignite.Core.Binary.BinaryObjectException: Invalid header on
> deserialization [pos=136, hdr=0]
>    at Apache.Ignite.Core.Impl.Binary.BinaryReader.TryDeserialize[T](T& res,
> Type typeOverride)
>    at Apache.Ignite.Core.Impl.Binary.BinaryReader.Deserialize[T](Type
> typeOverride)
>    at
>
> Apache.Ignite.Core.Impl.Cache.Store.CacheStoreInternal`2.<ReadPairs>d__14.MoveNext()
>    at System.Collections.Generic.List`1.AddEnumerable(IEnumerable`1
> enumerable)
>    at System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
>    at
> IgnitePersistenceApp.CacheStore.TenantCacheStore.WriteAll(IEnumerable`1
> entries)
>
> anything i have to change in create or insert query?
>
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>