全文索引不同步

问答 问题
1
  • nebula 版本：v2.0.1
    image
    image864×155 32.1 KB
  • 部署方式（分布式 / 单机 / Docker / DBaaS）：docker-compose
  • 是否为线上版本：N
  • 问题的具体描述
    插入新的vertex，通过全文检索搜索不到，检查es中也没有相关文档，文档数量没有变化
  • 相关的 meta / storage / graph info 日志信息

测试环境，启动是通过docker-compose，修改了官方提供的nebula-docker-compose文件，添加了三个listener服务，分别如下：

  listener0:
    image: vesoft/nebula-storaged:v2-nightly
    environment:
      USER: root
      TZ:   "${TZ}"
    entrypoint:
      - sh
      - -c
    command:
      - /usr/local/nebula/bin/nebula-storaged --flagfile=/usr/local/nebula/etc/nebula-storaged-listener.conf --daemonize=false --local_ip=$$(hostname -i) --ws_ip=$$(hostname -i)
    depends_on:
      - metad0
      - metad1
      - metad2
    healthcheck:
      test: ["CMD", "curl", "-sf", "http://listener0:19779/status"]
      interval: 30s
      timeout: 10s
      retries: 3
      start_period: 20s
    ports:
      - 9779
      - 19779
      - 19780
    volumes:
      - ./nebula-storaged-listener.conf:/usr/local/nebula/etc/nebula-storaged-listener.conf
      - ./data/listener0:/data/listener
      - ./logs/listener0:/logs
    networks:
      - nebula-net
    restart: on-failure
    cap_add:
      - SYS_PTRACE

  listener1:
    image: vesoft/nebula-storaged:v2-nightly
    environment:
      USER: root
      TZ:   "${TZ}"
    entrypoint:
      - sh
      - -c
    command:
      - /usr/local/nebula/bin/nebula-storaged --flagfile=/usr/local/nebula/etc/nebula-storaged-listener.conf --daemonize=false --local_ip=$$(hostname -i) --ws_ip=$$(hostname -i)
    depends_on:
      - metad0
      - metad1
      - metad2
    healthcheck:
      test: ["CMD", "curl", "-sf", "http://listener1:19779/status"]
      interval: 30s
      timeout: 10s
      retries: 3
      start_period: 20s
    ports:
      - 9779
      - 19779
      - 19780
    volumes:
      - ./nebula-storaged-listener.conf:/usr/local/nebula/etc/nebula-storaged-listener.conf
      - ./data/listener1:/data/listener
      - ./logs/listener1:/logs
    networks:
      - nebula-net
    restart: on-failure
    cap_add:
      - SYS_PTRACE

  listener2:
    image: vesoft/nebula-storaged:v2-nightly
    environment:
      USER: root
      TZ:   "${TZ}"
    entrypoint:
      - sh
      - -c
    command:
      - /usr/local/nebula/bin/nebula-storaged --flagfile=/usr/local/nebula/etc/nebula-storaged-listener.conf --daemonize=false --local_ip=$$(hostname -i) --ws_ip=$$(hostname -i)
    depends_on:
      - metad0
      - metad1
      - metad2
    healthcheck:
      test: ["CMD", "curl", "-sf", "http://listener2:19779/status"]
      interval: 30s
      timeout: 10s
      retries: 3
      start_period: 20s
    ports:
      - 9779
      - 19779
      - 19780
    volumes:
      - ./nebula-storaged-listener.conf:/usr/local/nebula/etc/nebula-storaged-listener.conf
      - ./data/listener2:/data/listener
      - ./logs/listener2:/logs
    networks:
      - nebula-net
    restart: on-failure
    cap_add:
      - SYS_PTRACE

其中挂载的nebula-storaged-listener.conf配置文件内容如下：

########## nebula-storaged-listener ###########
########## basics ##########
# Whether to run as a daemon process
--daemonize=false
# The file to host the process id
--pid_file=pids/nebula-storaged-listener.pid

########## logging ##########
# The directory to host logging files
--log_dir=/logs
# Log level, 0, 1, 2, 3 for INFO, WARNING, ERROR, FATAL respectively
--minloglevel=0
# Verbose log level, 1, 2, 3, 4, the higher of the level, the more verbose of the logging
--v=0
# Maximum seconds to buffer the log messages
--logbufsecs=0
# Whether to redirect stdout and stderr to separate output files
--redirect_stdout=true
# Destination filename of stdout and stderr, which will also reside in log_dir.
--stdout_log_file=storaged-stdout.log
--stderr_log_file=storaged-stderr.log
# Copy log messages at or above this level to stderr in addition to logfiles. The numbers of severity levels INFO, WARNING, ERROR, and FATAL are 0, 1, 2, and 3, respectively.
--stderrthreshold=2

