Evgenii Zhuravlev created IGNITE-9486:
-----------------------------------------
Summary: JobStealing doesn't work with affinityRun
Key: IGNITE-9486
URL: https://issues.apache.org/jira/browse/IGNITE-9486
Project: Ignite
Issue Type: Bug
Affects Versions: 2.6
Reporter: Evgenii Zhuravlev
It rebalances job to the node, that doesn't have needed partition, which lead
to the exception:
{code:java}
[2018-09-06 18:03:47,545][ERROR][pub-#61][GridJobWorker] Failed to lock
partitions [jobId=a29f86fa561-3e2c91e1-1f47-401c-80a2-ea2b452a3cb5,
ses=GridJobSessionImpl [ses=GridTaskSessionImpl
[taskName=o.a.i.examples.ExampleNodeStartup3$1, dep=GridDeployment
[ts=1536246214786, depMode=SHARED,
clsLdr=sun.misc.Launcher$AppClassLoader@18b4aac2,
clsLdrId=606b86fa561-cffc6951-7eef-4a58-82e1-69511458d650, userVer=0, loc=true,
sampleClsName=o.a.i.i.processors.cache.distributed.dht.preloader.GridDhtPartitionFullMap,
pendingUndeploy=false, undeployed=false, usage=1],
taskClsName=o.a.i.examples.ExampleNodeStartup3$1,
sesId=929f86fa561-3e2c91e1-1f47-401c-80a2-ea2b452a3cb5,
startTime=1536246223300, endTime=9223372036854775807,
taskNodeId=3e2c91e1-1f47-401c-80a2-ea2b452a3cb5,
clsLdr=sun.misc.Launcher$AppClassLoader@18b4aac2, closed=false, cpSpi=null,
failSpi=null, loadSpi=null, usage=1, fullSup=false, internal=false,
topPred=null, subjId=3e2c91e1-1f47-401c-80a2-ea2b452a3cb5, mapFut=IgniteFuture
[orig=GridFutureAdapter [ignoreInterrupts=false, state=INIT, res=null,
hash=30355072]], execName=null],
jobId=a29f86fa561-3e2c91e1-1f47-401c-80a2-ea2b452a3cb5]]
class org.apache.ignite.IgniteException: Failed partition reservation.
Partition is not primary on the node. [partition=1, cacheName=test,
nodeId=cffc6951-7eef-4a58-82e1-69511458d650, topology=AffinityTopologyVersion
[topVer=3, minorTopVer=0]]
at
org.apache.ignite.internal.processors.job.GridJobProcessor$PartitionsReservation.reserve(GridJobProcessor.java:1596)
at
org.apache.ignite.internal.processors.job.GridJobWorker.execute0(GridJobWorker.java:510)
at
org.apache.ignite.internal.processors.job.GridJobWorker.body(GridJobWorker.java:489)
at
org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110)
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)
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
