Stuck in the error: "Not Started" when try to access BigTable through Dataflow Pipeline

Question

我的管道很简单。

Pipeline p = Pipeline.create();
         p.apply("Read", (BigtableIO.read().withBigtableOptions(BIGTABLE_OPTIONS)).withKeyRange(keyRange).withTableId("myTable"));
        p.run().waitUntilFinish();

但是当我运行我不断收到：

Exception in thread "main" java.lang.IllegalStateException: **Not started**
    at com.google.common.base.Preconditions.checkState(Preconditions.java:459)
    at io.grpc.internal.ClientCallImpl.request(ClientCallImpl.java:344)
    at io.grpc.ForwardingClientCall.request(ForwardingClientCall.java:52)
    at io.grpc.ForwardingClientCall.request(ForwardingClientCall.java:52)
    at io.grpc.ForwardingClientCall.request(ForwardingClientCall.java:52)
    at io.grpc.stub.ClientCalls.startCall(ClientCalls.java:276)
    at io.grpc.stub.ClientCalls.asyncUnaryRequestCall(ClientCalls.java:249)
    at io.grpc.stub.ClientCalls.futureUnaryCall(ClientCalls.java:186)
    at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:132)
    at com.google.bigtable.admin.v2.BigtableTableAdminGrpc$BigtableTableAdminBlockingStub.getTable(BigtableTableAdminGrpc.java:381)
    at com.google.cloud.bigtable.grpc.BigtableTableAdminGrpcClient.getTable(BigtableTableAdminGrpcClient.java:58)
    at org.apache.beam.sdk.io.gcp.bigtable.BigtableServiceImpl.tableExists(BigtableServiceImpl.java:82)
    at org.apache.beam.sdk.io.gcp.bigtable.BigtableIO$Read.validate(BigtableIO.java:294)
    at org.apache.beam.sdk.Pipeline$ValidateVisitor.enterCompositeTransform(Pipeline.java:578)
    at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:482)
    at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:486)
    at org.apache.beam.sdk.runners.TransformHierarchy$Node.access0(TransformHierarchy.java:235)
    at org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:210)
    at org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:409)
    at org.apache.beam.sdk.Pipeline.validate(Pipeline.java:520)
    at org.apache.beam.sdk.Pipeline.run(Pipeline.java:294)
    at org.apache.beam.sdk.Pipeline.run(Pipeline.java:281)

我已经在 IDE 内部尝试过，在外部通过命令行尝试过。

每次尝试我都会收到此错误。

我运行正在Windows环境中。

如有任何帮助，我们将不胜感激。

谢谢。

Answer 1

我认为这是 Cloud Bigtable 客户端中的一个问题，已在更高版本中修复。 Beam 2.1.0使用新版本，请尝试使用Beam 2.1.0，如果问题仍然存在，请告诉我们。

Stuck in the error: "Not Started" when try to access BigTable through Dataflow Pipeline

Stuck in the error: "Not Started" when try to access BigTable through Dataflow Pipeline

google-cloud-dataflow

google-cloud-bigtable