This is an automated email from the ASF dual-hosted git repository.
zhaojinchao 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 ef71d184142 Fix broadcast event builder (#26625)
ef71d184142 is described below
commit ef71d184142979c993694e36b077d2bfd7b78365
Author: ChenJiaHao <[email protected]>
AuthorDate: Tue Jun 27 18:20:59 2023 +0800
Fix broadcast event builder (#26625)
---
.../broadcast/event/BroadcastRuleConfigurationEventBuilder.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/event/BroadcastRuleConfigurationEventBuilder.java
b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/event/BroadcastRuleConfigurationEventBuilder.java
index a60e0a7ee15..8b856ba8cc1 100644
---
a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/event/BroadcastRuleConfigurationEventBuilder.java
+++
b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/event/BroadcastRuleConfigurationEventBuilder.java
@@ -42,7 +42,7 @@ public final class BroadcastRuleConfigurationEventBuilder
implements RuleConfigu
if (!broadcastRuleNodePath.getRoot().isValidatedPath(event.getKey())
|| Strings.isNullOrEmpty(event.getValue())) {
return Optional.empty();
}
- if
(broadcastRuleNodePath.getNamedItem(BroadcastNodePath.TABLES).getNameByActiveVersion(event.getKey()).isPresent()
&& !Strings.isNullOrEmpty(event.getValue())) {
+ if
(broadcastRuleNodePath.getUniqueItem(BroadcastNodePath.TABLES).isActiveVersionPath(event.getKey())
&& !Strings.isNullOrEmpty(event.getValue())) {
return createBroadcastConfigEvent(databaseName, event);
}
return Optional.empty();