CODAIT#209 fix + checkstyle fix

avshalomman · Jun 27, 2019 · 12f9ffa · 12f9ffa
1 parent 048d7e6
commit 12f9ffa
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/ibm/stocator/fs/cos/COSAPIClient.java b/src/main/java/com/ibm/stocator/fs/cos/COSAPIClient.java
@@ -34,6 +34,7 @@
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.Date;
@@ -254,7 +255,7 @@ public COSAPIClient(URI pFilesystemURI, Configuration pConf) throws IOException
 
   @Override
   public void initiate(String scheme) throws IOException, ConfigurationParseException {
-    mCachedSparkOriginated = new HashMap<String, Boolean>();
+    mCachedSparkOriginated = new ConcurrentHashMap<String, Boolean>();
     mCachedSparkJobsStatus = new HashMap<String, Boolean>();
     schemaProvided = scheme;
     Properties props = ConfigurationHandler.initialize(filesystemURI, conf, scheme);