You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2023/06/29 12:18:09 UTC

[shardingsphere] branch master updated: Fix creating transaction hook when global clock is not enabled (#26694)

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 14753c0014b Fix creating transaction hook when global clock is not enabled (#26694)
14753c0014b is described below

commit 14753c0014b207165bffbdd05ddc4bcf0fdaa3bd
Author: ZhangCheng <ch...@apache.org>
AuthorDate: Thu Jun 29 20:18:01 2023 +0800

    Fix creating transaction hook when global clock is not enabled (#26694)
---
 .../apache/shardingsphere/globalclock/core/rule/GlobalClockRule.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/rule/GlobalClockRule.java b/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/rule/GlobalClockRule.java
index 868d3514779..5081ed150bf 100644
--- a/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/rule/GlobalClockRule.java
+++ b/kernel/global-clock/core/src/main/java/org/apache/shardingsphere/globalclock/core/rule/GlobalClockRule.java
@@ -44,8 +44,8 @@ public final class GlobalClockRule implements GlobalRule {
         configuration = ruleConfig;
         if (ruleConfig.isEnabled()) {
             TypedSPILoader.getService(GlobalClockProvider.class, getGlobalClockProviderType(), configuration.getProps());
+            TypedSPILoader.getService(TransactionHook.class, "GLOBAL_CLOCK", getProps(databases));
         }
-        TypedSPILoader.getService(TransactionHook.class, "GLOBAL_CLOCK", getProps(databases));
     }
     
     private Properties getProps(final Map<String, ShardingSphereDatabase> databases) {