[Verifier] Add application-name config

presto-docs/src/main/sphinx/admin/verifier.rst

@@ -36,10 +36,16 @@ Next, create a ``config.properties`` file:
 
 .. code-block:: none
 
-    source-query.suite=my_suite
-    source-query.database=jdbc:mysql://localhost:3306/my_database?user=my_username&password=my_password
-    control.gateway=jdbc:presto://localhost:8080
-    test.gateway=jdbc:presto://localhost:8081
+    source-query.suites=suite
+    source-query.database=jdbc:mysql://localhost:3306/mydb?user=my_username&password=my_password
+    control.hosts=127.0.0.1
+    control.http-port=8080
+    control.jdbc-port=8080
+    control.application-name=verifier-test
+    test.hosts=127.0.0.1
+    test.http-port=8081
+    test.jdbc-port=8081
+    test.application-name=verifier-test
     test-id=1
 
 Download :maven_download:`verifier` and rename it to ``verifier``. To run the Verifier:
@@ -274,6 +280,7 @@ Name                                        Description
 ``control.query-timeout``                   The execution time limit of the control and the test queries.
 ``control.metadata-timeout``                The execution time limit of ``DESC`` queries and ``LIMIT 0`` queries.
 ``control.checksum-timeout``                The execution time limit of checksum queries.
+``control.application-name``                ApplicationName to be passed in ClientInfo. Can be used to set source.
 =========================================== ===============================================================================
 
 Determinism Analyzer Configuration

presto-verifier/src/main/java/com/facebook/presto/verifier/prestoaction/JdbcPrestoAction.java

@@ -64,6 +64,7 @@ public class JdbcPrestoAction
     private final Duration checksumTimeout;
     private final String testId;
     private final Optional<String> testName;
+    private final String applicationName;
 
     private final RetryDriver<QueryException> networkRetry;
     private final RetryDriver<QueryException> prestoRetry;
@@ -85,6 +86,7 @@ public JdbcPrestoAction(
 
         this.jdbcUrls = requireNonNull(cycle(prestoActionConfig.getJdbcUrls()), "jdbcUrls is null");
         this.queryTimeout = requireNonNull(prestoActionConfig.getQueryTimeout(), "queryTimeout is null");
+        this.applicationName = requireNonNull(prestoActionConfig.getApplicationName(), "applicationName is null");
         this.metadataTimeout = requireNonNull(metadataTimeout, "metadataTimeout is null");
         this.checksumTimeout = requireNonNull(checksumTimeout, "checksumTimeout is null");
         this.testId = requireNonNull(verifierConfig.getTestId(), "testId is null");
@@ -154,7 +156,7 @@ private PrestoConnection getConnection(QueryStage queryStage, String clientInfo)
                 .unwrap(PrestoConnection.class);
 
         try {
-            connection.setClientInfo("ApplicationName", "verifier-test");
+            connection.setClientInfo("ApplicationName", applicationName);
             connection.setClientInfo("ClientInfo", clientInfo);
             connection.setCatalog(queryConfiguration.getCatalog());
             connection.setSchema(queryConfiguration.getSchema());

presto-verifier/src/main/java/com/facebook/presto/verifier/prestoaction/PrestoActionConfig.java

@@ -44,6 +44,7 @@ public class PrestoActionConfig
     private Optional<Integer> httpPort = Optional.empty();
     private Map<String, String> jdbcUrlParameters = ImmutableMap.of();
     private Duration queryTimeout = new Duration(60, MINUTES);
+    private String applicationName = "verifier-test";
 
     @Override
     @NotNull
@@ -126,4 +127,17 @@ public PrestoActionConfig setQueryTimeout(Duration queryTimeout)
         this.queryTimeout = queryTimeout;
         return this;
     }
+
+    @NotNull
+    public String getApplicationName()
+    {
+        return applicationName;
+    }
+
+    @Config("application-name")
+    public PrestoActionConfig setApplicationName(String applicationName)
+    {
+        this.applicationName = applicationName;
+        return this;
+    }
 }

presto-verifier/src/test/java/com/facebook/presto/verifier/prestoaction/TestPrestoActionConfig.java

@@ -38,6 +38,7 @@ public void testDefault()
                 .setJdbcPort(0)
                 .setHttpPort(null)
                 .setJdbcUrlParameters(null)
+                .setApplicationName("verifier-test")
                 .setQueryTimeout(new Duration(60, MINUTES)));
     }
 
@@ -50,13 +51,15 @@ public void testExplicitPropertyMappings()
                 .put("http-port", "7777")
                 .put("jdbc-url-parameters", "{\"SSL\": false}")
                 .put("query-timeout", "2h")
+                .put("application-name", "verifier")
                 .build();
         PrestoActionConfig expected = new PrestoActionConfig()
                 .setHosts("proxy.presto.fbinfra.net")
                 .setJdbcPort(7778)
                 .setHttpPort(7777)
                 .setJdbcUrlParameters("{\"SSL\": false}")
-                .setQueryTimeout(new Duration(2, HOURS));
+                .setQueryTimeout(new Duration(2, HOURS))
+                .setApplicationName("verifier");
 
         assertFullMapping(properties, expected);
     }