Hacktoberfest 2026: die Issues, die Maintainer für den Oktober markiert haben – offen und einsteigerfreundlich. Hacktoberfest-Issues durchsuchen

[Bug] Java SDK 自动发现持续选择已断网的 DataNode，导致查询周期性等待连接超时

Offen
#18,633 2 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen

Dieses Issue hat noch niemand übernommen.

Bewertung

Schwierigkeit
4/5
Geschätzter Aufwand
3-5 Tage
Anfängerfreundlichkeit
48/100
Issue-Typ
Bug
Klarheit
Größtenteils klar
Aktivitätsstatus
Aktiv
Tech-Stack
java
Bereich
databases, distributed-systems

Rechercherichtung

Beginnen Sie mit ShowAvailableUrlsTask.java, NodesSupplier.java und Session.java an den verknüpften v2.0.11-Stellen. Reproduzieren Sie anschließend das TableSessionPoolBuilder-Szenario mit einem getrennten Knoten und vergleichen Sie die aktivierte und deaktivierte auto-discovery. Verfolgen Sie, wie nicht verfügbare Endpunkte ausgewählt werden und wie fehlgeschlagene Verbindungen behandelt werden. Das Ziel ist erreicht, wenn die wiederholte Verzögerung durch Verbindungs-Timeouts verhindert wird, während gesunde Knoten weiterhin Abfragen bedienen und eine Wiederherstellung möglich bleibt.

Vom Indexierungsmodell aus dem Issue-Text verfasst.

Beschreibung

现象与复现

IoTDB 服务端和 Java SDK 均为 2.0.10，Table model，三节点各部署 ConfigNode/DataNode；Schema 三副本，Data 两副本，数据共识为 IoTConsensus。

  1. 将节点 A 断网，保持 B/C 正常。等待 SHOW CLUSTER 显示 A 为 Unknown、B/C 为 Running。
  2. 此时 SHOW AVAILABLE URLS 仍返回 A/B/C 三个地址。
  3. 使用原生 TableSessionPoolBuilder，初始 nodeUrls 只配置 B/C，设置 maxSize(1)、connectionTimeoutInMs(3000)，开启 enableAutoFetch(true) 和 enableRedirection(true)，串行重复执行同一条 SELECT … LIMIT 5，完整读取并关闭结果集。

绕过业务适配层仍能复现，12 次查询均成功返回 5 行：

设置 12 次查询结果
自动发现、重定向均开启 第 1/4/7/10 次分别约 2423/2976/3029/3028 ms，其余约 22–29 ms
两项均关闭，其他配置及 SQL 不变 全部约 21–30 ms

节点 A 在整个对照期间保持断网。即使初始地址仅填写 B/C，自动发现仍会将 A 加回查询候选列表。这不是故障发生瞬间的一次切换等待，而是持续的周期性延迟。

关键源码

以下链接固定到 v2.0.11：对比发现，本问题涉及的关键逻辑仍保留；尚未在完整 2.0.11 集群实测复现。

1. 服务端仅排除 Removing，没有排除 Unknown。

ShowAvailableUrlsTask.buildTsBlock()：

for (TDataNodeInfo dataNodeInfo : showDataNodesResp.getDataNodesInfoList()) {
  String status = dataNodeInfo.getStatus();
  if (RegionStatus.Removing.getStatus().equals(status)) {
    continue;
  }

2. SDK 根据发现列表轮询端点。

NodesSupplier 使用以下策略；getQueryEndPoint() 调用 policy.chooseOne(get())：

private final QueryEndPointPolicy policy = new RoundRobinPolicy();

3. 连接失败后回落默认连接，但没有在该路径隔离失败端点。

Session.getQuerySessionConnection()，该方法与 2.0.10 完全一致：

endPointToSessionConnection.computeIfAbsent(
    endPoint.get(),
    k -> {
      try {
        return constructSessionConnection(this, endPoint.get(), zoneId);
      } catch (IoTDBConnectionException ex) {
        return null;
      }
    });

computeIfAbsent 返回 null 时不会保存映射；方法随后回落到默认连接。故障地址仍留在轮询列表，下次选中时再次尝试连接，和实测“每三次出现一次秒级等待”吻合。

期望与希望确认

当一个节点持续不可达且其他节点可完成查询时，希望 SDK 能暂时隔离失败端点并探测恢复，避免后续查询反复承担完整连接超时。

请确认：SHOW AVAILABLE URLS 包含 Unknown 是否为预期？此场景是否应由 SDK 增加故障端点退避/隔离，或调整服务端过滤规则？是否已有对应修复或推荐配置？

目前临时通过关闭自动发现、重定向并只配置健康节点规避，但这需要用户手动维护节点列表。

Vorherrschende Sprache
Java
Sterne
6.4k
Forks
1.2k
Ø Merge
1 T. 17 Std.
Gemergte PRs (30 T.)
152

Beitragsleitfaden

Beitragsleitfaden öffnen

Erste Schritte

  1. Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
  2. Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
  3. Forken Sie das Repository und arbeiten Sie in einem Branch.
  4. Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.

Mehr aus apache/iotdb

Alle Issues in apache/iotdb

Ähnliche Issues

Weitere Issues zu Java

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.