azkaban-aplcache

Create Md5HasherTest (#1978)

10/24/2018 12:08:31 AM

Details

diff --git a/azkaban-common/src/main/java/azkaban/utils/Md5Hasher.java b/azkaban-common/src/main/java/azkaban/utils/Md5Hasher.java
index d0d75d8..f674a28 100644
--- a/azkaban-common/src/main/java/azkaban/utils/Md5Hasher.java
+++ b/azkaban-common/src/main/java/azkaban/utils/Md5Hasher.java
@@ -31,7 +31,7 @@ public class Md5Hasher {
 
   private static final int BYTE_BUFFER_SIZE = 1024;
 
-  public static MessageDigest getMd5Digest() {
+  private static MessageDigest getMd5Digest() {
     MessageDigest digest = null;
     try {
       digest = MessageDigest.getInstance("MD5");
diff --git a/azkaban-common/src/test/java/azkaban/utils/Md5HasherTest.java b/azkaban-common/src/test/java/azkaban/utils/Md5HasherTest.java
new file mode 100644
index 0000000..7fdca34
--- /dev/null
+++ b/azkaban-common/src/test/java/azkaban/utils/Md5HasherTest.java
@@ -0,0 +1,19 @@
+package azkaban.utils;
+
+import static org.hamcrest.Matchers.is;
+import static org.junit.Assert.assertThat;
+
+import java.io.File;
+import org.junit.Test;
+
+public class Md5HasherTest {
+
+  private static final File ZIP_FILE = new File("src/test/resources/sample_flow_01.zip");
+
+  @Test
+  public void md5Hash() throws Exception {
+    assertThat(Md5Hasher.md5Hash(ZIP_FILE), is(new byte[]{
+        -59, -26, 22, -50, -80, -101, -57, -121, -27, 46, -71, -101, -85, -115, 42, -116}));
+  }
+
+}