Fix

Author: rok

parquet/src/encryption/encrypt.rs

@@ -409,13 +409,9 @@ pub(crate) fn write_signed_plaintext_object<T: TSerializable, W: Write>(
     sink.write_all(&buffer)?;
     buffer = encryptor.encrypt(buffer.as_ref(), module_aad)?;
 
-    let ciphertext_length : u32 = buffer.len()
-        .try_into()
-        .map_err(|err| general_err!("Plaintext data too long. {:?}", err))?;
-
     // Format of encrypted buffer is: [ciphertext size, nonce, ciphertext, authentication tag]
     let nonce = &buffer[SIZE_LEN..SIZE_LEN + NONCE_LEN];
-    let tag = &buffer[(buffer.len() - TAG_LEN)..];
+    let tag = &buffer[buffer.len() - TAG_LEN..];
     sink.write_all(nonce)?;
     sink.write_all(tag)?;
 

parquet/src/file/metadata/writer.rs

@@ -17,7 +17,7 @@
 
 #[cfg(feature = "encryption")]
 use crate::encryption::{
-    encrypt::{encrypt_object, encrypt_object_to_vec, sign_and_write_object, FileEncryptor},
+    encrypt::{encrypt_object, encrypt_object_to_vec, write_signed_plaintext_object, FileEncryptor},
     modules::{create_footer_aad, create_module_aad, ModuleType},
 };
 #[cfg(feature = "encryption")]
@@ -516,7 +516,7 @@ impl MetadataObjectWriter {
             Some(file_encryptor) if file_metadata.encryption_algorithm.is_some() => {
                 let aad = create_footer_aad(file_encryptor.file_aad())?;
                 let mut encryptor = file_encryptor.get_footer_encryptor()?;
-                sign_and_write_object(file_metadata, &mut encryptor, &mut sink, &aad)
+                write_signed_plaintext_object(file_metadata, &mut encryptor, &mut sink, &aad)
             }
             _ => Self::write_object(file_metadata, &mut sink),
         }