소스 검색

feat:修改无回传判断逻辑

zhaohaipeng 6 달 전
부모
커밋
6ceac0fc86
1개의 변경된 파일4개의 추가작업 그리고 1개의 파일을 삭제
  1. 4 1
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_31_originData_20240718.scala

+ 4 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_31_originData_20240718.scala

@@ -59,7 +59,10 @@ object makedata_ad_31_originData_20240718 {
               JSON.parseObject(record.getString("extend_alg"))
             var isApi = extendAlg.getString("is_api")
             if (extendAlg.containsKey("extinfo")) {
-              isApi = extendAlg.getJSONObject("extinfo").getString("isApi")
+              val extInfoJson = extendAlg.getJSONObject("extinfo")
+              if (extInfoJson.containsKey("isApi")) {
+                isApi = extInfoJson.getString("isApi")
+              }
             }
             "1".equals(isApi)
           })