Uploaded image for project: 'Ignite'
  1. Ignite
  2. IGNITE-8528

Peer deployment does not work for continuous query transformers

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.5
    • Fix Version/s: 2.5
    • Component/s: None
    • Labels:
      None

      Description

      Build local Ignite distribution using

      mvn clean install -Pall-java,all-scala,licenses -DskipTests
      mvn initialize -Prelease
      

      Start one node in console and run continuous query with transformer example in IDE. I am getting the following exception:

      [15:30:43] To start Console Management & Monitoring run ignitevisorcmd.{sh|bat}
      [15:30:43] 
      [15:30:43] Ignite node started OK (id=f1356a5b)
      [15:30:43] Topology snapshot [ver=1, servers=1, clients=0, CPUs=16, offheap=19.0GB, heap=2.0GB]
      [15:30:43]   ^-- Node [id=F1356A5B-4CDB-4480-A64F-35BF2C96DBB5, clusterState=ACTIVE]
      [15:30:43] Data Regions Configured:
      [15:30:43]   ^-- default [initSize=256.0 MiB, maxSize=18.9 GiB, persistenceEnabled=false]
      [15:30:52] Topology snapshot [ver=2, servers=2, clients=0, CPUs=16, offheap=38.0GB, heap=3.0GB]
      [15:30:52]   ^-- Node [id=F1356A5B-4CDB-4480-A64F-35BF2C96DBB5, clusterState=ACTIVE]
      [15:30:52] Data Regions Configured:
      [15:30:52]   ^-- default [initSize=256.0 MiB, maxSize=18.9 GiB, persistenceEnabled=false]
      [15:30:53,065][SEVERE][tcp-disco-msg-worker-#2][BinaryContext] Failed to deserialize object [typeName=java.lang.invoke.SerializedLambda]
      class org.apache.ignite.binary.BinaryObjectException: Failed to read field [name=capturingClass]
      	at org.apache.ignite.internal.binary.BinaryFieldAccessor.read(BinaryFieldAccessor.java:187)
      	at org.apache.ignite.internal.binary.BinaryClassDescriptor.read(BinaryClassDescriptor.java:870)
      	at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1762)
      	at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1714)
      	at org.apache.ignite.internal.binary.BinaryReaderExImpl.readField(BinaryReaderExImpl.java:1982)
      	at org.apache.ignite.internal.binary.BinaryFieldAccessor$DefaultFinalClassAccessor.read0(BinaryFieldAccessor.java:698)
      	at org.apache.ignite.internal.binary.BinaryFieldAccessor.read(BinaryFieldAccessor.java:183)
      	at org.apache.ignite.internal.binary.BinaryClassDescriptor.read(BinaryClassDescriptor.java:870)
      	at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize0(BinaryReaderExImpl.java:1762)
      	at org.apache.ignite.internal.binary.BinaryReaderExImpl.deserialize(BinaryReaderExImpl.java:1714)
      	at org.apache.ignite.internal.binary.GridBinaryMarshaller.deserialize(GridBinaryMarshaller.java:310)
      	at org.apache.ignite.internal.binary.BinaryMarshaller.unmarshal0(BinaryMarshaller.java:99)
      	at org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller.unmarshal(AbstractNodeNameAwareMarshaller.java:82)
      	at org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9962)
      	at org.apache.ignite.internal.util.IgniteUtils.unmarshal(IgniteUtils.java:9991)
      	at org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryDeployableObject.unmarshal(CacheContinuousQueryDeployableObject.java:94)
      	at org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandlerV3.p2pUnmarshal(CacheContinuousQueryHandlerV3.java:155)
      	at org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.processStartRequest(GridContinuousProcessor.java:1327)
      	at org.apache.ignite.internal.processors.continuous.GridContinuousProcessor.access$400(GridContinuousProcessor.java:108)
      	at org.apache.ignite.internal.processors.continuous.GridContinuousProcessor$2.onCustomEvent(GridContinuousProcessor.java:200)
      	at org.apache.ignite.internal.processors.continuous.GridContinuousProcessor$2.onCustomEvent(GridContinuousProcessor.java:191)
      	at org.apache.ignite.internal.managers.discovery.GridDiscoveryManager$4.onDiscovery0(GridDiscoveryManager.java:707)
      	at org.apache.ignite.internal.managers.discovery.GridDiscoveryManager$4.onDiscovery(GridDiscoveryManager.java:589)
      	at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.notifyDiscoveryListener(ServerImpl.java:5479)
      	at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processCustomMessage(ServerImpl.java:5305)
      	at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processMessage(ServerImpl.java:2765)
      	at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processMessage(ServerImpl.java:2536)
      	at org.apache.ignite.spi.discovery.tcp.ServerImpl$MessageWorkerAdapter.body(ServerImpl.java:6775)
      	at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.body(ServerImpl.java:2621)
      	at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62)
      Caused by: class org.apache.ignite.binary.BinaryInvalidTypeException: org.apache.ignite.examples.datagrid.CacheContinuousQueryWithTransformerExample
      	at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:697)
      	at org.apache.ignite.internal.binary.BinaryUtils.doReadClass(BinaryUtils.java:1631)
      	at org.apache.ignite.internal.binary.BinaryUtils.doReadClass(BinaryUtils.java:1568)
      	at org.apache.ignite.internal.binary.BinaryUtils.doReadClass(BinaryUtils.java:1545)
      	at org.apache.ignite.internal.binary.BinaryReaderExImpl.readClass(BinaryReaderExImpl.java:380)
      	at org.apache.ignite.internal.binary.BinaryFieldAccessor$DefaultFinalClassAccessor.readFixedType(BinaryFieldAccessor.java:902)
      	at org.apache.ignite.internal.binary.BinaryFieldAccessor$DefaultFinalClassAccessor.read0(BinaryFieldAccessor.java:698)
      	at org.apache.ignite.internal.binary.BinaryFieldAccessor.read(BinaryFieldAccessor.java:183)
      	... 29 more
      Caused by: java.lang.ClassNotFoundException: org.apache.ignite.examples.datagrid.CacheContinuousQueryWithTransformerExample
      	at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
      	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
      	at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338)
      	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
      	at java.lang.Class.forName0(Native Method)
      	at java.lang.Class.forName(Class.java:348)
      	at org.apache.ignite.internal.util.IgniteUtils.forName(IgniteUtils.java:8608)
      	at org.apache.ignite.internal.MarshallerContextImpl.getClass(MarshallerContextImpl.java:349)
      	at org.apache.ignite.internal.binary.BinaryContext.descriptorForTypeId(BinaryContext.java:688)
      	... 36 more
      

      Note that CacheContinuousQueryExample works fine in this case.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                NIzhikov Nikolay Izhikov
                Reporter:
                agoncharuk Alexey Goncharuk
              • Votes:
                0 Vote for this issue
                Watchers:
                6 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: