Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
dataroaring committed Sep 17, 2024
1 parent 6103b0c commit 8e9f94c
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -103,6 +103,10 @@ class DebugPoint {
def enableDebugPointForAllBEs(String name, Map<String, String> params = null) {
operateDebugPointForAllBEs({ host, port ->
logger.info("enable debug point ${name} with params ${params} for BE $host:$port")
if (port == -1) {
logger.info("skip for BE $host:$port")
return
}
enableDebugPoint(host, port, NodeType.BE, name, params)
})
}
Expand All @@ -111,6 +115,10 @@ class DebugPoint {
def disableDebugPointForAllBEs(String name) {
operateDebugPointForAllBEs { host, port ->
logger.info("disable debug point ${name} for BE $host:$port")
if (port == -1) {
logger.info("skip for BE $host:$port")
return
}
disableDebugPoint(host, port, NodeType.BE, name)
}
}
Expand All @@ -119,6 +127,10 @@ class DebugPoint {
def clearDebugPointsForAllBEs() {
operateDebugPointForAllBEs { host, port ->
logger.info("clear debug point for BE $host:$port")
if (port == -1) {
logger.info("skip for BE $host:$port")
return
}
clearDebugPoints(host, port, NodeType.BE)
}
}
Expand All @@ -137,6 +149,10 @@ class DebugPoint {
def enableDebugPointForAllFEs(String name, Map<String, String> params = null) {
operateDebugPointForAllFEs({ host, port ->
logger.info("enable debug point ${name} with params ${params} for FE $host:$port")
if (port == -1) {
logger.info("skip for FE $host:$port")
return
}
enableDebugPoint(host, port, NodeType.FE, name, params)
})
}
Expand All @@ -145,7 +161,7 @@ class DebugPoint {
operateDebugPointForAllFEs { host, port ->
logger.info("disable debug point ${name} for FE $host:$port")
if (port == -1) {
logger.info("skip for BE $host:$port")
logger.info("skip for FE $host:$port")
return
}
disableDebugPoint(host, port, NodeType.FE, name)
Expand All @@ -156,7 +172,7 @@ class DebugPoint {
operateDebugPointForAllFEs { host, port ->
logger.info("clear debug point for FE $host:$port")
if (port == -1) {
logger.info("skip for BE $host:$port")
logger.info("skip for FE $host:$port")
return
}
clearDebugPoints(host, port, NodeType.FE)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,7 @@ suite("test_grant_revoke_compute_group_to_user", "cloud_auth") {
}

def groups = sql " SHOW COMPUTE GROUPS; "
logger.info("compute groups {}", groups);
assertTrue(!groups.isEmpty())
def validCluster = groups[0][0]

Expand Down

0 comments on commit 8e9f94c

Please sign in to comment.