Hi @csoulios, since you've updated the version of the Bigtable client library in to address issue #16, could you please build a new version of the library and update OpenTSDB library deps accordingly?

The latest version on Maven Central is currently 0.1.0 from Oct 2015, which is quite out-of-date.

Thanks!

I want to make some exist calls, but it's private in GetRequest.java

Hi - we are using version 0.4.3 in our application using OpenTSDB. We ran a Prisma scan against it and vulnerabilities were found with regards to asyncbigtable-0.4.3-jar-with-dependencies.jar. Can we attach the Prisma report here for your reference? Or there is some other process/email/mailing list to report vulnerabilities?

Looks like Travis CI is not enabled for this repo, and I lack the permissions to do so.

@manolama — would you mind visiting https://travis-ci.org/OpenTSDB/asyncbigtable and enabling it for the repo, including the master branch and all new PRs?

I can submit a boilerplate .travis.yml file that will help get the process started.

Thanks!

I was getting this error from time to time when I was doing some highly concurrent writes using the driver. I'm using a single instance of the HBaseClient from many threads that are all doing AtomicIncrementRequest. I'm also flushing the client in a timer only from the main thread. In the BigTable dashboard I saw that I was doing like 800 write req/s on a development type instance.

1. is HBaseClient thread safe?
2. if 1) is yes. I see that the com.google.cloud.bigtable.hbase2_x.FutureUtils class doesn't provide executor when calling toCompletableFuture() method and that might be the issue as well.
   What do you guys think is the problem here and how to resolve it?

ERROR [org.hbase.async.HBaseClient] BigTable API: CompletableFuture failed with exception java.util.concurrent.CompletionException: io.grpc.StatusRuntimeException: ABORTED: ReadModifyWrite failed: too many concurrent modifications. at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:593) at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) at com.google.cloud.bigtable.hbase2_x.FutureUtils$2.onFailure(FutureUtils.java:51) at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1228) at com.google.common.util.concurrent.MoreExecutors$DirectExecutor.execute(MoreExecutors.java:399) at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:911) at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:822) at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:686) at com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation$GrpcFuture.setException(AbstractRetryingOperation.java:119) at com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation.setException(AbstractRetryingOperation.java:271) at com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation.onError(AbstractRetryingOperation.java:222) at com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation.onClose(AbstractRetryingOperation.java:187) at com.google.cloud.bigtable.grpc.io.ChannelPool$InstrumentedChannel$2.onClose(ChannelPool.java:210) at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:41) at com.google.cloud.bigtable.grpc.io.RefreshingOAuth2CredentialsInterceptor$UnAuthResponseListener.onClose(RefreshingOAuth2CredentialsInterceptor.java:85) at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:41) at io.grpc.internal.CensusStatsModule$StatsClientInterceptor$1$1.onClose(CensusStatsModule.java:684) at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:41) at io.grpc.internal.CensusTracingModule$TracingClientInterceptor$1$1.onClose(CensusTracingModule.java:391) at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:475) at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:63) at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.close(ClientCallImpl.java:557) at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.access$600(ClientCallImpl.java:478) at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:590) at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: io.grpc.StatusRuntimeException: ABORTED: ReadModifyWrite failed: too many concurrent modifications. at io.grpc.Status.asRuntimeException(Status.java:517) ... 19 more

The README currently says:

Changelog

This project uses Semantic Versioning.

0.3.0

[...]

0.2.1

[...]

However, it doesn't appear that v0.2.1 was ever released or published. If we search on Maven Central, the only version of com.pythian.opentsdb that appears is v0.1.0, there's no mention of v0.2.1 .

So, is the "0.2.1" heading here supposed to be changed to 0.1.0 instead? Or was there a release of 0.2.1 somewhere that's not obvious?

I believe 0.2.1 was at some point added to pom.xml as a version, it might have not just been built and released, so perhaps there was another 0.1.0 release prior to that?

On the other hand, OpenTSDB depends on asyncbigtable 0.2.1-20160228.235952-3, but that version isn't listed as a version of com.pythian.opentsdb/asyncbigtable, so it's confusing as to where it comes from.

