H,
i'm getting exception on the server nodes when a new City record is added .
The c# code is below:
namespace ignite_test
{
class Program
{
class CityEventListener : ICacheEntryEventListener<int, City>
{
public void OnEvent(IEnumerable<ICacheEntryEvent<int, City>>
evts)
{
foreach (var evt in evts)
Console.WriteLine(evt.Value);
}
}
static void Main(string[] args)
{
Ignition.ClientMode = true;
using (var ignite =
Ignition.Start(@"C:\apache_ignite\examples\config\example-ignite.xml"))
{
var persons = ignite.GetCache<int, City>("City");
var localListener = new CityEventListener();
var qry = new ContinuousQuery<int, City>(localListener);
{
qry.Filter = new RemoteFilter();
}
//var query = new SqlQuery("City", "select * from City where
id = 1");
var queryHandle = persons.QueryContinuous(qry);
//foreach (var entry in queryHandle.GetInitialQueryCursor())
/// Console.WriteLine("key={0}, val={1}", entry.Key,
entry.Value);
Console.ReadLine();
}
}
}
}
namespace ignite_shared
{
public class City
{
public City(int id, string name)
{
Name = name;
Id = id;
}
[QuerySqlField]
public int Id { get; set; }
[QuerySqlField]
public string Name { get; set; }
}
}
namespace ignite_shared
{
public class RemoteFilter : ICacheEntryEventFilter<int, City>
{
public bool Evaluate(ICacheEntryEvent<int, City> evt)
{
return true;
//return (evt.Value.Id == 1);
}
}
}
One i start the server node, i go into SQlLine and execute the following
command:
CREATE TABLE City (id int PRIMARY KEY, name VARCHAR) WITH
"template=replicated, CACHE_NAME=City, VALUE_TYPE=ignite_shared.City";
then
insert into City (id, name) values (1, 'Lima');
then I start the C# application with no issues, and then i do this on
sqlline:
insert into City (id, name) values (2, 'Quito');
Result (on server node):
[14:07:26,499][SEVERE][sys-#55][] Failure in Java callback
class org.apache.ignite.IgniteException: Platform
error:Apache.Ignite.Core.Binar
y.BinaryObjectException: Requesting mapping from grid failed for
[platformId=1,
typeId=1173251103] ---> Apache.Ignite.Core.Common.JavaException: class
org.apach
e.ignite.binary.BinaryObjectException: Requesting mapping from grid failed
for [
platformId=1, typeId=1173251103]
at
org.apache.ignite.internal.processors.platform.binary.PlatformBinaryP
rocessor.processInStreamOutStream(PlatformBinaryProcessor.java:126)
at
org.apache.ignite.internal.processors.platform.PlatformTargetProxyImp
l.inStreamOutStream(PlatformTargetProxyImpl.java:136)
at
org.apache.ignite.internal.processors.platform.callback.PlatformCallb
ackUtils.inLongOutLong(Native Method)
at
org.apache.ignite.internal.processors.platform.callback.PlatformCallb
ackGateway.continuousQueryListenerApply(PlatformCallbackGateway.java:377)
at
org.apache.ignite.internal.processors.platform.utils.PlatformUtils.ap
plyContinuousQueryEvents(PlatformUtils.java:556)
at
org.apache.ignite.internal.processors.platform.cache.query.PlatformCo
ntinuousQueryImpl.onUpdated(PlatformContinuousQueryImpl.java:200)
at
org.apache.ignite.internal.processors.cache.query.continuous.CacheCon
tinuousQueryHandler.notifyLocalListener(CacheContinuousQueryHandler.java:942)
at
org.apache.ignite.internal.processors.cache.query.continuous.CacheCon
tinuousQueryHandler.notifyCallback0(CacheContinuousQueryHandler.java:786)
at
org.apache.ignite.internal.processors.cache.query.continuous.CacheCon
tinuousQueryHandler.notifyCallback(CacheContinuousQueryHandler.java:727)
at
org.apache.ignite.internal.processors.continuous.GridContinuousProces
sor.processNotification(GridContinuousProcessor.java:1618)
at
org.apache.ignite.internal.processors.continuous.GridContinuousProces
sor.access$1800(GridContinuousProcessor.java:108)
at
org.apache.ignite.internal.processors.continuous.GridContinuousProces
sor$8.onMessage(GridContinuousProcessor.java:1003)
at
org.apache.ignite.internal.managers.communication.GridIoManager.invok
eListener(GridIoManager.java:1556)
at
org.apache.ignite.internal.managers.communication.GridIoManager.acces
s$4100(GridIoManager.java:125)
at
org.apache.ignite.internal.managers.communication.GridIoManager$GridC
ommunicationMessageSet.unwind(GridIoManager.java:2752)
at
org.apache.ignite.internal.managers.communication.GridIoManager.unwin
dMessageSet(GridIoManager.java:1516)
at
org.apache.ignite.internal.managers.communication.GridIoManager.acces
s$4400(GridIoManager.java:125)
at
org.apache.ignite.internal.managers.communication.GridIoManager$10.ru
n(GridIoManager.java:1485)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.
java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassNotFoundException: Requesting mapping from grid
failed
for [platformId=1, typeId=1173251103]
at
org.apache.ignite.internal.MarshallerContextImpl.getClassName(Marshal
lerContextImpl.java:385)
at
org.apache.ignite.internal.processors.platform.binary.PlatformBinaryP
rocessor.processInStreamOutStream(PlatformBinaryProcessor.java:121)
... 20 more
at Apache.Ignite.Core.Impl.Unmanaged.Jni.Env.ExceptionCheck()
at
Apache.Ignite.Core.Impl.Unmanaged.UnmanagedUtils.TargetInStreamOutStream(G
lobalRef target, Int32 opType, Int64 inMemPtr, Int64 outMemPtr)
at Apache.Ignite.Core.Impl.PlatformJniTarget.InStreamOutStream[TR](Int32
type
, Action`1 writeAction, Func`2 readAction)
--- End of inner exception stack trace ---
at Apache.Ignite.Core.Impl.PlatformJniTarget.InStreamOutStream[TR](Int32
type
, Action`1 writeAction, Func`2 readAction)
at Apache.Ignite.Core.Impl.Binary.BinaryProcessor.GetTypeName(Int32 id)
at Apache.Ignite.Core.Impl.Binary.Marshaller.GetDescriptor(Boolean
userType,
Int32 typeId, Boolean requiresType, String typeName, Type knownType)
at Apache.Ignite.Core.Impl.Binary.BinaryReader.ReadFullObject[T](Int32
pos, T
ype typeOverride)
at Apache.Ignite.Core.Impl.Binary.BinaryReader.TryDeserialize[T](T& res,
Type
typeOverride)
at Apache.Ignite.Core.Impl.Binary.BinaryReader.Deserialize[T](Type
typeOverri
de)
at
Apache.Ignite.Core.Impl.Binary.BinaryReader.ReadBinaryObject[T](Boolean do
Detach)
at Apache.Ignite.Core.Impl.Binary.BinaryReader.TryDeserialize[T](T& res,
Type
typeOverride)
at
Apache.Ignite.Core.Impl.Cache.Query.Continuous.ContinuousQueryUtils.ReadEv
ent0[TK,TV](BinaryReader reader)
at
Apache.Ignite.Core.Impl.Cache.Query.Continuous.ContinuousQueryUtils.ReadEv
ents[TK,TV](IBinaryStream stream, Marshaller marsh, Boolean keepBinary)
at
Apache.Ignite.Core.Impl.Cache.Query.Continuous.ContinuousQueryHandleImpl`2
.Apply(IBinaryStream stream)
at
Apache.Ignite.Core.Impl.Unmanaged.UnmanagedCallbacks.ContinuousQueryListen
erApply(Int64 memPtr)
at
Apache.Ignite.Core.Impl.Unmanaged.UnmanagedCallbacks.InLongOutLong(Int32 t
ype, Int64 val)
at
org.apache.ignite.internal.processors.platform.PlatformProcessorImpl.
loggerLog(PlatformProcessorImpl.java:400)
at
org.apache.ignite.internal.processors.platform.PlatformProcessorImpl.
processInStreamOutLong(PlatformProcessorImpl.java:456)
at
org.apache.ignite.internal.processors.platform.PlatformProcessorImpl.
processInStreamOutLong(PlatformProcessorImpl.java:503)
at
org.apache.ignite.internal.processors.platform.PlatformTargetProxyImp
l.inStreamOutLong(PlatformTargetProxyImpl.java:67)
at
org.apache.ignite.internal.processors.platform.callback.PlatformCallb
ackUtils.inLongOutLong(Native Method)
at
org.apache.ignite.internal.processors.platform.callback.PlatformCallb
ackGateway.continuousQueryListenerApply(PlatformCallbackGateway.java:377)
at
org.apache.ignite.internal.processors.platform.utils.PlatformUtils.ap
plyContinuousQueryEvents(PlatformUtils.java:556)
at
org.apache.ignite.internal.processors.platform.cache.query.PlatformCo
ntinuousQueryImpl.onUpdated(PlatformContinuousQueryImpl.java:200)
at
org.apache.ignite.internal.processors.cache.query.continuous.CacheCon
tinuousQueryHandler.notifyLocalListener(CacheContinuousQueryHandler.java:942)
at
org.apache.ignite.internal.processors.cache.query.continuous.CacheCon
tinuousQueryHandler.notifyCallback0(CacheContinuousQueryHandler.java:786)
at
org.apache.ignite.internal.processors.cache.query.continuous.CacheCon
tinuousQueryHandler.notifyCallback(CacheContinuousQueryHandler.java:727)
at
org.apache.ignite.internal.processors.continuous.GridContinuousProces
sor.processNotification(GridContinuousProcessor.java:1618)
at
org.apache.ignite.internal.processors.continuous.GridContinuousProces
sor.access$1800(GridContinuousProcessor.java:108)
at
org.apache.ignite.internal.processors.continuous.GridContinuousProces
sor$8.onMessage(GridContinuousProcessor.java:1003)
at
org.apache.ignite.internal.managers.communication.GridIoManager.invok
eListener(GridIoManager.java:1556)
at
org.apache.ignite.internal.managers.communication.GridIoManager.acces
s$4100(GridIoManager.java:125)
at
org.apache.ignite.internal.managers.communication.GridIoManager$GridC
ommunicationMessageSet.unwind(GridIoManager.java:2752)
at
org.apache.ignite.internal.managers.communication.GridIoManager.unwin
dMessageSet(GridIoManager.java:1516)
at
org.apache.ignite.internal.managers.communication.GridIoManager.acces
s$4400(GridIoManager.java:125)
at
org.apache.ignite.internal.managers.communication.GridIoManager$10.ru
n(GridIoManager.java:1485)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.
java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:617)
at java.lang.Thread.run(Thread.java:745)
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
