Tag: bucket

Couchbase Bucket身份validation错误

使用Couchbase 5.0及其Java客户端2.0.3，我有以下错误。 只需按照这些说明打开一个桶： https://developer.couchbase.com/documentation/server/current/sdk/java/managing-connections.html 如上所述，使用基本的本地配置，只需两行代码： Cluster cluster = CouchbaseCluster.create(); Bucket bucket = cluster.openBucket(“hero”); 这应该打开localhost集群（实际上是这样），然后打开一个名为“hero”的存储桶，它实际存在于我的Couchbase服务器中。 不过，我一直收到以下错误： 2017-11-08 00:40:25.546 ERROR 1077 — [nio-8080-exec-1] oaccC[.[.[/].[dispatcherServlet] : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is com.couchbase.client.java.error.InvalidPasswordException: Passwords for bucket “hero” do not match.] with root cause com.couchbase.client.java.error.InvalidPasswordException: Passwords for bucket […]

如何在Scalding中输出数据

我正在尝试将管道输出到不同的目录中，以便每个目录的输出将基于某些ID进行分区。 所以在一个普通的地图中减少代码我会使用MultipleOutputs类，我会在reducer中做这样的事情。 protected void reduce(final SomeKey key, final Iterable values, final Context context) { … for (SomeValue value: values) { String bucketId = computeBucketIdFrom(…); multipleOutputs.write(key, value, folderName + “/” + bucketId); … 所以我想在烫伤时可以这样做 … val somePipe = Csv(in, separator = “\t”, fields = someSchema, skipHeader = true) .read for (i (id.hashCode % numberOfBuckets) == i} […]