Github user parthchandra commented on a diff in the pull request:
https://github.com/apache/drill/pull/1041#discussion_r155396889
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/work/WorkManager.java ---
@@ -277,7 +277,9 @@ public void startFragmentPendingRemote(final
FragmentManager fragmentManager) {
@Override
protected void cleanup() {
runningFragments.remove(fragmentHandle);
- workBus.removeFragmentManager(fragmentHandle);
+ if (!fragmentManager.isCancelled()) {
+ workBus.removeFragmentManager(fragmentHandle, false);
--- End diff --
Not sure why you don't want to cancel here.
---
