Add added_snapshot_id column to Iceberg $files table

Author: kaveti

.github/actions/process-test-results/action.yml

@@ -58,7 +58,7 @@ runs:
       # don't create or update checks, only annotate current job
       skip_publishing: true
   - name: Process Product Test reports
-    uses: starburstdata/action-testng-report@d139fdb2941218d327f5ce0ad8fd85b65d9f9ce3
+    uses: starburstdata/action-testng-report@f245422953fb97ec5075d07782a1b596124b7cc4
     if: format('{0}', inputs.has-failed-tests) == 'true'
     with:
       # this workflow should never fail, as it is not a quality gateway

.github/bin/redshift/setup-aws-redshift.sh

@@ -43,7 +43,7 @@ echo "Waiting for the Amazon Redshift cluster ${REDSHIFT_CLUSTER_IDENTIFIER} on
 aws redshift wait cluster-available \
   --cluster-identifier ${REDSHIFT_CLUSTER_IDENTIFIER}
 
-echo "The Amazon Redshift cluster ${REDSHIFT_CLUSTER_IDENTIFIER} on the region ${AWS_REGION} reports available status."
+echo "The Amazon Redshift cluster ${REDSHIFT_CLUSTER_IDENTIFIER} on the region ${AWS_REGION} is available for queries."
 
 REDSHIFT_CLUSTER_DESCRIPTION=$(aws redshift describe-clusters --cluster-identifier ${REDSHIFT_CLUSTER_IDENTIFIER})
 
@@ -52,21 +52,3 @@ export REDSHIFT_PORT=$(echo ${REDSHIFT_CLUSTER_DESCRIPTION} | jq -r '.Clusters[0
 export REDSHIFT_CLUSTER_DATABASE_NAME=$(echo ${REDSHIFT_CLUSTER_DESCRIPTION} | jq -r '.Clusters[0].DBName' )
 export REDSHIFT_USER=$(echo ${REDSHIFT_CLUSTER_DESCRIPTION} | jq -r '.Clusters[0].MasterUsername' )
 export REDSHIFT_PASSWORD
-
-# The AWS API status "available" doesn't guarantee the endpoint is accepting connections yet.
-# Poll the actual TCP port until Redshift is truly ready.
-echo "Waiting for the Redshift endpoint ${REDSHIFT_ENDPOINT}:${REDSHIFT_PORT} to accept connections..."
-MAX_RETRIES=30
-RETRY_INTERVAL_SECONDS=10
-for ((i=1; i<=MAX_RETRIES; i++)); do
-    if nc -z -w 5 "${REDSHIFT_ENDPOINT}" "${REDSHIFT_PORT}" 2>/dev/null; then
-        echo "The Amazon Redshift cluster ${REDSHIFT_CLUSTER_IDENTIFIER} on the region ${AWS_REGION} is accepting connections."
-        break
-    fi
-    if [ "$i" -eq "$MAX_RETRIES" ]; then
-        echo "ERROR: Redshift endpoint ${REDSHIFT_ENDPOINT}:${REDSHIFT_PORT} did not become reachable after $((MAX_RETRIES * RETRY_INTERVAL_SECONDS)) seconds."
-        exit 1
-    fi
-    echo "  Attempt ${i}/${MAX_RETRIES}: endpoint not ready yet, retrying in ${RETRY_INTERVAL_SECONDS}s..."
-    sleep ${RETRY_INTERVAL_SECONDS}
-done

.github/bin/s3/setup-empty-s3-bucket.sh

@@ -44,17 +44,3 @@ echo "Tagging the AWS S3 bucket ${S3_BUCKET_IDENTIFIER} with TTL tags"
 aws s3api put-bucket-tagging \
   --bucket "${S3_BUCKET_IDENTIFIER}" \
   --tagging "TagSet=[{Key=environment,Value=test},{Key=ttl,Value=${S3_BUCKET_TTL}}]"
-
-echo "Allowing SSE-C encryption for the AWS S3 bucket ${S3_BUCKET_IDENTIFIER}"
-
-# Since April 2026, AWS S3 blocks SSE-C (Server-Side Encryption with Customer-provided keys)
-# by default on new buckets. Unblock it by setting BlockedEncryptionTypes to an empty list.
-aws s3api put-bucket-encryption \
-  --bucket "${S3_BUCKET_IDENTIFIER}" \
-  --server-side-encryption-configuration '{
-    "Rules": [{
-      "BlockedEncryptionTypes": {
-        "EncryptionType": ["NONE"]
-      }
-    }]
-  }'

