diff --git a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/StreamDirSet.java b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/StreamDirSet.java
index de1d727..bd44ae4 100644
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/StreamDirSet.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/StreamDirSet.java
@@ -9,7 +9,7 @@ public class StreamDirSet extends ScalarFunction {
         if (flags == null) {
             return 8192 + 16384L;
         }
-        Long r = null;
+        long r = 0;
         if ((flags & 8192) == 0) {
             r += 8192;
         }