########## networking ##########
# Meta server address
--meta_server_addrs=metad0:9559,metad1:9559,metad2:9559
# Local ip
# --local_ip=storagels
# Storage daemon listening port
--port=9779
# HTTP service ip
# --ws_ip=storagels
# HTTP service port
--ws_http_port=19779
# HTTP2 service port
--ws_h2_port=19780
# heartbeat with meta service
--heartbeat_interval_secs=10

########## storage ##########
# Listener wal directory. only one path is allowed.
--listener_path=/data/listener
# This parameter can be ignored for compatibility. let's fill A default value of "data"
--data_path=/data/storage
# The type of part manager, [memory | meta]
--part_man_type=memory
# The default reserved bytes for one batch operation
--rocksdb_batch_size=4096
# The default block cache size used in BlockBasedTable.
# The unit is MB.
--rocksdb_block_cache=4
# The type of storage engine, `rocksdb', `memory', etc.
--engine_type=rocksdb
# The type of part, `simple', `consensus'...
--part_type=simple

检查listener和text search clients：

(root@nebula) [basketballplayer]> show listener;
+--------+-----------------+----------------------+-----------+
| PartId | Type            | Host                 | Status    |
+--------+-----------------+----------------------+-----------+
| 1      | "ELASTICSEARCH" | ""172.24.0.7":9779"  | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 2      | "ELASTICSEARCH" | ""172.24.0.9":9779"  | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 3      | "ELASTICSEARCH" | ""172.24.0.10":9779" | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 4      | "ELASTICSEARCH" | ""172.24.0.7":9779"  | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 5      | "ELASTICSEARCH" | ""172.24.0.9":9779"  | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 6      | "ELASTICSEARCH" | ""172.24.0.10":9779" | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 7      | "ELASTICSEARCH" | ""172.24.0.7":9779"  | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 8      | "ELASTICSEARCH" | ""172.24.0.9":9779"  | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 9      | "ELASTICSEARCH" | ""172.24.0.10":9779" | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
| 10     | "ELASTICSEARCH" | ""172.24.0.7":9779"  | "OFFLINE" |
+--------+-----------------+----------------------+-----------+
Got 10 rows (time spent 3249/8022 us)

Fri, 23 Apr 2021 19:33:00 CST

(root@nebula) [basketballplayer]> show text search clients;
+-----------------+-------+
| Host            | Port  |
+-----------------+-------+
| "172.17.10.252" | 9200  |
+-----------------+-------+
| "172.17.10.252" | 19200 |
+-----------------+-------+
| "172.17.10.252" | 29200 |
+-----------------+-------+
Got 3 rows (time spent 3095/5195 us)

Fri, 23 Apr 2021 19:33:04 CST

问题现场截图：

(root@nebula) [basketballplayer]> show tag indexes;
+------------------+
| Names            |
+------------------+
| "player_index_0" |
+------------------+
| "player_index_1" |
+------------------+
| "team_index_0"   |
+------------------+
Got 3 rows (time spent 2638/12718 us)

Fri, 23 Apr 2021 19:34:45 CST

(root@nebula) [basketballplayer]> describe tag index player_index_1;
+--------+--------------------+
| Field  | Type               |
+--------+--------------------+
| "name" | "fixed_string(20)" |
+--------+--------------------+
Got 1 rows (time spent 2679/4743 us)

Fri, 23 Apr 2021 19:34:53 CST

(root@nebula) [basketballplayer]> insert vertex player(name,age) values "player300":("Robin Khan", 20);
Execution succeeded (time spent 3360/7458 us)

Fri, 23 Apr 2021 19:35:37 CST
(root@nebula) [basketballplayer]> LOOKUP on player where prefix(player.name, "Robin") yield player.name;
Empty set (time spent 61602/63964 us)

Fri, 23 Apr 2021 19:36:18 CST

同时检查es索引nebula_basketballplayer_tag文档数量在INSERT VERTEX前后也并无变化。

检查日志并无特别异常：

