[native] Add native-execution-enabled flag to NativeQueryRunnerUtils.…

…getNativeWorkerSystemProperties NativeQueryRunnerUtils.getNativeWorkerSystemProperties is an authoritative set of native worker system config that are used by several parties when setting up their clusters. This property was set in the calling QueryRunner invocations instead leading to some confusion.
prestodb · Nov 6, 2023 · 16970a0 · 16970a0
1 parent f0bd6a5
commit 16970a0
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 2 deletions.
diff --git a/...tive-execution/src/test/java/com/facebook/presto/nativeworker/NativeQueryRunnerUtils.java b/...tive-execution/src/test/java/com/facebook/presto/nativeworker/NativeQueryRunnerUtils.java
@@ -33,6 +33,7 @@ public static Map<String, String> getNativeWorkerHiveProperties(String storageFo
     public static Map<String, String> getNativeWorkerSystemProperties()
     {
         return ImmutableMap.<String, String>builder()
+                .put("native-execution-enabled", "true")
                 .put("optimizer.optimize-hash-generation", "false")
                 .put("parse-decimal-literals-as-double", "true")
                 .put("regex-library", "RE2J")

diff --git a/...xecution/src/test/java/com/facebook/presto/nativeworker/PrestoNativeQueryRunnerUtils.java b/...xecution/src/test/java/com/facebook/presto/nativeworker/PrestoNativeQueryRunnerUtils.java
@@ -158,7 +158,6 @@ public static QueryRunner createNativeQueryRunner(
                 ImmutableMap.<String, String>builder()
                         .put("http-server.http.port", "8080")
                         .put("experimental.internal-communication.thrift-transport-enabled", String.valueOf(useThrift))
-                        .put("native-execution-enabled", "true")
                         .putAll(getNativeWorkerSystemProperties())
                         .build(),
                 ImmutableMap.of(),

diff --git a/...-execution/src/test/java/com/facebook/presto/spark/PrestoSparkNativeQueryRunnerUtils.java b/...-execution/src/test/java/com/facebook/presto/spark/PrestoSparkNativeQueryRunnerUtils.java
@@ -81,7 +81,6 @@ public static Map<String, String> getNativeExecutionSessionConfigs()
                 // Do not use default Prestissimo config files. Presto-Spark will generate the configs on-the-fly.
                 .put("catalog.config-dir", "/")
                 .put("task.info-update-interval", "100ms")
-                .put("native-execution-enabled", "true")
                 .put("spark.initial-partition-count", "1")
                 .put("register-test-functions", "true")
                 .put("native-execution-program-arguments", "--logtostderr=1 --minloglevel=3")