This is an automated email from the ASF dual-hosted git repository.
cameronlee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new aefd705 [Checkstyle] Fix checkstyle indentation error (#1025)
aefd705 is described below
commit aefd705cbd27cb69dcef5af46928bd03fd864a63
Author: mynameborat <[email protected]>
AuthorDate: Thu May 9 13:19:47 2019 -0700
[Checkstyle] Fix checkstyle indentation error (#1025)
---
.../samza/table/remote/couchbase/CouchbaseTableWriteFunction.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java
b/samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java
index 42de583..cbdcb00 100644
---
a/samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java
+++
b/samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java
@@ -74,7 +74,7 @@ public class CouchbaseTableWriteFunction<V> extends
BaseCouchbaseTableFunction<V
: BinaryDocument.create(key, (int) ttl.getSeconds(),
Unpooled.copiedBuffer(valueSerde.toBytes(record)));
return asyncWriteHelper(bucket.async().upsert(document,
timeout.toMillis(), TimeUnit.MILLISECONDS).toSingle(),
String.format("Failed to insert key %s into bucket %s", key,
bucketName));
-}
+ }
@Override
public CompletableFuture<Void> deleteAsync(String key) {
