Uploaded image for project: 'Zeppelin'
  1. Zeppelin
  2. ZEPPELIN-5029

Ignite interpreter doesn't work if PeerClassLoading enabled

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Blocker
    • Resolution: Unresolved
    • Affects Version/s: 0.9.0
    • Fix Version/s: None
    • Labels:
      None

      Description

      Hello,

      Since this option is enabled on the server, it must be enabled on the client as well. When testing the interpreter (https://github.com/apache/zeppelin/blob/master/ignite/src/test/java/org/apache/zeppelin/ignite/IgniteInterpreterTest.java#L48) with the option enabled, the test ends with an error:

      SEVERE: Failed to process message [senderId=502dddc0-5e8d-49fd-9240-ff1c24670b2d, msg=GridDhtPartitionsFullMessage [parts=HashMap {-2100569601=GridDhtPartitionFullMap {502dddc0-5e8d-49fd-9240-ff1c24670b2d=GridDhtPartitionMap [moving=0, top=AffinityTopologyVersion [topVer=1, minorTopVer=0], updateSeq=2, size=100]}}, partCntrs=null, partCntrs2=null, partHistSuppliers=null, partsToReload=null, topVer=AffinityTopologyVersion [topVer=2, minorTopVer=0], errs=null, resTopVer=null, flags=1, partCnt=1, super=GridDhtPartitionsAbstractMessage [exchId=GridDhtPartitionExchangeId [topVer=AffinityTopologyVersion [topVer=2, minorTopVer=0], discoEvt=null, nodeId=9b5649a2, evt=NODE_JOINED], lastVer=GridCacheVersion [topVer=0, order=1599314988778, nodeOrder=0], super=GridCacheMessage [msgId=2, depInfo=null, lastAffChangedTopVer=AffinityTopologyVersion [topVer=1, minorTopVer=0], err=null, skipPrepare=false]]]]SEVERE: Failed to process message [senderId=502dddc0-5e8d-49fd-9240-ff1c24670b2d, msg=GridDhtPartitionsFullMessage [parts=HashMap {-2100569601=GridDhtPartitionFullMap {502dddc0-5e8d-49fd-9240-ff1c24670b2d=GridDhtPartitionMap [moving=0, top=AffinityTopologyVersion [topVer=1, minorTopVer=0], updateSeq=2, size=100]}}, partCntrs=null, partCntrs2=null, partHistSuppliers=null, partsToReload=null, topVer=AffinityTopologyVersion [topVer=2, minorTopVer=0], errs=null, resTopVer=null, flags=1, partCnt=1, super=GridDhtPartitionsAbstractMessage [exchId=GridDhtPartitionExchangeId [topVer=AffinityTopologyVersion [topVer=2, minorTopVer=0], discoEvt=null, nodeId=9b5649a2, evt=NODE_JOINED], lastVer=GridCacheVersion [topVer=0, order=1599314988778, nodeOrder=0], super=GridCacheMessage [msgId=2, depInfo=null, lastAffChangedTopVer=AffinityTopologyVersion [topVer=1, minorTopVer=0], err=null, skipPrepare=false]]]]java.lang.ClassCastException: org.apache.ignite.internal.processors.cache.distributed.dht.preloader.IgniteDhtPartitionCountersMap2 cannot be cast to org.apache.ignite.internal.processors.cache.distributed.dht.preloader.IgniteDhtPartitionCountersMap2 at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsFullMessage.finishUnmarshal(GridDhtPartitionsFullMessage.java:589) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.unmarshall(GridCacheIoManager.java:1625) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:586) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:392) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:318) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$100(GridCacheIoManager.java:109) at org.apache.ignite.internal.processors.cache.GridCacheIoManager$1.onMessage(GridCacheIoManager.java:308) at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1843) at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:1468) at org.apache.ignite.internal.managers.communication.GridIoManager.access$5200(GridIoManager.java:229) at org.apache.ignite.internal.managers.communication.GridIoManager$9.run(GridIoManager.java:1365) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

      If I try to start the client not in the context of the interpreter, then everything works.

      The following versions of Ignite have been tested: 2.7.6, 2.8.0

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              bostonaqua Aleksander Kiyaschenko
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: