Uploaded image for project: 'Apache IoTDB'
  1. Apache IoTDB
  2. IOTDB-5876

[ ConfigNode "Took a snapshot" + expand a config node ] restart this cluster, there is a config node startup failure

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • mpp-cluster
    • None

    Description

      问题描述
      confignode ratis协议,schema region ratis协议,data region IoT协议,
      启动2C5D, 客户端写入不停,confignode触发snapshot后,扩容1个confignode,
      继续写入数据,confignode触发snapshot。
      客户端写入完成,连接1个datanode执行flush。
      停止集群:停止5D, 停止3C
      清各节点的操作系统缓存,
      启动集群:脚本间隔2秒启动 3C ,脚本间隔1秒启动5D。
      查看集群状态,全部节点是Running.
      停止ip5的confignode服务,停止ip4的confignode服务,执行查询失败(只有1个confignode ip14为扩容节点 ,在线)
      继续启动ip4的confignode ,失败(AC 2节点查询成功,AB 2节点查询成功,需要A在才可以成功):

      2023-05-15 11:00:10,015 [main] INFO o.a.i.c.s.ConfigNode:247 - Successfully initialize ConfigManager.
      2023-05-15 11:00:10,016 [main] INFO o.a.i.c.s.ConfigNode:107 - IoTDB-ConfigNode is in restarting process...
      2023-05-15 11:00:10,196 [main] WARN o.a.i.c.c.s.SyncConfigNodeClientPool:99 - RESTART_CONFIG_NODE failed on ConfigNode TEndPoint(ip:172.20.70.5, port:10710), because net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused), retrying 0...
      2023-05-15 11:00:10,298 [main] WARN o.a.i.c.c.s.SyncConfigNodeClientPool:99 - RESTART_CONFIG_NODE failed on ConfigNode TEndPoint(ip:172.20.70.5, port:10710), because net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused), retrying 1...
      2023-05-15 11:00:10,499 [main] WARN o.a.i.c.c.s.SyncConfigNodeClientPool:99 - RESTART_CONFIG_NODE failed on ConfigNode TEndPoint(ip:172.20.70.5, port:10710), because net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused), retrying 2...
      2023-05-15 11:00:10,901 [main] WARN o.a.i.c.c.s.SyncConfigNodeClientPool:99 - RESTART_CONFIG_NODE failed on ConfigNode TEndPoint(ip:172.20.70.5, port:10710), because net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused), retrying 3...
      2023-05-15 11:00:11,702 [main] WARN o.a.i.c.c.s.SyncConfigNodeClientPool:99 - RESTART_CONFIG_NODE failed on ConfigNode TEndPoint(ip:172.20.70.5, port:10710), because net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused), retrying 4...
      2023-05-15 11:00:13,304 [main] WARN o.a.i.c.c.s.SyncConfigNodeClientPool:99 - RESTART_CONFIG_NODE failed on ConfigNode TEndPoint(ip:172.20.70.5, port:10710), because net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused), retrying 5...
      2023-05-15 11:00:16,507 [main] ERROR o.a.i.c.c.s.SyncConfigNodeClientPool:108 - RESTART_CONFIG_NODE failed on ConfigNode TEndPoint(ip:172.20.70.5, port:10710)
      org.apache.iotdb.commons.client.exception.ClientManagerException: net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused)
      at org.apache.iotdb.commons.client.ClientManager.borrowClient(ClientManager.java:55)
      at org.apache.iotdb.confignode.client.sync.SyncConfigNodeClientPool.sendSyncRequestToConfigNodeWithRetry(SyncConfigNodeClientPool.java:72)
      at org.apache.iotdb.confignode.service.ConfigNode.sendRestartConfigNodeRequest(ConfigNode.java:330)
      at org.apache.iotdb.confignode.service.ConfigNode.active(ConfigNode.java:115)
      at org.apache.iotdb.confignode.service.ConfigNodeCommandLine.run(ConfigNodeCommandLine.java:78)
      at org.apache.iotdb.commons.ServerCommandLine.doMain(ServerCommandLine.java:58)
      at org.apache.iotdb.confignode.service.ConfigNode.main(ConfigNode.java:90)
      Caused by: net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused)
      at net.sf.cglib.core.ReflectUtils.newInstance(ReflectUtils.java:235)
      at net.sf.cglib.core.ReflectUtils.newInstance(ReflectUtils.java:220)
      at net.sf.cglib.proxy.Enhancer.createUsingReflection(Enhancer.java:639)
      at net.sf.cglib.proxy.Enhancer.firstInstance(Enhancer.java:538)
      at net.sf.cglib.core.AbstractClassGenerator.create(AbstractClassGenerator.java:231)
      at net.sf.cglib.proxy.Enhancer.createHelper(Enhancer.java:377)
      at net.sf.cglib.proxy.Enhancer.create(Enhancer.java:304)
      at org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler.newErrorHandler(SyncThriftClientWithErrorHandler.java:46)
      at org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient$Factory.makeObject(SyncConfigNodeIServiceClient.java:112)
      at org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient$Factory.makeObject(SyncConfigNodeIServiceClient.java:94)
      at org.apache.commons.pool2.impl.GenericKeyedObjectPool.create(GenericKeyedObjectPool.java:780)
      at org.apache.commons.pool2.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:439)
      at org.apache.commons.pool2.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:350)
      at org.apache.iotdb.commons.client.ClientManager.borrowClient(ClientManager.java:53)
      ... 6 common frames omitted
      Caused by: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused (Connection refused)
      at org.apache.thrift.transport.TSocket.open(TSocket.java:243)
      at org.apache.iotdb.rpc.TElasticFramedTransport.open(TElasticFramedTransport.java:91)
      at org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient.<init>(SyncConfigNodeIServiceClient.java:62)
      at org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient$$EnhancerByCGLIB$$74177f2d.<init>(<generated>)
      at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
      at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
      at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
      at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
      at net.sf.cglib.core.ReflectUtils.newInstance(ReflectUtils.java:228)
      ... 19 common frames omitted
      Caused by: java.net.ConnectException: Connection refused (Connection refused)
      at java.net.PlainSocketImpl.socketConnect(Native Method)
      at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
      at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
      at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
      at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
      at java.net.Socket.connect(Socket.java:589)
      at org.apache.thrift.transport.TSocket.open(TSocket.java:238)
      ... 27 common frames omitted
      2023-05-15 11:00:16,513 [main] ERROR o.a.i.c.s.ConfigNode:204 - Meet error while starting up.
      org.apache.iotdb.commons.exception.StartupException: All retry failed due to: net.sf.cglib.core.CodeGenerationException: org.apache.thrift.transport.TTransportException-->java.net.ConnectException: Connection refused (Connection refused)
      at org.apache.iotdb.confignode.service.ConfigNode.sendRestartConfigNodeRequest(ConfigNode.java:340)
      at org.apache.iotdb.confignode.service.ConfigNode.active(ConfigNode.java:115)
      at org.apache.iotdb.confignode.service.ConfigNodeCommandLine.run(ConfigNodeCommandLine.java:78)
      at org.apache.iotdb.commons.ServerCommandLine.doMain(ServerCommandLine.java:58)
      at org.apache.iotdb.confignode.service.ConfigNode.main(ConfigNode.java:90)
      2023-05-15 11:00:16,514 [main] INFO o.a.i.c.s.ConfigNode:362 - Deactivating IoTDB-ConfigNode...
      2023-05-15 11:00:16,514 [main] INFO o.a.i.c.s.RegisterManager:67 - deregister all service.
      2023-05-15 11:00:16,514 [main] INFO o.a.i.c.s.ConfigNode:368 - IoTDB-ConfigNode is deactivated.

      测试环境
      1. 启动2C5D 8CPU 32GB内存
      测试版本:Enterprise version 1.1.1-SNAPSHOT (Build: 4e34fa6)
      2C : 172.20.70.5 / 4
      5D :
      172.20.70.26
      172.20.70.14
      172.20.70.27
      172.20.70.30
      显式配置参数
      COMMON 参数显式配置:
      schema_replication_factor=3
      data_replication_factor=2
      time_partition_interval=86400000
      config_node_ratis_snapshot_trigger_threshold=10000
      schema_region_ratis_snapshot_trigger_threshold=10000
      schema_region_group_extension_policy=CUSTOM
      data_region_group_extension_policy=CUSTOM
      default_data_region_group_num_per_database=9
      default_schema_region_group_num_per_database=3
      fsync_wal_delay_in_ms=1000
      wal_buffer_size_in_byte=167772160
      wal_file_size_threshold_in_byte=104857600
      wal_buffer_queue_capacity=1000
      iot_consensus_throttle_threshold_in_byte=536870912000
      CONFIGNODE ENV:
      MAX_HEAP_SIZE="4G"
      HEAP_NEWSIZE="4G"
      MAX_DIRECT_MEMORY_SIZE="2G"
      DATANODE ENV:
      MAX_HEAP_SIZE="20G"
      HEAP_NEWSIZE="20G"
      MAX_DIRECT_MEMORY_SIZE="2G"
      2. 启动Benchmark 写入数据 配置参数见附件1.conf
      bm在172.20.70.13 /data/iotdb/benchmark/bm_20230428_e7dad04
      3. 查看ip5 (Leader) ConfigNode 的 日志
      触发几次snapshot后,(扩容)启动ip14的confignode
      [图片]

      查看ip14的confignode日志:

      4. 等待benchmark写入完成
      此时ip5的confignode snapshot信息

      5. 连ip30 执行flush ,成功
      /data/iotdb/t_rc3_0514_4e34fa6/sbin/start-cli.sh -h 172.20.70.30 -e 'flush'

      以下脚本的位置在:172.20.70.3 /data/iotdb/cluster_shell
      6. 停止集群,先停止5D,再停止3C ,脚本见附件
      only_stop_dn.sh
      only_stop_timecho_cn.sh
      7.各节点清操作系统缓存
      脚本见附件clear_cache.sh
      8.启动集群 先启动3C ,再启动5D
      启动3C的脚本
      start_timecho_cn.sh
      启动5D的脚本
      start_timecho_dn.sh
      9.查看集群状态,全部节点是Running
      查询某个设备的count(s_0) 成功
      10. stop ip5的confignode ,stop ip4的confignode 服务
      只有ip14的confignode服务在线,执行查询,失败:
      /data/iotdb/t_rc3_0514_4e34fa6/sbin/start-cli.sh -h 172.20.70.30 -e 'show regions'
      Msg: 305: Error in calling method showRegion, because: Fail to connect to any config node. Please check status of ConfigNodes
      11.启动ip4的confignode 服务,失败。
      所有的各节点日志见附件。

      Attachments

        1. start_timecho_dn.sh
          0.9 kB
          刘珍
        2. start_timecho_cn.sh
          0.7 kB
          刘珍
        3. only_stop_timecho_cn.sh
          1 kB
          刘珍
        4. only_stop_dn.sh
          1 kB
          刘珍
        5. ip5_logs.tar.gz
          87 kB
          刘珍
        6. ip4_logs.tar.gz
          6.94 MB
          刘珍
        7. ip4_conf.tar.gz
          25 kB
          刘珍
        8. ip30_logs.tar.gz
          4.61 MB
          刘珍
        9. ip27_logs.tar.gz
          5.73 MB
          刘珍
        10. ip26_logs.tar.gz
          3.28 MB
          刘珍
        11. ip14_logs.tar.gz
          4.82 MB
          刘珍
        12. image-2023-05-15-15-21-40-565.png
          88 kB
          刘珍
        13. image-2023-05-15-15-21-11-259.png
          47 kB
          刘珍
        14. image-2023-05-15-15-15-39-161.png
          136 kB
          刘珍
        15. 1.conf
          14 kB
          刘珍

        Activity

          People

            William Song Song Ziyang
            刘珍 刘珍
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: