diff --git a/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/dstore/universal/miners/UniversalFileSystemMiner.java b/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/dstore/universal/miners/UniversalFileSystemMiner.java
index 3d25c4d7097..9200c829f44 100644
--- a/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/dstore/universal/miners/UniversalFileSystemMiner.java
+++ b/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/dstore/universal/miners/UniversalFileSystemMiner.java
@@ -455,12 +455,12 @@ public class UniversalFileSystemMiner extends Miner {
 		{
 			while (iter.hasNext())
 			{
-				String threadName = (String) iter.next();
-				ICancellableHandler theThread = (ICancellableHandler) _cancellableThreads.get(threadName);
+				DataElement threadElement = (DataElement) iter.next();
+				ICancellableHandler theThread = (ICancellableHandler) _cancellableThreads.get(threadElement);
 				if ((theThread == null) ||
 						theThread.isDone() || theThread.isCancelled())
 				{
-					_cancellableThreads.remove(threadName);
+					_cancellableThreads.remove(threadElement);
 				}
 			}
 		}