drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From s..@apache.org
Subject drill git commit: DRILL-3522: Fix for sporadic Mongo errors
Date Fri, 22 Apr 2016 00:20:03 GMT
Repository: drill
Updated Branches:
  refs/heads/master d93a36338 -> a07f4de7e


DRILL-3522: Fix for sporadic Mongo errors


Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/a07f4de7
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/a07f4de7
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/a07f4de7

Branch: refs/heads/master
Commit: a07f4de7e8725f7971ace308e81a241b7b07b5b6
Parents: d93a363
Author: Adam <adam@tipihq.com>
Authored: Tue Jul 21 12:44:21 2015 +1000
Committer: Steven Phillips <steven@dremio.com>
Committed: Thu Apr 21 17:19:19 2016 -0700

----------------------------------------------------------------------
 .../drill/exec/store/mongo/schema/MongoSchemaFactory.java      | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/a07f4de7/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/schema/MongoSchemaFactory.java
----------------------------------------------------------------------
diff --git a/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/schema/MongoSchemaFactory.java
b/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/schema/MongoSchemaFactory.java
index 9d08abd..be212de 100644
--- a/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/schema/MongoSchemaFactory.java
+++ b/contrib/storage-mongo/src/main/java/org/apache/drill/exec/store/mongo/schema/MongoSchemaFactory.java
@@ -61,12 +61,10 @@ public class MongoSchemaFactory implements SchemaFactory {
   private LoadingCache<String, List<String>> tableNameLoader;
   private final String schemaName;
   private final MongoStoragePlugin plugin;
-  private final MongoClient client;
 
   public MongoSchemaFactory(MongoStoragePlugin plugin, String schemaName) throws ExecutionSetupException
{
     this.plugin = plugin;
     this.schemaName = schemaName;
-    this.client = plugin.getClient();
 
     databases = CacheBuilder //
         .newBuilder() //
@@ -88,7 +86,7 @@ public class MongoSchemaFactory implements SchemaFactory {
       }
       try {
         List<String> dbNames = new ArrayList<>();
-        client.listDatabaseNames().into(dbNames);
+        plugin.getClient().listDatabaseNames().into(dbNames);
         return dbNames;
       } catch (MongoException me) {
         logger.warn("Failure while loading databases in Mongo. {}",
@@ -106,7 +104,7 @@ public class MongoSchemaFactory implements SchemaFactory {
     @Override
     public List<String> load(String dbName) throws Exception {
       try {
-        MongoDatabase db = client.getDatabase(dbName);
+        MongoDatabase db = plugin.getClient().getDatabase(dbName);
         List<String> collectionNames = new ArrayList<>();
         db.listCollectionNames().into(collectionNames);
         return collectionNames;


Mime
View raw message