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}));
+ }
+
+}