update the final table name

This commit is contained in:
jbai 2016-08-24 15:50:44 -07:00 committed by Mars Lan
parent fe428cf3bb
commit fa3bcfd48c

View File

@ -60,7 +60,7 @@ class DatasetDescriptionLoad:
def load_kafka_to_hdfs_map(self):
cursor = self.conn_mysql.cursor()
load_cmd = """
INSERT IGNORE INTO cfg_object_name_map_test
INSERT IGNORE INTO cfg_object_name_map
(
object_type,
object_sub_type,