diff --git a/wrapper/src/main/java/software/amazon/jdbc/plugin/failover/ClusterAwareReaderFailoverHandler.java b/wrapper/src/main/java/software/amazon/jdbc/plugin/failover/ClusterAwareReaderFailoverHandler.java index 58af99059..0feb0c75b 100644 --- a/wrapper/src/main/java/software/amazon/jdbc/plugin/failover/ClusterAwareReaderFailoverHandler.java +++ b/wrapper/src/main/java/software/amazon/jdbc/plugin/failover/ClusterAwareReaderFailoverHandler.java @@ -396,7 +396,9 @@ public ReaderFailoverResult call() { new Object[] {this.newHost.getUrl(), initialConnectionProps})); try { - final Properties copy = new Properties(initialConnectionProps); + final Properties copy = new Properties(); + copy.putAll(initialConnectionProps); + final Connection conn = pluginService.forceConnect(this.newHost, copy); pluginService.setAvailability(this.newHost.asAliases(), HostAvailability.AVAILABLE); LOGGER.fine(