.github/workflows/ci.yml

@@ -71,7 +71,7 @@ jobs:
       matrix:
         include:
           - { java-version: 25.0.2, cache: 'true', cleanup-node: true }
-          - { java-version: 26, cache: 'restore', cleanup-node: true }
+          - { java-version: 26-ea, cache: 'restore', cleanup-node: true }
           - { java-version: 27-ea, cache: 'restore', cleanup-node: true }
     timeout-minutes: 45
     steps:
@@ -486,7 +486,6 @@ jobs:
             - { modules: plugin/trino-druid }
             - { modules: plugin/trino-duckdb }
             - { modules: plugin/trino-elasticsearch }
-            - { modules: plugin/trino-exchange-filesystem, profile: cloud-tests }
             - { modules: plugin/trino-exasol }
             - { modules: plugin/trino-google-sheets }
             - { modules: plugin/trino-hive }
@@ -561,7 +560,6 @@ jobs:
           && ! (contains(matrix.modules, 'trino-redshift') && contains(matrix.profile, 'cloud-tests'))
           && ! (contains(matrix.modules, 'trino-redshift') && contains(matrix.profile, 'fte-tests'))
           && ! (contains(matrix.modules, 'trino-snowflake') && contains(matrix.profile, 'cloud-tests'))
-          && ! (contains(matrix.modules, 'trino-exchange-filesystem') && contains(matrix.profile, 'cloud-tests'))
           && ! (contains(matrix.modules, 'trino-filesystem-azure') && contains(matrix.profile, 'cloud-tests'))
           && ! (contains(matrix.modules, 'trino-filesystem-gcs') && contains(matrix.profile, 'cloud-tests'))
           && ! (contains(matrix.modules, 'trino-filesystem-s3') && contains(matrix.profile, 'cloud-tests'))
@@ -572,18 +570,6 @@ jobs:
         if: contains(matrix.modules, 'trino-hdfs')
         run: |
           $MAVEN test ${MAVEN_TEST} -pl :trino-hdfs -P test-isolated-jvm-suites
-      - name: FileSystem Exchange Storage Cloud Tests
-        id: tests-filesystem-exchange
-        env:
-          ABFS_FLAT_ACCOUNT: ${{ vars.AZURE_ABFS_FLAT_ACCOUNT }}
-          ABFS_FLAT_ACCESS_KEY: ${{ secrets.AZURE_ABFS_FLAT_ACCESS_KEY }}
-          ABFS_HIERARCHICAL_ACCOUNT: ${{ vars.AZURE_ABFS_HIERARCHICAL_ACCOUNT }}
-          ABFS_HIERARCHICAL_ACCESS_KEY: ${{ secrets.AZURE_ABFS_HIERARCHICAL_ACCESS_KEY }}
-        if: >-
-          contains(matrix.modules, 'trino-exchange-filesystem') && contains(matrix.profile, 'cloud-tests') &&
-          (env.CI_SKIP_SECRETS_PRESENCE_CHECKS != '' || env.ABFS_FLAT_ACCESS_KEY != '' || env.ABFS_HIERARCHICAL_ACCESS_KEY != '')
-        run: |
-          $MAVEN test ${MAVEN_TEST} -pl ${{ matrix.modules }} ${{ format('-P {0}', matrix.profile) }}
       - name: S3 FileSystem Cloud Tests
         id: tests-s3
         env:
@@ -803,7 +789,6 @@ jobs:
               || steps.tests-hdfs-isolated.outcome == 'failure'
               || steps.tests-s3.outcome == 'failure'
               || steps.tests-azure.outcome == 'failure'
-              || steps.tests-filesystem-exchange.outcome == 'failure'
               || steps.tests-gcs.outcome == 'failure'
               || steps.tests-delta.outcome == 'failure'
               || steps.tests-bq.outcome == 'failure'

.gitignore

@@ -34,4 +34,3 @@ product-test-reports
 **/dependency-reduced-pom.xml
 core/trino-web-ui/src/main/resources/webapp/dist/
 .node
-.claude

client/trino-cli/pom.xml

@@ -16,7 +16,7 @@
     <properties>
         <project.build.targetJdk>11</project.build.targetJdk>
         <main-class>io.trino.cli.Trino</main-class>
-        <dep.jline.version>4.0.12</dep.jline.version>
+        <dep.jline.version>4.0.9</dep.jline.version>
     </properties>
 
     <dependencies>

