diff --git a/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ArrowReader.java b/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ArrowReader.java index 8869da40fd56..4b87302a55a7 100644 --- a/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ArrowReader.java +++ b/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/ArrowReader.java @@ -268,6 +268,7 @@ private static final class VectorizedCombinedScanIterator implements CloseableIt .map(entry -> EncryptedFiles.encryptedInput(io.newInputFile(entry.getKey()), entry.getValue())); // decrypt with the batch call to avoid multiple RPCs to a key server, if possible + @SuppressWarnings("StreamToIterable") Iterable decryptedFiles = encryptionManager.decrypt(encrypted::iterator); Map files = Maps.newHashMapWithExpectedSize(fileTasks.size()); diff --git a/aws/src/integration/java/org/apache/iceberg/aws/glue/TestGlueCatalogTable.java b/aws/src/integration/java/org/apache/iceberg/aws/glue/TestGlueCatalogTable.java index 92b906a44944..68f797d550ab 100644 --- a/aws/src/integration/java/org/apache/iceberg/aws/glue/TestGlueCatalogTable.java +++ b/aws/src/integration/java/org/apache/iceberg/aws/glue/TestGlueCatalogTable.java @@ -404,7 +404,7 @@ public void testTablePropsDefinedAtCatalogLevel() { NestedField.required(4, "data", Types.StringType.get()) ); - org.apache.iceberg.Table table = glueCatalog.buildTable(tableIdent, schema) + Table table = glueCatalog.buildTable(tableIdent, schema) .withProperty("key2", "table-key2") .withProperty("key3", "table-key3") .withProperty("key5", "table-key5") diff --git a/aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java b/aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java index a9132bbdb623..c223069d7560 100644 --- a/aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java +++ b/aws/src/main/java/org/apache/iceberg/aws/glue/GlueTableOperations.java @@ -133,7 +133,7 @@ protected void doCommit(TableMetadata base, TableMetadata metadata) { } catch (software.amazon.awssdk.services.glue.model.AlreadyExistsException e) { throw new AlreadyExistsException(e, "Cannot commit %s because its Glue table already exists when trying to create one", tableName()); - } catch (software.amazon.awssdk.services.glue.model.EntityNotFoundException e) { + } catch (EntityNotFoundException e) { throw new NotFoundException(e, "Cannot commit %s because Glue cannot find the requested entity", tableName()); } catch (software.amazon.awssdk.services.glue.model.AccessDeniedException e) { diff --git a/core/src/main/java/org/apache/iceberg/util/ZOrderByteUtils.java b/core/src/main/java/org/apache/iceberg/util/ZOrderByteUtils.java index 70f686f94ed0..a25a90a20cdf 100644 --- a/core/src/main/java/org/apache/iceberg/util/ZOrderByteUtils.java +++ b/core/src/main/java/org/apache/iceberg/util/ZOrderByteUtils.java @@ -166,7 +166,8 @@ static byte[] interleaveBits(byte[][] columnsBinary, int interleavedSize) { * @param interleavedSize the number of bytes to use in the output * @return the columnbytes interleaved */ - @SuppressWarnings("ByteBufferBackingArray") + // NarrowingCompoundAssignment is intended here. See https://github.com/apache/iceberg/pull/5200#issuecomment-1176226163 + @SuppressWarnings({"ByteBufferBackingArray", "NarrowingCompoundAssignment"}) public static byte[] interleaveBits(byte[][] columnsBinary, int interleavedSize, ByteBuffer reuse) { byte[] interleavedBytes = reuse.array(); Arrays.fill(interleavedBytes, 0, interleavedSize, (byte) 0x00); diff --git a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java index bc9053c59f2e..3cdc58064af0 100644 --- a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java +++ b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java @@ -502,6 +502,7 @@ private StorageDescriptor storageDescriptor(TableMetadata metadata, boolean hive return storageDescriptor; } + @SuppressWarnings("ReverseDnsLookup") @VisibleForTesting long acquireLock() throws UnknownHostException, TException, InterruptedException { final LockComponent lockComponent = new LockComponent(LockType.EXCLUSIVE, LockLevel.TABLE, database);