This is an automated email from the ASF dual-hosted git repository.
shirshanka pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new be1f28e [Gobblin-872][GOBBLIN-872] Only use one CouchbaseEnvironment
instane per JVM
be1f28e is described below
commit be1f28e0dd46149328f40825fe17a30a56ef55f9
Author: Zihan Li <[email protected]>
AuthorDate: Sat Sep 7 14:48:05 2019 -0700
[Gobblin-872][GOBBLIN-872] Only use one CouchbaseEnvironment instane per JVM
Closes #2727 from ZihanLi58/Couchbase
---
.../apache/gobblin/couchbase/writer/CouchbaseEnvironmentFactory.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseEnvironmentFactory.java
b/gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseEnvironmentFactory.java
index 102d6ed..084c172 100644
---
a/gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseEnvironmentFactory.java
+++
b/gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseEnvironmentFactory.java
@@ -57,7 +57,8 @@ public class CouchbaseEnvironmentFactory {
if (couchbaseEnvironment == null)
{
- return builder.build();
+ couchbaseEnvironment = builder.build();
+ return couchbaseEnvironment;
}
else {
return couchbaseEnvironment;