Would be nice to clarify the history of this module for clarity:

• add v0.1.0 with features, date of release, etc.
• clarify where v0.2.x was released and how

@csoulios, I'm guessing you're the expert on the history of this module, so would be great to get an authoritative record from you.

In HBaseClient, the hbase_connection is private final. This makes it impossible for me to interface with Bigtable's admin operations

Hey guys,
I'm trying to delete a row with a simple DeleteRequest but the data never gets deleted :(
The table is set with gc policy: versions() > 1
Create, Update and Read operations work as expected, but Delete is not working.
And the addErrback() on the deferred is never called.

DeleteRequest del = new DeleteRequest(TABLE, KEY, FAMILY); Deferred<Object> callback = CLIENT.delete(del); callback.addErrback(eb -> { System.out.println("errback: " + eb.toString()); return null; }); CLIENT.flush().join(); callback.join();

When I read the data after that operation, it's still there.
Please, help me out.

com.google.cloud.bigtable.hbase.adapters.filters.UnsupportedFilterException: Unsupported filters encountered: FilterSupportStatus{isSupported=false, reason='Don't know how to adapt Filter class 'class org.apache.hadoop.hbase.filter.RowFilter''}

Found while trying to use the API in opentsdb to delete some timeseries. The code in question for opentsdb is: https://github.com/OpenTSDB/opentsdb/blob/master/src/core/TsdbQuery.java#L781

final DeleteRequest del = new DeleteRequest(tsdb.dataTable(), key);

The result of System.out.println(del):

DeleteRequest(table="tsdb", key=[0, 0...], family="", qualifiers=[""], attempt=0, region=)

The function in asyncbigtable is:

https://github.com/OpenTSDB/asyncbigtable/blob/master/src/main/java/org/hbase/async/DeleteRequest.java#L69

  public DeleteRequest(final byte[] table, final byte[] key) {
    this(table, key, null, null, KeyValue.TIMESTAMP_NOW, RowLock.NO_LOCK);
  }

Exception from asyncbigtable

2017-11-14 13:02:03,372 ERROR [OpenTSDB I/O Worker #5] BigtableTable: Encountered exception when executing delete.
com.google.bigtable.repackaged.io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Error in field 'Mutation list' : Error in element #0 : Invalid id for collection columnFamilies : Length should be between [1,64], but found 0 ''
at com.google.bigtable.repackaged.io.grpc.Status.asRuntimeException(Status.java:503) ~[asyncbigtable-0.2.2-SNAPSHOT-jar-with-dependencies.jar:na]
at com.google.cloud.bigtable.grpc.BigtableDataGrpcClient.getBlockingResult(BigtableDataGrpcClient.java:396) ~[asyncbigtable-0.2.2-SNAPSHOT-jar-with-dependencies.jar:na]
at com.google.cloud.bigtable.grpc.BigtableDataGrpcClient.getBlockingUnaryResult(BigtableDataGrpcClient.java:358) ~[asyncbigtable-0.2.2-SNAPSHOT-jar-with-dependencies.jar:na]
at com.google.cloud.bigtable.grpc.BigtableDataGrpcClient.mutateRow(BigtableDataGrpcClient.java:255) ~[asyncbigtable-0.2.2-SNAPSHOT-jar-with-dependencies.jar:na]
at com.google.cloud.bigtable.hbase.BigtableTable.delete(BigtableTable.java:347) ~[asyncbigtable-0.2.2-SNAPSHOT-jar-with-dependencies.jar:na]
at org.hbase.async.HBaseClient.delete(HBaseClient.java:1228) [asyncbigtable-0.2.2-SNAPSHOT-jar-with-dependencies.jar:na]
at net.opentsdb.core.TsdbQuery$1ScannerCB.processRow(TsdbQuery.java:782) [tsdb-2.3.0.jar:b81ef90]
at net.opentsdb.core.TsdbQuery$1ScannerCB.call(TsdbQuery.java:750) [tsdb-2.3.0.jar:b81ef90]
at net.opentsdb.core.TsdbQuery$1ScannerCB.call(TsdbQuery.java:575) [tsdb-2.3.0.jar:b81ef90]
at com.stumbleupon.async.Deferred.doCall(Deferred.java:1278) [async-1.4.0.jar:na]
at com.stumbleupon.async.Deferred.addCallbacks(Deferred.java:688) [async-1.4.0.jar:na]
at com.stumbleupon.async.Deferred.addCallback(Deferred.java:724) [async-1.4.0.jar:na]
at net.opentsdb.core.TsdbQuery$1ScannerCB.scan(TsdbQuery.java:616) [tsdb-2.3.0.jar:b81ef90]
at net.opentsdb.core.TsdbQuery.findSpans(TsdbQuery.java:878) [tsdb-2.3.0.jar:b81ef90]
at net.opentsdb.core.TsdbQuery.runAsync(TsdbQuery.java:515) [tsdb-2.3.0.jar:b81ef90]
<snip>

Adding a family argument to the call makes the resulting request:

DeleteRequest(table="tsdb", key=[0, 0...], family="t", qualifiers=[""], attempt=0, region=)

Which does not throw the Exception however no rows are deleted as qualifiers is empty

Adding valid qualifiers to the argument deletes the cells as expected.

DeleteRequest(table="tsdb", key=[0, 0...], family="t", qualifiers=["\x00"], attempt=0, region=)

It seems that java 11 is not supported. I get that error when I try to read data from bigtable:

javax.net.ssl.SSLHandshakeException: General OpenSslEngine problem at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslContext$AbstractCertificateVerifier.verify(ReferenceCountedOpenSslContext.java:629) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.internal.tcnative.SSL.readFromSSL(Native Method) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslEngine.readPlaintextData(ReferenceCountedOpenSslEngine.java:511) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslEngine.unwrap(ReferenceCountedOpenSslEngine.java:1060) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslEngine.unwrap(ReferenceCountedOpenSslEngine.java:1169) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.SslHandler$SslEngineType$1.unwrap(SslHandler.java:211) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1297) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1199) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1243) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: java.lang.ClassCastException: class com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.OpenSslEngine cannot be cast to class sun.security.ssl.SSLEngineImpl (com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.OpenSslEngine is in unnamed module of loader 'app'; sun.security.ssl.SSLEngineImpl is in module java.base of loader 'bootstrap') at java.base/sun.security.ssl.SSLAlgorithmConstraints.<init>(SSLAlgorithmConstraints.java:132) at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:267) at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:141) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslClientContext$ExtendedTrustManagerVerifyCallback.verify(ReferenceCountedOpenSslClientContext.java:237) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslContext$AbstractCertificateVerifier.verify(ReferenceCountedOpenSslContext.java:625) ... 26 more } on channel 22. Trailers: Metadata(bigtable-channel-id=22)"} javax.net.ssl.SSLHandshakeException: General OpenSslEngine problem at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslContext$AbstractCertificateVerifier.verify(ReferenceCountedOpenSslContext.java:629) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.internal.tcnative.SSL.readFromSSL(Native Method) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslEngine.readPlaintextData(ReferenceCountedOpenSslEngine.java:511) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslEngine.unwrap(ReferenceCountedOpenSslEngine.java:1060) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslEngine.unwrap(ReferenceCountedOpenSslEngine.java:1169) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.SslHandler$SslEngineType$1.unwrap(SslHandler.java:211) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1297) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1199) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1243) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:502) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:441) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:278) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:579) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:496) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: java.lang.ClassCastException: class com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.OpenSslEngine cannot be cast to class sun.security.ssl.SSLEngineImpl (com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.OpenSslEngine is in unnamed module of loader 'app'; sun.security.ssl.SSLEngineImpl is in module java.base of loader 'bootstrap') at java.base/sun.security.ssl.SSLAlgorithmConstraints.<init>(SSLAlgorithmConstraints.java:132) at java.base/sun.security.ssl.X509TrustManagerImpl.checkTrusted(X509TrustManagerImpl.java:267) at java.base/sun.security.ssl.X509TrustManagerImpl.checkServerTrusted(X509TrustManagerImpl.java:141) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslClientContext$ExtendedTrustManagerVerifyCallback.verify(ReferenceCountedOpenSslClientContext.java:237) at com.google.bigtable.repackaged.io.grpc.netty.shaded.io.netty.handler.ssl.ReferenceCountedOpenSslContext$AbstractCertificateVerifier.verify(ReferenceCountedOpenSslContext.java:625) ... 26 more

