Update Rubix to 0.3.12

trinodb · Jun 25, 2020 · 8b7a6a9 · 8b7a6a9
1 parent 1785960
commit 8b7a6a9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 17 deletions.
diff --git a/pom.xml b/pom.xml
@@ -55,7 +55,7 @@
         <dep.tempto.version>179</dep.tempto.version>
         <dep.gcs.version>2.0.0</dep.gcs.version>
         <dep.errorprone.version>2.3.4</dep.errorprone.version>
-        <rubix.version>0.3.11</rubix.version>
+        <rubix.version>0.3.12</rubix.version>
 
         <!--
           America/Bahia_Banderas has:

diff --git a/presto-hive/src/test/java/io/prestosql/plugin/hive/rubix/CachingLocalFileSystem.java b/presto-hive/src/test/java/io/prestosql/plugin/hive/rubix/CachingLocalFileSystem.java
@@ -14,31 +14,18 @@
 package io.prestosql.plugin.hive.rubix;
 
 import com.qubole.rubix.core.CachingFileSystem;
-import com.qubole.rubix.core.ClusterManagerInitilizationException;
-import org.apache.hadoop.conf.Configuration;
+import com.qubole.rubix.spi.ClusterType;
 import org.apache.hadoop.fs.LocalFileSystem;
 
-import java.io.IOException;
-import java.net.URI;
-
-import static com.qubole.rubix.spi.ClusterType.PRESTOSQL_CLUSTER_MANAGER;
-
 public class CachingLocalFileSystem
         extends CachingFileSystem<LocalFileSystem>
 {
     private static final String SCHEME = "file";
 
     @Override
-    public void initialize(URI uri, Configuration conf)
-            throws IOException
+    public ClusterType getClusterType()
     {
-        try {
-            initializeClusterManager(conf, PRESTOSQL_CLUSTER_MANAGER);
-            super.initialize(uri, conf);
-        }
-        catch (ClusterManagerInitilizationException exception) {
-            throw new IOException(exception);
-        }
+        return ClusterType.PRESTOSQL_CLUSTER_MANAGER;
     }
 
     @Override