add

trans2es/management/commands/trans2es_data2es_parallel.py

@@ -49,7 +49,6 @@ class Job(object):
     def __call__(self):
         type_info = get_type_info_map()[self._type_name]
         assert isinstance(type_info, TypeInfo)
-
         result = type_info.insert_table_chunk(
             sub_index_name=self._sub_index_name,
             table_chunk=self._chunk,

trans2es/mapping/topic.json

@@ -12,7 +12,7 @@
     "content_level":{"type":"text"},
     "user_id":{"type":"long"},
 //    "group_id":{"type":"long"}, //所在组ID
-    "pictorial_id":{"type":"long"},//所在画报的ID
+//    "pictorial_id":{"type":"long"},//所在画报的ID
     "tag_list":{"type":"long"},//标签属性
     "edit_tag_list":{"type":"long"},//编辑标签
     "tag_name_list":{"type":"text","analyzer":"gm_default_index","search_analyzer":"gm_default_index"},

trans2es/models/user.py

@@ -111,7 +111,6 @@ class User(models.Model):
             logging.error("catch exception,err_msg:%s" % traceback.format_exc())
             return []
 
-
     def get_pick_user_id_list(self):
         pick_topic_id_list = list()
         user_picks = self.user_pick.using(settings.SLAVE_DB_NAME).filter(is_deleted=False, is_pick=True)