[avro] branch master updated: AVRO-3410: [Rust] lint failure

[mgrigorov]

This is an automated email from the ASF dual-hosted git repository.

mgrigorov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/avro.git


The following commit(s) were added to refs/heads/master by this push:
     new 5d3f9a6  AVRO-3410: [Rust] lint failure
5d3f9a6 is described below

commit 5d3f9a687484aac766783442f45fc66d02df530e
Author: Martin Tzvetanov Grigorov <mgrigo...@apache.org>
AuthorDate: Mon Feb 21 15:20:46 2022 +0200

    AVRO-3410: [Rust] lint failure
    
    Signed-off-by: Martin Tzvetanov Grigorov <mgrigo...@apache.org>
---
 lang/rust/src/reader.rs | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/lang/rust/src/reader.rs b/lang/rust/src/reader.rs
index e4bf706..fb83e64 100644
--- a/lang/rust/src/reader.rs
+++ b/lang/rust/src/reader.rs
@@ -72,7 +72,7 @@ impl<R: Read> Block<R> {
 
         if let Value::Map(metadata) = decode(&meta_schema, &mut self.reader)? {
             self.read_writer_schema(&metadata)?;
-            self.read_codec(&metadata)?;
+            self.read_codec(&metadata);
 
             for (key, value) in metadata {
                 if key == "avro.schema" || key == "avro.codec" {
@@ -80,7 +80,7 @@ impl<R: Read> Block<R> {
                 } else if key.starts_with("avro.") {
                     warn!("Ignoring unknown metadata key: {}", key);
                 } else {
-                    self.read_user_metadata(key, value)?;
+                    self.read_user_metadata(key, value);
                 }
             }
         } else {
@@ -189,7 +189,7 @@ impl<R: Read> Block<R> {
         Ok(())
     }
 
-    fn read_codec(&mut self, metadata: &HashMap<String, Value>) -> 
AvroResult<()> {
+    fn read_codec(&mut self, metadata: &HashMap<String, Value>) {
         if let Some(codec) = metadata
             .get("avro.codec")
             .and_then(|codec| {
@@ -203,21 +203,18 @@ impl<R: Read> Block<R> {
         {
             self.codec = codec;
         }
-        Ok(())
     }
 
-    fn read_user_metadata(&mut self, key: String, value: Value) -> 
AvroResult<()> {
+    fn read_user_metadata(&mut self, key: String, value: Value) {
         match value {
             Value::Bytes(ref vec) => {
                 self.user_metadata.insert(key, vec.clone());
-                Ok(())
             }
             wrong => {
                 warn!(
                     "User metadata values must be Value::Bytes, found {:?}",
                     wrong
                 );
-                Ok(())
             }
         }
     }