Avoid using S3 multipart upload for a single part

presto-hive/src/main/java/io/prestosql/plugin/hive/HiveQlToPrestoTranslator.java

@@ -23,7 +23,7 @@
 
 /**
  * Translate statements in Hive QL to Presto SQL.
- *
+ * <p>
  * Only translation of quoted literals is currently included.
  */
 public final class HiveQlToPrestoTranslator

presto-hive/src/main/java/io/prestosql/plugin/hive/ReaderColumns.java

@@ -23,9 +23,9 @@
 
 /**
  * Stores a mapping between
- *  - the projected columns required by a connector level pagesource and
- *  -  the columns supplied by format-specific page source
- *
+ * - the projected columns required by a connector level pagesource and
+ * -  the columns supplied by format-specific page source
+ * <p>
  * Currently used in {@link HivePageSource}.
  */
 public class ReaderColumns

presto-hive/src/test/java/io/prestosql/plugin/hive/TestHiveQlTranslation.java

@@ -104,7 +104,9 @@ public class TestHiveQlTranslation
                             "'double: two singles'''''")
                     .build();
 
-    /** Prepare all combinations of {@code n} of the given columns. */
+    /**
+     * Prepare all combinations of {@code n} of the given columns.
+     */
     private static Iterator<Object[]> getNColumns(int n, Map<String, String> columns)
     {
         Stream<String> hiveNames =
@@ -115,7 +117,7 @@ private static Iterator<Object[]> getNColumns(int n, Map<String, String> columns
                 Lists.cartesianProduct(nCopies(n, List.copyOf(columns.values()))).stream()
                         .map(names -> join(", ", names));
 
-        return Streams.zip(hiveNames, prestoNames, (h, p) -> new Object[]{h, p}).iterator();
+        return Streams.zip(hiveNames, prestoNames, (h, p) -> new Object[] {h, p}).iterator();
     }
 
     @DataProvider(name = "simple_hive_translation_columns")

presto-hive/src/test/java/io/prestosql/plugin/hive/TestNodeLocalDynamicSplitPruning.java

@@ -163,7 +163,8 @@ private static TestingConnectorSession getSession(HiveConfig config)
 
     private static DynamicFilter getDynamicFilter(TupleDomain<ColumnHandle> tupleDomain)
     {
-        return new DynamicFilter() {
+        return new DynamicFilter()
+        {
             @Override
             public CompletableFuture<?> isBlocked()
             {

presto-hive/src/test/java/io/prestosql/plugin/hive/metastore/TestRecordingHiveMetastore.java

@@ -119,8 +119,8 @@ public class TestRecordingHiveMetastore
     private static final List<String> PARTITION_COLUMN_NAMES = ImmutableList.of(TABLE_COLUMN.getName());
     private static final Domain PARTITION_COLUMN_EQUAL_DOMAIN = Domain.singleValue(createUnboundedVarcharType(), Slices.utf8Slice("value1"));
     private static final TupleDomain<String> TUPLE_DOMAIN = TupleDomain.withColumnDomains(ImmutableMap.<String, Domain>builder()
-                .put(TABLE_COLUMN.getName(), PARTITION_COLUMN_EQUAL_DOMAIN)
-                .build());
+            .put(TABLE_COLUMN.getName(), PARTITION_COLUMN_EQUAL_DOMAIN)
+            .build());
 
     @Test
     public void testRecordingHiveMetastore()

presto-hive/src/test/java/io/prestosql/plugin/hive/metastore/TestSemiTransactionalHiveMetastore.java

@@ -131,17 +131,17 @@ public Optional<Table> getTable(HiveIdentity identity, String databaseName, Stri
         {
             if (databaseName.equals("database")) {
                 return Optional.of(new Table(
-                    "database",
-                    tableName,
-                    "owner",
-                    "table_type",
-                    TABLE_STORAGE,
-                    ImmutableList.of(TABLE_COLUMN),
-                    ImmutableList.of(TABLE_COLUMN),
-                    ImmutableMap.of("param", "value3"),
-                    Optional.of("original_text"),
-                    Optional.of("expanded_text"),
-                    OptionalLong.empty()));
+                        "database",
+                        tableName,
+                        "owner",
+                        "table_type",
+                        TABLE_STORAGE,
+                        ImmutableList.of(TABLE_COLUMN),
+                        ImmutableList.of(TABLE_COLUMN),
+                        ImmutableMap.of("param", "value3"),
+                        Optional.of("original_text"),
+                        Optional.of("expanded_text"),
+                        OptionalLong.empty()));
             }
             return Optional.empty();
         }

presto-hive/src/test/java/io/prestosql/plugin/hive/util/TestHiveBucketing.java

@@ -140,7 +140,7 @@ public void testHashingCompare()
         for (BucketingVersion version : BucketingVersion.values()) {
             List<TypeInfo> typeInfos = ImmutableList.of(timestampTypeInfo);
 
-            assertThatThrownBy(() -> version.getBucketHashCode(typeInfos, new Object[]{0}))
+            assertThatThrownBy(() -> version.getBucketHashCode(typeInfos, new Object[] {0}))
                     .hasMessage("Computation of Hive bucket hashCode is not supported for Hive primitive category: TIMESTAMP");
 
             TimestampType timestampType = createTimestampType(3);

presto-parquet/src/main/java/io/prestosql/parquet/writer/ParquetWriter.java

@@ -176,11 +176,12 @@ public void close()
             return;
         }
         closed = true;
-        columnWriters.forEach(ColumnWriter::close);
 
-        flush();
-        writeFooter();
-        outputStream.close();
+        try (outputStream) {
+            columnWriters.forEach(ColumnWriter::close);
+            flush();
+            writeFooter();
+        }
     }
 
     // Parquet File Layout: