Aleksander Kiyaschenko created ZEPPELIN-5029:
------------------------------------------------
Summary: Ignite interpreter doesn't work if PeerClassLoading
enabled
Key: ZEPPELIN-5029
URL: https://issues.apache.org/jira/browse/ZEPPELIN-5029
Project: Zeppelin
Issue Type: Bug
Components: Interpreters, zeppelin-interpreter
Affects Versions: 0.9.0
Reporter: Aleksander Kiyaschenko
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:
{quote}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)
{quote}
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
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
