fix: init value

2024-10-21 14:41:43 +08:00
parent 16d71addda
commit 728e3407e8
1 changed files with 1 additions and 1 deletions
--- 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;
        }