Skip to content

Commit 5dbc2ae

Browse files
committed
more cleanup
1 parent 4f3ea33 commit 5dbc2ae

5 files changed

Lines changed: 3 additions & 21 deletions

File tree

docs/api-reference/service-status-api.md

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -413,7 +413,6 @@ Host: http://ROUTER_IP:ROUTER_PORT
413413
Retrieves a JSON map of the form `{"selfDiscovered": true/false}`, indicating whether the node has received a confirmation from the central node discovery mechanism (currently ZooKeeper) of the Druid cluster that the node has been added to the cluster.
414414

415415
Only consider a Druid node "healthy" or "ready" in automated deployment/container management systems when this endpoint returns `{"selfDiscovered": true}`. Nodes experiencing network issues may become isolated and are not healthy.
416-
For nodes that use Zookeeper segment discovery, a response of `{"selfDiscovered": true}` indicates that the node's Zookeeper client has started receiving data from the Zookeeper cluster, enabling timely discovery of segments and other nodes.
417416

418417
#### URL
419418

docs/configuration/index.md

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,6 @@ Druid interacts with ZooKeeper through a set of standard path configurations. We
154154
|Property|Description|Default|
155155
|--------|-----------|-------|
156156
|`druid.zk.paths.base`|Base ZooKeeper path.|`/druid`|
157-
|`druid.zk.paths.announcementsPath`|Druid service announcement path.|`${druid.zk.paths.base}/announcements`|
158157
|`druid.zk.paths.coordinatorPath`|Used by the Coordinator for leader election.|`${druid.zk.paths.base}/coordinator`|
159158

160159
The indexing service also uses its own set of paths. These configs can be included in the common configuration.
@@ -167,7 +166,7 @@ The indexing service also uses its own set of paths. These configs can be includ
167166
|`druid.zk.paths.indexer.statusPath`|Parent path for announcement of task statuses.|`${druid.zk.paths.indexer.base}/status`|
168167

169168
If `druid.zk.paths.base` and `druid.zk.paths.indexer.base` are both set, and none of the other `druid.zk.paths.*` or `druid.zk.paths.indexer.*` values are set, then the other properties will be evaluated relative to their respective `base`.
170-
For example, if `druid.zk.paths.base` is set to `/druid1` and `druid.zk.paths.indexer.base` is set to `/druid2` then `druid.zk.paths.announcementsPath` will default to `/druid1/announcements` while `druid.zk.paths.indexer.announcementsPath` will default to `/druid2/announcements`.
169+
For example, if `druid.zk.paths.base` is set to `/druid1` and `druid.zk.paths.indexer.base` is set to `/druid2` then `druid.zk.paths.coordinatorPath` will default to `/druid1/coordinator` while `druid.zk.paths.indexer.announcementsPath` will default to `/druid2/announcements`.
171170

172171
The following path is used for service discovery. It is **not** affected by `druid.zk.paths.base` and **must** be specified separately.
173172

docs/design/zookeeper.md

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -58,16 +58,10 @@ ${druid.zk.paths.overlordPath}/_OVERLORD
5858

5959
## Service announcement and discovery
6060

61-
All Druid services publish their presence by creating an ephemeral znode at
62-
63-
```
64-
${druid.zk.paths.announcementsPath}/${druid.host}
65-
```
66-
67-
In addition, each service announces a richer `DruidNode` record (host, port, role, services) under the internal-discovery path, so that other services can enumerate cluster members by role:
61+
Each Druid service announces a `DruidNode` record (host, port, role, services) under the internal-discovery path so that other services can enumerate cluster members by role:
6862

6963
```
7064
${druid.zk.paths.base}/internal-discovery/${nodeRole}/${druid.host}
7165
```
7266

73-
Brokers and Coordinators use this internal-discovery path to find Historicals, Peons, and Indexers. They then poll each discovered service's HTTP `/druid-internal/v1/segments` endpoint to get its current set of served segments.
67+
Brokers and Coordinators use this path to find Historicals, Peons, and Indexers. They then poll each discovered service's HTTP `/druid-internal/v1/segments` endpoint to get its current set of served segments.

server/src/main/java/org/apache/druid/server/initialization/ZkPathsConfig.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -27,20 +27,13 @@ public class ZkPathsConfig
2727
@JsonProperty
2828
private String base = "druid";
2929
@JsonProperty
30-
private String announcementsPath;
31-
@JsonProperty
3230
private String coordinatorPath;
3331

3432
public String getBase()
3533
{
3634
return base;
3735
}
3836

39-
public String getAnnouncementsPath()
40-
{
41-
return (null == announcementsPath) ? defaultPath("announcements") : announcementsPath;
42-
}
43-
4437
public String getCoordinatorPath()
4538
{
4639
return (null == coordinatorPath) ? defaultPath("coordinator") : coordinatorPath;
@@ -75,15 +68,13 @@ public boolean equals(Object other)
7568
}
7669
ZkPathsConfig otherConfig = (ZkPathsConfig) other;
7770
return this.getBase().equals(otherConfig.getBase()) &&
78-
this.getAnnouncementsPath().equals(otherConfig.getAnnouncementsPath()) &&
7971
this.getCoordinatorPath().equals(otherConfig.getCoordinatorPath());
8072
}
8173

8274
@Override
8375
public int hashCode()
8476
{
8577
int result = base != null ? base.hashCode() : 0;
86-
result = 31 * result + (announcementsPath != null ? announcementsPath.hashCode() : 0);
8778
result = 31 * result + (coordinatorPath != null ? coordinatorPath.hashCode() : 0);
8879
return result;
8980
}

server/src/test/java/org/apache/druid/initialization/ZkPathsConfigTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,6 @@ public void testOverrideBaseOnlyConfig()
5454

5555
propertyValues.clear();
5656
propertyValues.put(StringUtils.format("%s.base", CONFIG_PREFIX), base);
57-
propertyValues.put(StringUtils.format("%s.announcementsPath", CONFIG_PREFIX), ZKPaths.makePath(base, "announcements"));
5857
propertyValues.put(StringUtils.format("%s.coordinatorPath", CONFIG_PREFIX), ZKPaths.makePath(base, "coordinator"));
5958

6059
ZkPathsConfig zkPathsConfigObj = zkPathsConfig.get();

0 commit comments

Comments
 (0)