# cat logs/*/*.ERROR
Log file created at: 2021/04/23 11:34:42
Running on machine: 693f16cd1f3d
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:34:42.665920    50 QueryInstance.cpp:107] SyntaxError: syntax error near `;'
Log file created at: 2021/04/23 11:13:01
Running on machine: e6b4d028af7b
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.676985     1 GflagsManager.cpp:70] Load gflags json failed
Log file created at: 2021/04/23 11:13:01
Running on machine: ea0e91d16145
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.367278     1 GflagsManager.cpp:70] Load gflags json failed
Log file created at: 2021/04/23 11:13:01
Running on machine: 9ca094144a08
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.195583     1 GflagsManager.cpp:70] Load gflags json failed
Log file created at: 2021/04/23 11:13:01
Running on machine: 12232694f0a1
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.201259   119 RaftPart.cpp:366] [Port: 9560, Space: 0, Part: 0] The partition is not a leader
E0423 11:13:01.201561   119 RaftPart.cpp:686] [Port: 9560, Space: 0, Part: 0] Cannot append logs, clean the buffer
E0423 11:13:01.201614   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:01.372473   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:03.015368   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:03.129184   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
Log file created at: 2021/04/23 11:10:47
Running on machine: efdedeb4f0ca
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:10:47.272495   118 ListenerProcessor.cpp:24] Add listener failed, listener already exists.
E0423 11:12:48.705444    97 JobDescription.cpp:189] Loading Job Description FailedE_NOT_FOUND
E0423 11:12:48.705497    97 JobManager.cpp:90] [JobManager] load an invalid job from queue 0
Log file created at: 2021/04/23 11:12:59
Running on machine: 70d600f1b6d9
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:12:59.847100    47 RaftPart.cpp:1142] [Port: 9560, Space: 0, Part: 0] Receive response about askForVote from "metad1":9560, error code is E_UNKNOWN_PART
E0423 11:12:59.847286    47 RaftPart.cpp:1142] [Port: 9560, Space: 0, Part: 0] Receive response about askForVote from "metad0":9560, error code is E_UNKNOWN_PART
E0423 11:13:01.112439   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:01.683113   119 RaftPart.cpp:366] [Port: 9560, Space: 0, Part: 0] The partition is not a leader
E0423 11:13:01.683192   119 RaftPart.cpp:686] [Port: 9560, Space: 0, Part: 0] Cannot append logs, clean the buffer
E0423 11:13:01.683248   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:01.719718   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
Log file created at: 2021/04/23 11:13:01
Running on machine: 1d63cd7217f5
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.519528     1 GflagsManager.cpp:70] Load gflags json failed
Log file created at: 2021/04/23 11:13:01
Running on machine: 46c80a274912
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.107072     1 GflagsManager.cpp:70] Load gflags json failed
Log file created at: 2021/04/23 11:13:01
Running on machine: f9ecd84af63f
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.714326     1 GflagsManager.cpp:70] Load gflags json failed

# cat logs/*/*.WARNING
Log file created at: 2021/04/23 11:34:42
Running on machine: 693f16cd1f3d
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:34:42.665920    50 QueryInstance.cpp:107] SyntaxError: syntax error near `;'
Log file created at: 2021/04/23 11:13:01
Running on machine: e6b4d028af7b
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.676985     1 GflagsManager.cpp:70] Load gflags json failed
Log file created at: 2021/04/23 11:13:01
Running on machine: ea0e91d16145
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.367278     1 GflagsManager.cpp:70] Load gflags json failed
Log file created at: 2021/04/23 11:13:01
Running on machine: 9ca094144a08
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.195583     1 GflagsManager.cpp:70] Load gflags json failed
Log file created at: 2021/04/23 11:12:59
Running on machine: 12232694f0a1
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
W0423 11:12:59.846249    43 RaftexService.cpp:181] Cannot find the part 0 in the graph space 0
E0423 11:13:01.201259   119 RaftPart.cpp:366] [Port: 9560, Space: 0, Part: 0] The partition is not a leader
E0423 11:13:01.201561   119 RaftPart.cpp:686] [Port: 9560, Space: 0, Part: 0] Cannot append logs, clean the buffer
E0423 11:13:01.201614   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:01.372473   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:03.015368   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:03.129184   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
Log file created at: 2021/04/23 11:12:59
Running on machine: 7971746efaf2
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
W0423 11:12:59.846189    43 RaftexService.cpp:181] Cannot find the part 0 in the graph space 0
Log file created at: 2021/04/23 11:12:59
Running on machine: 70d600f1b6d9
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:12:59.847100    47 RaftPart.cpp:1142] [Port: 9560, Space: 0, Part: 0] Receive response about askForVote from "metad1":9560, error code is E_UNKNOWN_PART
E0423 11:12:59.847286    47 RaftPart.cpp:1142] [Port: 9560, Space: 0, Part: 0] Receive response about askForVote from "metad0":9560, error code is E_UNKNOWN_PART
E0423 11:13:01.112439   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:01.683113   119 RaftPart.cpp:366] [Port: 9560, Space: 0, Part: 0] The partition is not a leader
E0423 11:13:01.683192   119 RaftPart.cpp:686] [Port: 9560, Space: 0, Part: 0] Cannot append logs, clean the buffer
E0423 11:13:01.683248   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
E0423 11:13:01.719718   119 ActiveHostsMan.cpp:248] Get last update time failed, error: E_LEADER_CHANGED
Log file created at: 2021/04/23 11:13:01
Running on machine: 1d63cd7217f5
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.519528     1 GflagsManager.cpp:70] Load gflags json failed
W0423 11:13:01.520450     1 FileBasedClusterIdMan.cpp:46] Open file failed, error No such file or directory
Log file created at: 2021/04/23 11:13:01
Running on machine: 46c80a274912
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.107072     1 GflagsManager.cpp:70] Load gflags json failed
W0423 11:13:01.108357     1 FileBasedClusterIdMan.cpp:46] Open file failed, error No such file or directory
Log file created at: 2021/04/23 11:13:01
Running on machine: f9ecd84af63f
Log line format: [IWEF]mmdd hh:mm:ss.uuuuuu threadid file:line] msg
E0423 11:13:01.714326     1 GflagsManager.cpp:70] Load gflags json failed
W0423 11:13:01.715508     1 FileBasedClusterIdMan.cpp:46] Open file failed, error No such file or directory
1 个赞
2

