Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2487#discussion_r159097108
--- Diff:
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java ---
@@ -437,18 +436,14 @@ public void supervisorHeartbeat(String supervisorId,
SupervisorInfo info) {
public void workerBackpressure(String stormId, String node, Long port,
long timestamp) {
String path = ClusterUtils.backpressurePath(stormId, node, port);
boolean existed = stateStorage.node_exists(path, false);
+ if (timestamp <= 0) {
--- End diff --
This check could be moved to the top of the function, if the timestamp is
negative there's no reason to check if the znode exists.
---
