This is an automated email from the ASF dual-hosted git repository.
sunnianjun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new bca041fbe60 Fix sonar issues (#32254)
bca041fbe60 is described below
commit bca041fbe604a6af2836ae897e0484464c7a8621
Author: Haoran Meng <[email protected]>
AuthorDate: Wed Jul 24 22:45:06 2024 +0800
Fix sonar issues (#32254)
---
.../shardingsphere/mode/metadata/refresher/MetaDataRefreshEngine.java | 1 +
.../mode/persist/service/ComputeNodePersistServiceTest.java | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefreshEngine.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefreshEngine.java
index e4bac058e0a..aaf884789ae 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefreshEngine.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/MetaDataRefreshEngine.java
@@ -101,6 +101,7 @@ public final class MetaDataRefreshEngine {
return getFederationMetaDataRefresher(sqlStatementContext).isPresent();
}
+ @SuppressWarnings("rawtypes")
private Optional<FederationMetaDataRefresher>
getFederationMetaDataRefresher(final SQLStatementContext sqlStatementContext) {
Class<? extends SQLStatement> sqlStatementClass =
sqlStatementContext.getSqlStatement().getClass();
return TypedSPILoader.findService(FederationMetaDataRefresher.class,
sqlStatementClass.getSuperclass());
diff --git
a/mode/core/src/test/java/org/apache/shardingsphere/mode/persist/service/ComputeNodePersistServiceTest.java
b/mode/core/src/test/java/org/apache/shardingsphere/mode/persist/service/ComputeNodePersistServiceTest.java
index 0ade84a10ba..2047b4e2b20 100644
---
a/mode/core/src/test/java/org/apache/shardingsphere/mode/persist/service/ComputeNodePersistServiceTest.java
+++
b/mode/core/src/test/java/org/apache/shardingsphere/mode/persist/service/ComputeNodePersistServiceTest.java
@@ -149,6 +149,6 @@ class ComputeNodePersistServiceTest {
void assertOffline() {
ComputeNodeInstance computeNodeInstance = new ComputeNodeInstance(new
ProxyInstanceMetaData("foo_instance_id", 3307));
new ComputeNodePersistService(repository).offline(computeNodeInstance);
- verify(repository).delete(eq("/nodes/compute_nodes/online/proxy/" +
computeNodeInstance.getMetaData().getId()));
+ verify(repository).delete("/nodes/compute_nodes/online/proxy/" +
computeNodeInstance.getMetaData().getId());
}
}