Uploaded image for project: 'Hot Rod Native client'
  1. Hot Rod Native client
  2. HRCPP-415

Adding continuous query listener for aggregated queries results in confusing exception

This issue belongs to an archived project. You can view it, but you can't modify it. Learn more

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • None
    • 8.1.1.Final
    • .NET
    • None

      Registering a continuous query with aggregations or grouping is expected to fail. It currently fails but the exception is very confusing, maybe there's come other problem:

      Infinispan.HotRod.Exceptions.TransportException : write (host: 127.0.0.1 port: 11222) An operation was attempted on something that is not a socket.
      4:
      4:    at Infinispan.HotRod.SWIGGen.RemoteByteArrayCache.addClientListener(ClientListenerCallback cb, VectorChar filterName, VectorChar converterName, Boolean includeCurrentState, VectorVectorChar filterFactoryParam, VectorVectorChar converterFactoryParams, Boolean useRawData, Byte interestFlag) in Y:\build_windows\swig\RemoteByteArrayCache.cs:line 394
      4:    at Infinispan.HotRod.Impl.RemoteCacheSWIGGenImpl`2.AddClientListener[CQK,CQV](ClientListener`2 cl, String[] filterFactoryParams, String[] converterFactoryParams, Action recoveryCallback) in Y:\src\main\cs\Infinispan\HotRod\Impl\RemoteCacheSWIGImpl.cs:line 454
      4:    at Infinispan.HotRod.Impl.RemoteCacheSWIGGenImpl`2.AddContinuousQueryListener[CQK,CQV](ContinuousQueryListener`2 cql) in Y:\src\main\cs\Infinispan\HotRod\Impl\RemoteCacheSWIGImpl.cs:line 468
      

      The code used for reproducing this bug is here:

      [Test]
              public void ExceptionOnGroupingAndAggregationTest()
              {
                  IRemoteCache<int, User> userCache = remoteManager.GetCache<int, User>(NAMED_CACHE);
                  QueryRequest qr = new QueryRequest();
                  qr.QueryString = "select max(u.age) from sample_bank_account.User u where u.age >= 20";
                  Event.ContinuousQueryListener<int, User> cql = new Event.ContinuousQueryListener<int, User>(qr.QueryString);
                  userCache.AddContinuousQueryListener(cql);
              }
      

              vrigamon@redhat.com Vittorio Rigamonti
              mgencur Martin Gencur (Inactive)
              Archiver:
              rhn-support-adongare Amol Dongare

                Created:
                Updated:
                Resolved:
                Archived: