Move 'Error committing write to Hive' retry to Trino query executor

trinodb · Jan 28, 2021 · f40d2fa · f40d2fa
1 parent c2fbe7e
commit f40d2fa
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/testing/trino-product-tests/src/main/java/io/trino/tests/utils/QueryExecutors.java b/testing/trino-product-tests/src/main/java/io/trino/tests/utils/QueryExecutors.java
@@ -27,19 +27,14 @@ public final class QueryExecutors
 {
     public static QueryExecutor onPresto()
     {
-        return testContext().getDependency(QueryExecutor.class, "presto");
+        return connectToPresto("presto");
     }
 
     public static QueryExecutor connectToPresto(String prestoConfig)
-    {
-        return testContext().getDependency(QueryExecutor.class, prestoConfig);
-    }
-
-    public static QueryExecutor onHive()
     {
         return new QueryExecutor()
         {
-            private final QueryExecutor delegate = testContext().getDependency(QueryExecutor.class, "hive");
+            private final QueryExecutor delegate = testContext().getDependency(QueryExecutor.class, prestoConfig);
 
             @Override
             public QueryResult executeQuery(String sql, QueryParam... params)
@@ -63,6 +58,11 @@ public void close()
         };
     }
 
+    public static QueryExecutor onHive()
+    {
+        return testContext().getDependency(QueryExecutor.class, "hive");
+    }
+
     public static QueryExecutor onSqlServer()
     {
         return testContext().getDependency(QueryExecutor.class, "sqlserver");