Add current open writers to error message in Iceberg

trinodb · Apr 30, 2024 · d8e5dcf · d8e5dcf
1 parent a0103b1
commit d8e5dcf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSink.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSink.java
@@ -380,7 +380,7 @@ private int[] getWriterIndexes(Page page)
         verify(writers.size() == pagePartitioner.getMaxIndex() + 1);
 
         if (currentOpenWriters > maxOpenWriters) {
-            throw new TrinoException(ICEBERG_TOO_MANY_OPEN_PARTITIONS, format("Exceeded limit of %s open writers for partitions", maxOpenWriters));
+            throw new TrinoException(ICEBERG_TOO_MANY_OPEN_PARTITIONS, format("Exceeded limit of %s open writers for partitions: %s", maxOpenWriters, currentOpenWriters));
         }
 
         return writerIndexes;