diff --git a/plugin/trino-hive/src/test/java/io/trino/plugin/hive/TestHiveMinioQueryFailureRecoveryTest.java b/plugin/trino-hive/src/test/java/io/trino/plugin/hive/TestHiveMinioQueryFailureRecoveryTest.java index b354b508c1df..f93f27bfd8d2 100644 --- a/plugin/trino-hive/src/test/java/io/trino/plugin/hive/TestHiveMinioQueryFailureRecoveryTest.java +++ b/plugin/trino-hive/src/test/java/io/trino/plugin/hive/TestHiveMinioQueryFailureRecoveryTest.java @@ -50,6 +50,12 @@ protected QueryRunner createQueryRunner(List> requiredTpchTables, M .setInitialTables(requiredTpchTables) .setExtraProperties(configProperties) .setCoordinatorProperties(coordinatorProperties) + .setHiveProperties(ImmutableMap.builder() + // Streaming upload allocates non trivial amount of memory for buffering (16MB per output file by default). + // When streaming upload is enabled insert into a table with high number of buckets / partitions may cause + // the tests to run out of memory as the buffer space is eagerly allocated for each output file. + .put("hive.s3.streaming.enabled", "false") + .build()) .build(); }