Skip to content

Commit

Permalink
Rename variables and add attributes
Browse files Browse the repository at this point in the history
  • Loading branch information
malvads committed Apr 30, 2024
2 parents 10301b6 + 17142d4 commit 0ffad4b
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 2 deletions.
2 changes: 2 additions & 0 deletions resources/attributes/default.rb
Original file line number Diff line number Diff line change
Expand Up @@ -211,5 +211,7 @@
default["redborder"]["druid"]["historical"]["tier"] = "default"
default["redborder"]["druid"]["historical"]["maxsize"] = -1

# Realtime
default["redborder"]["druid"]["realtime"]["partition_num"] = 0

default["redborder"]["pending_changes"]=0
3 changes: 2 additions & 1 deletion resources/recipes/configure.rb
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,8 @@
druid_realtime "Configure Druid Realtime" do
name node["hostname"]
ipaddress node["ipaddress_sync"]
partition_num node["redborder"]["druid_realtime"]["partition_num"]
partition_num node["redborder"]["druid"]["realtime"]["partition_num"]
zookeeper_hosts node["redborder"]["zookeeper"]["zk_hosts"]
memory_kb node["redborder"]["memory_services"]["druid-realtime"]["memory"]
action (manager_services["druid-realtime"] ? [:add, :register] : [:remove, :deregister])
end
Expand Down
2 changes: 1 addition & 1 deletion resources/recipes/prepare_system.rb
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@

#set druid realtime partition id (its needed in cluster mode for druid brokers)
if node["redborder"]["manager_per_services"]["druid_realtime"].include?(node.name)
node.default["redborder"]["druid_realtime"]["partition_num"] = node["redborder"]["manager_per_services"]["druid_realtime"].index(node.name)
node.default["redborder"]["druid"]["realtime"]["partition_num"] = node["redborder"]["manager_per_services"]["druid_realtime"].index(node.name)
end

#get an array of managers
Expand Down

0 comments on commit 0ffad4b

Please sign in to comment.