Undo overwrite change and clean up token when not being used

crates/hdfs-native/minidfs/src/main/java/main/Main.java

@@ -155,6 +155,8 @@ public static void main(String args[]) throws Exception {
                 DataOutputStream os = new DataOutputStream(new FileOutputStream("target/test/delegation_token"));
                 creds.writeTokenStorageToStream(os, SerializedFormat.WRITABLE);
                 os.close();
+            } else {
+                new File("target/test/delegation_token").delete();
             }
         }
 

crates/hdfs-native/src/hdfs/protocol.rs

@@ -109,19 +109,18 @@ impl NamenodeProtocol {
     ) -> Result<hdfs::CreateResponseProto> {
         let masked = hdfs::FsPermissionProto { perm: permission };
 
-        let mut create_flag = hdfs::CreateFlagProto::Create as u32;
-        if overwrite {
-            create_flag |= hdfs::CreateFlagProto::Overwrite as u32;
-        }
-
         let message = hdfs::CreateRequestProto {
             src: src.to_string(),
             masked,
             client_name: self.client_name.clone(),
             create_parent,
             replication,
             block_size,
-            create_flag,
+            create_flag: if overwrite {
+                hdfs::CreateFlagProto::Overwrite
+            } else {
+                hdfs::CreateFlagProto::Create
+            } as u32,
             ..Default::default()
         };
 

crates/hdfs-native/tests/test_ec.rs

@@ -108,6 +108,7 @@ mod test {
 
             assert!(client.delete(&file, false).await?);
         }
+        let _ = EC_FAULT_INJECTOR.lock().unwrap().take();
         Ok(())
     }