你的listener 的状态都是offline的，确认下你storage的和你的listener是否通信正常，我看docker-compose配置文件用的是主机名，但是你添加的时候用的是ip。

3

抱歉引入了噪音，这是由于我执行过一次docker-compose down && docker-compose up -d，导致listener的IP地址发生了变化

请看下面操作过程

(root@nebula) [basketballplayer]> FETCH PROP ON player "player401";
Empty set (time spent 3937/13827 us)

Fri, 23 Apr 2021 22:37:28 CST

(root@nebula) [basketballplayer]> INSERT VERTEX player(name,age) values "player401":("Robin Khan", 20);
Execution succeeded (time spent 3773/13756 us)

Fri, 23 Apr 2021 22:37:35 CST

(root@nebula) [basketballplayer]> LOOKUP on player where prefix(player.name, "Robin") yield player.name;
Empty set (time spent 67440/78259 us)

Fri, 23 Apr 2021 22:37:41 CST

(root@nebula) [basketballplayer]> FETCH PROP ON player "player401";
+----------------------------------------------------+
| vertices_                                          |
+----------------------------------------------------+
| ("player401" :player{age: 20, name: "Robin Khan"}) |
+----------------------------------------------------+
Got 1 rows (time spent 3674/14684 us)

Fri, 23 Apr 2021 22:37:52 CST
(root@nebula) [basketballplayer]> show hosts;
+-------------+------+----------+--------------+-----------------------+------------------------+
| Host        | Port | Status   | Leader count | Leader distribution   | Partition distribution |
+-------------+------+----------+--------------+-----------------------+------------------------+
| "storaged0" | 9779 | "ONLINE" | 3            | "basketballplayer:3"  | "basketballplayer:3"   |
+-------------+------+----------+--------------+-----------------------+------------------------+
| "storaged1" | 9779 | "ONLINE" | 4            | "basketballplayer:4"  | "basketballplayer:4"   |
+-------------+------+----------+--------------+-----------------------+------------------------+
| "storaged2" | 9779 | "ONLINE" | 3            | "basketballplayer:3"  | "basketballplayer:3"   |
+-------------+------+----------+--------------+-----------------------+------------------------+
| "Total"     |      |          | 10           | "basketballplayer:10" | "basketballplayer:10"  |
+-------------+------+----------+--------------+-----------------------+------------------------+
Got 4 rows (time spent 3795/13983 us)

Fri, 23 Apr 2021 22:39:24 CST

