We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ea8f425 commit c40c082Copy full SHA for c40c082
1 file changed
plugin/trino-couchbase/src/main/java/io/trino/plugin/couchbase/CouchbaseClient.java
@@ -88,7 +88,20 @@ public CouchbaseClient(CouchbaseConfig config)
88
}));
89
}
90
else {
91
- cluster = Cluster.connect(config.getCluster(), config.getUsername(), config.getPassword());
+ cluster = Cluster.connect(
92
+ config.getCluster(),
93
+ ClusterOptions.clusterOptions(config.getUsername(), config.getPassword())
94
+ .environment(env -> {
95
+ env.securityConfig(security -> {
96
+ if (config.getTlsCertificate() != null) {
97
+ security.trustCertificate(Path.of(config.getTlsCertificate()));
98
+ }
99
+ });
100
+ env.timeoutConfig(timeout -> {
101
+ timeout.kvTimeout(config.getTimeouts());
102
+ timeout.queryTimeout(config.getTimeouts());
103
104
+ }));
105
106
107
catch (Exception e) {
0 commit comments