|
@@ -383,7 +383,7 @@ func SaveEsMethod() {
|
|
|
}()
|
|
|
Es.BulkSave(config.Conf.DB.Es.IndexB, arru)
|
|
|
if config.Conf.DB.Es.IndexTmp != "" {
|
|
|
- Es.BulkSave(config.Conf.DB.Es.IndexTmp, arru)
|
|
|
+ Es2.BulkSave(config.Conf.DB.Es.IndexTmp, arru)
|
|
|
}
|
|
|
if config.Conf.DB.Es.Addr2 != "" {
|
|
|
Es2.BulkSave(config.Conf.DB.Es.Indexb2, arru)
|
|
@@ -402,7 +402,7 @@ func SaveEsMethod() {
|
|
|
}()
|
|
|
Es.BulkSave(config.Conf.DB.Es.IndexB, arru)
|
|
|
if config.Conf.DB.Es.IndexTmp != "" {
|
|
|
- Es.BulkSave(config.Conf.DB.Es.IndexTmp, arru)
|
|
|
+ Es2.BulkSave(config.Conf.DB.Es.IndexTmp, arru)
|
|
|
}
|
|
|
if config.Conf.DB.Es.Addr2 != "" {
|
|
|
Es2.BulkSave(config.Conf.DB.Es.Indexb2, arru)
|