flowpool=null

src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys_r_rate/makedata_recsys_86_fm_sample_20250627.scala

@@ -88,7 +88,7 @@ object makedata_recsys_86_fm_sample_20250627 {
   }
 
   private def recommendFlow(flowPool: String): Boolean = {
-    if (flowPool.isEmpty || flowPool.endsWith("#1")) {
+    if (flowPool.isEmpty || flowPool.equals("null") || flowPool.endsWith("#1")) {
       return true
     }
     false