client/trino-cli/src/main/java/io/trino/cli/TableNameCompleter.java

@@ -29,10 +29,10 @@
 import java.util.List;
 import java.util.Optional;
 import java.util.concurrent.ExecutorService;
+import java.util.concurrent.TimeUnit;
 
 import static com.google.common.cache.CacheLoader.asyncReloading;
 import static java.lang.String.format;
-import static java.time.Duration.ofMinutes;
 import static java.util.Objects.requireNonNull;
 import static java.util.concurrent.Executors.newCachedThreadPool;
 
@@ -54,7 +54,7 @@ public TableNameCompleter(QueryRunner queryRunner)
 
         tableCache = buildUnsafeCache(
                 CacheBuilder.newBuilder()
-                        .refreshAfterWrite(ofMinutes(RELOAD_TIME_MINUTES)),
+                        .refreshAfterWrite(RELOAD_TIME_MINUTES, TimeUnit.MINUTES),
                 asyncReloading(CacheLoader.from(this::listTables), executor));
 
         functionCache = buildUnsafeCache(

client/trino-jdbc/src/test/java/io/trino/jdbc/TestJdbcConnection.java

@@ -330,10 +330,6 @@ public void testSession()
                 statement.execute("SET SESSION join_distribution_type = 'BROADCAST'");
             }
 
-            try (Statement statement = connection.createStatement()) {
-                statement.execute("EXECUTE IMMEDIATE 'SET SESSION join_distribution_type = ?' USING 'BROADCAST'");
-            }
-
             assertThat(listSession(connection))
                     .contains("join_distribution_type|BROADCAST|AUTOMATIC")
                     .contains("exchange_compression_codec|NONE|NONE");

core/trino-grammar/src/main/antlr4/io/trino/grammar/sql/SqlBase.g4

@@ -204,7 +204,6 @@ statement
     | EXECUTE IMMEDIATE string (USING expression (',' expression)*)?   #executeImmediate
     | DESCRIBE INPUT identifier                                        #describeInput
     | DESCRIBE OUTPUT identifier                                       #describeOutput
-    | DESCRIBE OUTPUT '(' rootQuery ')'                                #describeQueryOutput
     | SET PATH pathSpecification                                       #setPath
     | SET TIME ZONE (LOCAL | expression)                               #setTimeZone
     | UPDATE qualifiedName ('@' branch=identifier)?
@@ -482,10 +481,6 @@ relationPrimary
         )?
         ((ERROR | EMPTY) ON ERROR)?
       ')'                                                             #jsonTable
-    | NEAREST '('
-        FROM relation
-        (WHERE where=booleanExpression)?
-        MATCH match=booleanExpression ')'                             #nearest
     ;
 
 jsonTableColumn
@@ -1057,7 +1052,7 @@ nonReserved
     | KEEP | KEY | KEYS
     | LANGUAGE | LAST | LATERAL | LEADING | LEAVE | LEVEL | LIMIT | LOCAL | LOGICAL | LOOP
     | MAP | MATCH | MATCHED | MATCHES | MATCH_RECOGNIZE | MATERIALIZED | MEASURES | MERGE | MINUTE | MONTH
-    | NESTED | NEXT | NFC | NFD | NEAREST | NFKC | NFKD | NO | NONE | NULLIF | NULLS
+    | NESTED | NEXT | NFC | NFD | NFKC | NFKD | NO | NONE | NULLIF | NULLS
     | OBJECT | OF | OFFSET | OMIT | ONE | ONLY | OPTION | ORDINALITY | OUTPUT | OVER | OVERFLOW
     | PARTITION | PARTITIONS | PASSING | PAST | PATH | PATTERN | PER | PERIOD | PERMUTE | PLAN | POSITION | PRECEDING | PRECISION | PRIVILEGES | PROPERTIES | PRUNE
     | QUOTES
@@ -1237,7 +1232,6 @@ MONTH: 'MONTH';
 NATURAL: 'NATURAL';
 NESTED: 'NESTED';
 NEXT: 'NEXT';
-NEAREST: 'NEAREST';
 NFC : 'NFC';
 NFD : 'NFD';
 NFKC : 'NFKC';

core/trino-grammar/src/test/java/io/trino/grammar/sql/TestSqlKeywords.java

@@ -190,7 +190,6 @@ public void test()
                         "MONTH",
                         "NATURAL",
                         "NESTED",
-                        "NEAREST",
                         "NEXT",
                         "NFC",
                         "NFD",