(root@nebula) [basketballplayer]> show listener;
+--------+-----------------+---------------------+----------+
| PartId | Type            | Host                | Status   |
+--------+-----------------+---------------------+----------+
| 1      | "ELASTICSEARCH" | ""172.25.0.6":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 2      | "ELASTICSEARCH" | ""172.25.0.7":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 3      | "ELASTICSEARCH" | ""172.25.0.9":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 4      | "ELASTICSEARCH" | ""172.25.0.6":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 5      | "ELASTICSEARCH" | ""172.25.0.7":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 6      | "ELASTICSEARCH" | ""172.25.0.9":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 7      | "ELASTICSEARCH" | ""172.25.0.6":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 8      | "ELASTICSEARCH" | ""172.25.0.7":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 9      | "ELASTICSEARCH" | ""172.25.0.9":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 10     | "ELASTICSEARCH" | ""172.25.0.6":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
Got 10 rows (time spent 3122/14823 us)

Fri, 23 Apr 2021 22:39:28 CST
1 个赞
4

检查了listener到elasticsearch的网络没问题，但是在elasticsearch上抓包，在INSERT VERTEX之后并没有来自nebula所在机器（metad、graphd、storaged、listener）的请求

5

你贴下你部署的listener的日志，还要把 metad 的info 日志贴出来。

6 
I0426 03:25:11.325011    46 RaftPart.cpp:1636] [Port: 9780, Space: 1, Part: 2] Local is missing logs from id 0. Need to catch up
I0426 03:25:13.231604    45 RaftPart.cpp:1636] [Port: 9780, Space: 1, Part: 8] Local is missing logs from id 0. Need to catch up
I0426 03:25:13.364966    45 RaftPart.cpp:1636] [Port: 9780, Space: 1, Part: 5] Local is missing logs from id 0. Need to catch up
I0426 03:25:13.396575    53 ThriftClientManager.inl:61] resolve "metad1":9559 as "172.25.0.3":9559
I0426 03:25:23.408226    54 ThriftClientManager.inl:61] resolve "metad1":9559 as "172.25.0.3":9559
I0426 03:25:31.339479    44 RaftPart.cpp:1636] [Port: 9780, Space: 1, Part: 2] Local is missing logs from id 0. Need to catch up
I0426 03:25:33.252331    46 RaftPart.cpp:1636] [Port: 9780, Space: 1, Part: 8] Local is missing logs from id 0. Need to catch up
I0426 03:25:33.385627    46 RaftPart.cpp:1636] [Port: 9780, Space: 1, Part: 5] Local is missing logs from id 0. Need to catch up

注意到listener每隔20s都会打印这种日志，这种该如何处理呢？

7

–daemonize=true 呢？

8

在容器内不能使用这种方式启动，会导致容器直接退出。

9

show listener; 目前都是online状态？这个问题的原因是leader的wal没有同步给listener。需要检查一下listener的ip:port是否正确，listener_path是否正确。

10

是的。

(root@nebula) [basketballplayer]> show listener;
+--------+-----------------+---------------------+----------+
| PartId | Type            | Host                | Status   |
+--------+-----------------+---------------------+----------+
| 1      | "ELASTICSEARCH" | ""172.25.0.6":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 2      | "ELASTICSEARCH" | ""172.25.0.7":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 3      | "ELASTICSEARCH" | ""172.25.0.9":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 4      | "ELASTICSEARCH" | ""172.25.0.6":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 5      | "ELASTICSEARCH" | ""172.25.0.7":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 6      | "ELASTICSEARCH" | ""172.25.0.9":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 7      | "ELASTICSEARCH" | ""172.25.0.6":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 8      | "ELASTICSEARCH" | ""172.25.0.7":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 9      | "ELASTICSEARCH" | ""172.25.0.9":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
| 10     | "ELASTICSEARCH" | ""172.25.0.6":9779" | "ONLINE" |
+--------+-----------------+---------------------+----------+
Got 10 rows (time spent 2994/8132 us)

Mon, 26 Apr 2021 16:35:12 CST

(root@nebula) [basketballplayer]> show text search clients;
+-----------------+-------+
| Host            | Port  |
+-----------------+-------+
| "172.17.10.252" | 9200  |
+-----------------+-------+
| "172.17.10.252" | 19200 |
+-----------------+-------+
| "172.17.10.252" | 29200 |
+-----------------+-------+
Got 3 rows (time spent 2858/16224 us)

Mon, 26 Apr 2021 16:35:20 CST
11

楼主，你这个问题解决了吗？我也遇到相同的问题了。我是这样的。如果只给一个表空间创建一个tag,然后给这个tag创建索引同步到es之后,往这个tag里面插入数据是能同步到es中的。但是当我新建了几条边后，再往这个tag插入数据后es中就看不到了。我反反复复测试了好多次都是这个样子的

12

listener的log检查一下，需要把vlog打开

1 个赞
13

这个需要ADD LISTENER ELASTICSEARCH 命令添加操作吗？