Github user danny0405 commented on the issue:
https://github.com/apache/storm/pull/2517
@HeartSaVioR
During the cluster tests i also fond a bug for blob-store:
When we kill a topology, at the moment of topology blob-files be removed,
Supervisor executor still request blob-files and get an KeyNotFoundException,
this is the partial of Supervisor log:
```xml
2017-11-21 17:32:00.435 o.a.s.d.s.Slot SLOT_9703 [INFO] SLOT 9703: Changing
current assignment from
LocalAssignment(topology_id:word_count_fk_iii-3-1511256346,
executors:[ExecutorInfo(task_start:7, task_end:7), ExecutorInfo(task_start:5,
task_end:5), ExecutorInfo(task_start:3, task_end:3), ExecutorInfo(task_start:1,
task_end:1)], resources:WorkerResources(mem_on_heap:512.0, mem_off_heap:0.0,
cpu:40.0, shared_mem_on_heap:0.0, shared_mem_off_heap:0.0,
resources:{offheap.memory.mb=0.0, onheap.memory.mb=512.0,
cpu.pcore.percent=40.0}, shared_resources:{}), owner:sankuai) to null
2017-11-21 17:32:10.520 o.a.s.l.AsyncLocalizer AsyncLocalizer Executor - 3
[WARN] Failed to download blob LOCAL TOPO BLOB TOPO_CODE
word_count_fk_iii-3-1511256346 will try again in 100 ms
org.apache.storm.generated.KeyNotFoundException: null
at
org.apache.storm.generated.Nimbus$getBlobMeta_result$getBlobMeta_resultStandardScheme.read(Nimbus.java:24935)
~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at
org.apache.storm.generated.Nimbus$getBlobMeta_result$getBlobMeta_resultStandardScheme.read(Nimbus.java:24903)
~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at
org.apache.storm.generated.Nimbus$getBlobMeta_result.read(Nimbus.java:24834)
~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:86)
~[libthrift-0.9.3.jar:0.9.3]
at
org.apache.storm.generated.Nimbus$Client.recv_getBlobMeta(Nimbus.java:812)
~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at
org.apache.storm.generated.Nimbus$Client.getBlobMeta(Nimbus.java:799)
~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at
org.apache.storm.blobstore.NimbusBlobStore.getBlobMeta(NimbusBlobStore.java:306)
~[storm-client-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at
org.apache.storm.localizer.LocallyCachedTopologyBlob.getRemoteVersion(LocallyCachedTopologyBlob.java:176)
~[storm-server-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at
org.apache.storm.localizer.AsyncLocalizer.lambda$downloadOrUpdate$5(AsyncLocalizer.java:249)
~[storm-server-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1626)
[?:1.8.0_151]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_151]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[?:1.8.0_151]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
[?:1.8.0_151]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
[?:1.8.0_151]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_151]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_151]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_151]
```
I thought of maybe this bug is revised by this patch, then i switch to
master branch and have several tests, this bug can happens every time, so this
bug has no business with this path.
I will fire a bug report issue then.
---
