From e8392edc9806fea6748cae6c70c692d197e21cc3 Mon Sep 17 00:00:00 2001
From: Jing-Wei <jinlu@linkedin.com>
Date: Tue, 2 May 2023 15:26:45 -0700
Subject: [PATCH] Bump Trino dependency version to 414

---
 defaultEnvironment.gradle                                     | 2 +-
 transportable-udfs-plugin/build.gradle                        | 2 +-
 .../java/com/linkedin/transport/test/trino/TrinoTester.java   | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/defaultEnvironment.gradle b/defaultEnvironment.gradle
index 8771dee2..6dc383c6 100644
--- a/defaultEnvironment.gradle
+++ b/defaultEnvironment.gradle
@@ -7,7 +7,7 @@ subprojects {
     mavenCentral()
     jcenter()
   }
-  project.ext.setProperty('trino-version', '406')
+  project.ext.setProperty('trino-version', '414')
   project.ext.setProperty('airlift-slice-version', '0.44')
   project.ext.setProperty('spark-group', 'org.apache.spark')
   project.ext.setProperty('spark2-version', '2.3.0')
diff --git a/transportable-udfs-plugin/build.gradle b/transportable-udfs-plugin/build.gradle
index cd6370c6..1494b25b 100644
--- a/transportable-udfs-plugin/build.gradle
+++ b/transportable-udfs-plugin/build.gradle
@@ -19,7 +19,7 @@ def writeVersionInfo = { file ->
   ant.propertyfile(file: file) {
     entry(key: "transport-version", value: version)
     entry(key: "hive-version", value: '1.2.2')
-    entry(key: "trino-version", value: '406')
+    entry(key: "trino-version", value: '414')
     entry(key: "spark_2.11-version", value: '2.3.0')
     entry(key: "spark_2.12-version", value: '3.1.1')
     entry(key: "scala-version", value: '2.11.8')
diff --git a/transportable-udfs-test/transportable-udfs-test-trino/src/main/java/com/linkedin/transport/test/trino/TrinoTester.java b/transportable-udfs-test/transportable-udfs-test-trino/src/main/java/com/linkedin/transport/test/trino/TrinoTester.java
index 3c188360..099f4d10 100644
--- a/transportable-udfs-test/transportable-udfs-test-trino/src/main/java/com/linkedin/transport/test/trino/TrinoTester.java
+++ b/transportable-udfs-test/transportable-udfs-test-trino/src/main/java/com/linkedin/transport/test/trino/TrinoTester.java
@@ -65,7 +65,7 @@ public TrinoTester() {
     _stdFactory = null;
     _sqlFunctionCallGenerator = new TrinoSqlFunctionCallGenerator();
     _toPlatformTestOutputConverter = new ToTrinoTestOutputConverter();
-    SqlPath sqlPath = new SqlPath("LINKEDIN.TRANSPORT");
+    SqlPath sqlPath = new SqlPath("LINKEDIN.transport");
     _session = TestingSession.testSessionBuilder().setPath(sqlPath).setClientCapabilities((Set) Arrays.stream(
         ClientCapabilities.values()).map(Enum::toString).collect(ImmutableSet.toImmutableSet())).build();
     _featuresConfig = new FeaturesConfig();
@@ -90,7 +90,7 @@ public void setup(
     ConnectorFactory connectorFactory = new ConnectorFactory() {
       @Override
       public String getName() {
-        return "TRANSPORT";
+        return "transport";
       }
       @Override
       public Connector create(String catalogName, Map<String, String> config, ConnectorContext context) {