From 59c3befcf958a3819ff31bf0e94a2ec1c7399f50 Mon Sep 17 00:00:00 2001
From: "Mateusz \"Serafin\" Gajewski" <github@wendigo.pl>
Date: Thu, 31 Oct 2024 15:20:34 +0100
Subject: [PATCH] Do not use stream to create TypeDecoders

---
 .../src/main/java/io/trino/client/JsonDecodingUtils.java  | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/client/trino-client/src/main/java/io/trino/client/JsonDecodingUtils.java b/client/trino-client/src/main/java/io/trino/client/JsonDecodingUtils.java
index c6435503817b..cdba01c9ff97 100644
--- a/client/trino-client/src/main/java/io/trino/client/JsonDecodingUtils.java
+++ b/client/trino-client/src/main/java/io/trino/client/JsonDecodingUtils.java
@@ -76,9 +76,11 @@ private JsonDecodingUtils() {}
     public static TypeDecoder[] createTypeDecoders(List<Column> columns)
     {
         verify(!columns.isEmpty(), "Columns must not be empty");
-        return columns.stream()
-                .map(column -> createTypeDecoder(column.getTypeSignature()))
-                .toArray(TypeDecoder[]::new);
+        TypeDecoder[] decoders = new TypeDecoder[columns.size()];
+        for (int i = 0; i < columns.size(); i++) {
+            decoders[i] = createTypeDecoder(columns.get(i).getTypeSignature());
+        }
+        return decoders;
     }
 
     public interface TypeDecoder