yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-12 17:34:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix KeyError: static_boostring_score (#507)

Browse Source
This commit is contained in:
Shuya Tsukamoto 2017-05-19 15:14:39 +09:00 committed by Mars Lan
parent 53fe63680f
commit eefab3dc1e
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
metadata-etl/src/main/resources/jython/ElasticSearchIndex.py
View File

@ -148,7 +148,14 @@ class ElasticSearchIndex():
def update_dataset(self, last_unixtime=None): def update_dataset(self, last_unixtime=None):
if last_unixtime: if last_unixtime:
sql = """ sql = """
SELECT * FROM dict_dataset WHERE from_unixtime(modified_time) >= DATE_SUB(from_unixtime(%f), INTERVAL 1 HOUR) SELECT d.*,
COALESCE(s.static_boosting_score,1) as static_boosting_score
FROM dict_dataset d
LEFT JOIN cfg_search_score_boost s
ON d.id = s.id
WHERE d.urn not like "hive:///dev_foundation_tables%%"
and d.urn not like "hive:///dev_foundation_views%%"
and from_unixtime(d.modified_time) >= DATE_SUB(from_unixtime(%f), INTERVAL 1 HOUR)
""" % last_unixtime """ % last_unixtime
else: else:
sql = """ sql = """