From 728e3407e8125250450e9fa97bc786e47e2d3ec1 Mon Sep 17 00:00:00 2001
From: chaochaoc <13051077615@126.com>
Date: Mon, 21 Oct 2024 14:41:43 +0800
Subject: [PATCH] fix: init value

---
 .../flink/easy/application/voip/udf/StreamDirSet.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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