I believe that this is because the bigtable driver uses old version of netty which does not support java 11. Am I right? Btw, the code runs fine on java 8.

The current Bigtable dependencies in pom.xml are as follows:

<dependency>
  <groupId>com.google.cloud.bigtable</groupId>
  <artifactId>bigtable-hbase-1.2</artifactId>
  <version>0.9.6</version>
</dependency>

<dependency>
  <groupId>io.netty</groupId>
  <artifactId>netty-tcnative-boringssl-static</artifactId>
  <version>1.1.33.Fork26</version>
</dependency>

This should be updated to either 0.9.7.x series or straight to 1.0.0 series (current latest version is 1.0.0-pre2; we can upgrade now or wait until 1.0.0 final is released).

@sduskis, @igorbernstein — what do you think?

As per @sduskis latest commits we now have the final 1.0.0 Bigtable client library dependency in pom.xml:

<dependency>
  <groupId>com.google.cloud.bigtable</groupId>
  <artifactId>bigtable-hbase-1.x</artifactId>
  <version>1.0.0</version>
</dependency>

Can we now properly close #24 by releasing an updated 0.3.2 asyncbigtable?

Currently the asyncbigtable version in OpenTSDB 2.4.0RC2 is broken (only 0.3.0 is uploaded):
https://github.com/OpenTSDB/opentsdb/blob/v2.4.0RC2/third_party/asyncbigtable/include.mk#L16

