yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2026-01-06 06:46:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #829 from camelliazhang/master

Browse Source 
need to use new index name in reindex
This commit is contained in:
na zhang 2017-10-29 23:16:00 -07:00 committed by GitHub
commit 3fb30c5d3c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
wherehows-etl/src/main/resources/jython/ElasticSearchIndex.py
View File

@ -84,7 +84,7 @@ class ElasticSearchIndex():
LEFT JOIN field_comments f ON d.comment_id = f.id WHERE d.field_id = %d
"""
url = self.elasticsearch_index_url + ':' + str(
self.elasticsearch_port) + '/' + self.elasticsearch_index + '/field/_bulk'
self.elasticsearch_port) + '/' + self.new_index + '/field/_bulk'
params = []
attempts = 0
while attempts < self.max_retry_times:
@ -150,7 +150,7 @@ class ElasticSearchIndex():
"""
url = self.elasticsearch_index_url + ':' + str(
self.elasticsearch_port) + '/' + self.elasticsearch_index + '/comment/_bulk'
self.elasticsearch_port) + '/' + self.new_index + '/comment/_bulk'
params = []
self.wh_cursor.execute(sql)
row_count = 1
@ -258,7 +258,7 @@ class ElasticSearchIndex():
result = self.wh_cursor.fetchone()
url = self.elasticsearch_index_url + ':' + str(
self.elasticsearch_port) + '/' + self.elasticsearch_index + '/dataset/_bulk'
self.elasticsearch_port) + '/' + self.new_index + '/dataset/_bulk'
params = []
while result:
row = dict(zip(description, result))
@ -304,7 +304,7 @@ class ElasticSearchIndex():
"""
url = self.elasticsearch_index_url + ':' + str(
self.elasticsearch_port) + '/' + self.elasticsearch_index + '/metric/_bulk'
self.elasticsearch_port) + '/' + self.new_index + '/metric/_bulk'
params = []
self.wh_cursor.execute(sql)
description = [x[0] for x in self.wh_cursor.description]
@ -376,7 +376,7 @@ class ElasticSearchIndex():
"""
url = self.elasticsearch_index_url + ':' + str(
self.elasticsearch_port) + '/' + self.elasticsearch_index + '/flow_jobs/_bulk'
self.elasticsearch_port) + '/' + self.new_index + '/flow_jobs/_bulk'
params = []
self.wh_cursor.execute(flow_sql)