修复bug

eda/feededa/src/main/scala/com/gmei/find_bug.scala

@@ -87,6 +87,8 @@ object find_bug {
            |and jd.stat_date ='${stat_date}'
          """.stripMargin
       )
+      clk_count_oldUser_Contrast.show()
+
 
       val imp_count_oldUser_Contrast = sc.sql(
         s"""
@@ -99,6 +101,8 @@ object find_bug {
            |and je.stat_date ='${stat_date}'
          """.stripMargin
       )
+      imp_count_oldUser_Contrast.show()
+
 
       val clk_count_oldUser_all = sc.sql(
         s"""
@@ -110,6 +114,7 @@ object find_bug {
            |and jd.stat_date ='${stat_date}'
          """.stripMargin
       )
+      clk_count_oldUser_all.show()
 
       val imp_count_oldUser_all = sc.sql(
         s"""
@@ -121,6 +126,7 @@ object find_bug {
            |and je.stat_date ='${stat_date}'
          """.stripMargin
       )
+      imp_count_oldUser_all.show()
 
 
       val result1 = clk_count_oldUser_Contrast.join(imp_count_oldUser_Contrast,"stat_date")
@@ -150,6 +156,7 @@ object find_bug {
            |and jd.stat_date ='${stat_date}'
          """.stripMargin
       )
+      clk_active_1.show()
 
       //device_id尾号1有点击用户日记本曝光数
       val imp_active_1 = sc.sql(
@@ -163,6 +170,7 @@ object find_bug {
            |and je.stat_date ='${stat_date}'
          """.stripMargin
       )
+      imp_active_1.show()
 
       //device_id尾号1点击日记本用户数
       val clk_diary_device = sc.sql(
@@ -176,6 +184,7 @@ object find_bug {
            |and jd.stat_date ='${stat_date}'
             """.stripMargin
       )
+      clk_diary_device.show()
 
       //所有有点击用户日记本点击数
       val clk_active_all = sc.sql(
@@ -188,6 +197,7 @@ object find_bug {
            |and jd.stat_date ='${stat_date}'
           """.stripMargin
       )
+      clk_active_all.show()
 
       //所有有点击用户日记本曝光数
       val imp_active_all = sc.sql(
@@ -201,6 +211,7 @@ object find_bug {
            |and je.stat_date ='${stat_date}'
           """.stripMargin
       )
+      imp_active_all.show()
 
       //策略命中用户点击日记本用户数
       val clk_diary_device_cover = sc.sql(
@@ -210,6 +221,7 @@ object find_bug {
            |where device_id in (select distinct(device_id) from data_feed_click where stat_date = '${stat_date}')
           """.stripMargin
       )
+      clk_diary_device_cover.show()
 
       //策略命中用户总数
       val device_all_cover = sc.sql(
@@ -218,6 +230,8 @@ object find_bug {
            |from merge_queue_table
           """.stripMargin
       )
+      device_all_cover.show()
+
 
       val result2 = clk_active_1.join(imp_active_1,"stat_date")
         .join(clk_active_all,"stat_date")
@@ -263,6 +277,7 @@ object find_bug {
            |and jd.stat_date ='${stat_date}'
          """.stripMargin
       )
+      clk_count_newUser_Contrast.show()
 
       val imp_count_newUser_Contrast = sc.sql(
         s"""
@@ -275,6 +290,7 @@ object find_bug {
            |and je.stat_date ='${stat_date}'
          """.stripMargin
       )
+      imp_count_newUser_Contrast.show()
 
       val clk_count_newUser_all = sc.sql(
         s"""
@@ -286,6 +302,7 @@ object find_bug {
            |and jd.stat_date ='${stat_date}'
          """.stripMargin
       )
+      clk_count_newUser_all.show()
 
       val imp_count_newUser_all = sc.sql(
         s"""
@@ -297,6 +314,7 @@ object find_bug {
            |and je.stat_date ='${stat_date}'
          """.stripMargin
       )
+      imp_count_newUser_all.show()
 
       val result3 = clk_count_newUser_Contrast.join(imp_count_newUser_Contrast,"stat_date")
         .join(clk_count_newUser_all,"stat_date")