cc: @tsuna @mbrukman @manolama

I want to make some exist calls, but it's private in GetRequest.java

Hey guys,
maybe I'm missing something but I can't create a single PutRequest without calling flush on the client before that. If I don't call flush, the put request is blocked and never finishes.

Deferred<Object> result = client.put(new PutRequest(...)); result.join()

If I do only this, the call never finishes. So should I call flush to batch myself?

The mutators map is defined as:

ConcurrentHashMap<TableName, AsyncBufferedMutator> mutators

Here's getBufferedMutators():

  private AsyncBufferedMutator getBufferedMutator(TableName table) {
    AsyncBufferedMutator mutator = mutators.get(table);

    if (mutator == null) {
      synchronized (mutators) {
        mutator = hbase_asyncConnection.getBufferedMutator(table);
        mutators.put(table, mutator);
      }
    }

    return mutator;
  }

This logic won't work, since there's a race condition. Either use a regular HashMap, and synchronize around it, or use putIfAbsent in the right way.

E.g. http://localhost:4242/api/suggest/?type=metrics&q=&limit=10000 only returns 20 entries.

Can somebody please release the snapshot here https://oss.sonatype.org/content/repositories/snapshots?

The current version of Cloud Bigtable client used is 0.2.2-20151029.111903-12 which is quite old — there have been many newer versions of the client library released since then, and the performance has been improved significantly.

These release notes show the history of the Cloud Bigtable client releases.

The pom.xml file should be updated to use the latest version, and a new release of this module will enable OpenTSDB to use it directly without any additional work from the users.

cc: @csoulios, @sduskis

The size method returns the number of filters in the filter list. Since this isn't implemented by AsyncBigtable, it breaks the following test cases when building OpenTSDB:

../test/core/TestTsdbQueryQueries.java:1712: error: cannot find symbol
assertEquals(2, filter_list.size());
^
symbol: method size()
location: variable filter_list of type FilterList
../test/core/TestTsdbQueryQueries.java:1747: error: cannot find symbol
assertEquals(2, filter_list.size());
^
symbol: method size()
location: variable filter_list of type FilterList
../test/core/TestTsdbQueryQueries.java:1777: error: cannot find symbol
assertEquals(2, filter_list.size());