Commit 96b74897 authored by 王志伟's avatar 王志伟

repair bug

parent f9d4d83a
...@@ -46,14 +46,6 @@ object testt { ...@@ -46,14 +46,6 @@ object testt {
ti.tidbMapTable(dbName = "jerry_test", tableName = "bl_device_list") ti.tidbMapTable(dbName = "jerry_test", tableName = "bl_device_list")
ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure") ti.tidbMapTable(dbName = "jerry_prod", tableName = "data_feed_exposure")
val diary_id = sc.sql(
s"""
|select distinct(cid_id) as diary_id
|from data_feed_click
""".stripMargin
)
diary_id.show()
diary_id.createOrReplaceTempView("diary_id")
val view_count = sc.sql( val view_count = sc.sql(
s""" s"""
...@@ -61,7 +53,7 @@ object testt { ...@@ -61,7 +53,7 @@ object testt {
|from online.tl_hdfs_maidian_view |from online.tl_hdfs_maidian_view
|where action="page_view" |where action="page_view"
|and params["page_name"]="diary_detail" |and params["page_name"]="diary_detail"
|and partition_date >='20180801' |and partition_date ='20180801'
|group by diary_id |group by diary_id
""".stripMargin """.stripMargin
) )
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment