[ https://issues.apache.org/jira/browse/BEAM-6320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chamikara Jayalath reassigned BEAM-6320: ---------------------------------------- Assignee: (was: Chamikara Jayalath) > SpannerReadIT.testQuery flaky > ----------------------------- > > Key: BEAM-6320 > URL: https://issues.apache.org/jira/browse/BEAM-6320 > Project: Beam > Issue Type: Bug > Components: io-java-gcp > Reporter: Andrew Pilloud > Priority: Major > > https://builds.apache.org/job/beam_PostCommit_Java/2218/ > {code} > WARNING: No terminal state was returned. State value UNKNOWN > Dec 27, 2018 9:08:13 PM org.apache.beam.runners.dataflow.TestDataflowRunner > checkForPAssertSuccess > WARNING: Metrics not present for Dataflow job > 2018-12-27_13_02_39-18037927821693074732. > Dec 27, 2018 9:08:13 PM org.apache.beam.runners.dataflow.TestDataflowRunner > run > WARNING: Dataflow job 2018-12-27_13_02_39-18037927821693074732 did not output > a success or failure metric. > {code} > https://pantheon.corp.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-12-27_13_02_39-18037927821693074732?project=apache-beam-testing > {code} > com.google.cloud.spanner.SpannerException: NOT_FOUND: > io.grpc.StatusRuntimeException: NOT_FOUND: Database not found: > projects/apache-beam-testing/instances/beam-test/databases/beam-testdb-vkf2iqc72tevvroaop > resource_type: "type.googleapis.com/google.spanner.admin.database.v1.Database" > resource_name: > "projects/apache-beam-testing/instances/beam-test/databases/beam-testdb-vkf2iqc72tevvroaop" > description: "Database does not exist." > at > com.google.cloud.spanner.SpannerExceptionFactory.newSpannerExceptionPreformatted(SpannerExceptionFactory.java:119) > at > com.google.cloud.spanner.SpannerExceptionFactory.newSpannerException(SpannerExceptionFactory.java:43) > at > com.google.cloud.spanner.SpannerExceptionFactory.newSpannerException(SpannerExceptionFactory.java:80) > at > com.google.cloud.spanner.spi.v1.GrpcSpannerRpc.get(GrpcSpannerRpc.java:456) > at > com.google.cloud.spanner.spi.v1.GrpcSpannerRpc.createSession(GrpcSpannerRpc.java:350) > at com.google.cloud.spanner.SpannerImpl$2.call(SpannerImpl.java:258) > at com.google.cloud.spanner.SpannerImpl$2.call(SpannerImpl.java:255) > at > com.google.cloud.spanner.SpannerImpl.runWithRetries(SpannerImpl.java:227) > at > com.google.cloud.spanner.SpannerImpl.createSession(SpannerImpl.java:254) > at > com.google.cloud.spanner.BatchClientImpl.batchReadOnlyTransaction(BatchClientImpl.java:51) > at > org.apache.beam.sdk.io.gcp.spanner.CreateTransactionFn.processElement(CreateTransactionFn.java:47) > Caused by: java.util.concurrent.ExecutionException: > io.grpc.StatusRuntimeException: NOT_FOUND: Database not found: > projects/apache-beam-testing/instances/beam-test/databases/beam-testdb-vkf2iqc72tevvroaop > resource_type: "type.googleapis.com/google.spanner.admin.database.v1.Database" > resource_name: > "projects/apache-beam-testing/instances/beam-test/databases/beam-testdb-vkf2iqc72tevvroaop" > description: "Database does not exist." > at > com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:500) > at > com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:479) > at > com.google.cloud.spanner.spi.v1.GrpcSpannerRpc.get(GrpcSpannerRpc.java:450) > at > com.google.cloud.spanner.spi.v1.GrpcSpannerRpc.createSession(GrpcSpannerRpc.java:350) > at com.google.cloud.spanner.SpannerImpl$2.call(SpannerImpl.java:258) > at com.google.cloud.spanner.SpannerImpl$2.call(SpannerImpl.java:255) > at > com.google.cloud.spanner.SpannerImpl.runWithRetries(SpannerImpl.java:227) > at > com.google.cloud.spanner.SpannerImpl.createSession(SpannerImpl.java:254) > at > com.google.cloud.spanner.BatchClientImpl.batchReadOnlyTransaction(BatchClientImpl.java:51) > at > org.apache.beam.sdk.io.gcp.spanner.CreateTransactionFn.processElement(CreateTransactionFn.java:47) > at > org.apache.beam.sdk.io.gcp.spanner.CreateTransactionFn$DoFnInvoker.invokeProcessElement(Unknown > Source) > at > org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.invokeProcessElement(SimpleDoFnRunner.java:275) > at > org.apache.beam.runners.dataflow.worker.repackaged.org.apache.beam.runners.core.SimpleDoFnRunner.processElement(SimpleDoFnRunner.java:240) > at > org.apache.beam.runners.dataflow.worker.SimpleParDoFn.processElement(SimpleParDoFn.java:325) > at > org.apache.beam.runners.dataflow.worker.util.common.worker.ParDoOperation.process(ParDoOperation.java:44) > at > org.apache.beam.runners.dataflow.worker.util.common.worker.OutputReceiver.process(OutputReceiver.java:49) > at > org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.runReadLoop(ReadOperation.java:201) > at > org.apache.beam.runners.dataflow.worker.util.common.worker.ReadOperation.start(ReadOperation.java:159) > at > org.apache.beam.runners.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:76) > at > org.apache.beam.runners.dataflow.worker.BatchDataflowWorker.executeWork(BatchDataflowWorker.java:409) > at > org.apache.beam.runners.dataflow.worker.BatchDataflowWorker.doWork(BatchDataflowWorker.java:378) > at > org.apache.beam.runners.dataflow.worker.BatchDataflowWorker.getAndPerformWork(BatchDataflowWorker.java:306) > at > org.apache.beam.runners.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.doWork(DataflowBatchWorkerHarness.java:135) > at > org.apache.beam.runners.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:115) > at > org.apache.beam.runners.dataflow.worker.DataflowBatchWorkerHarness$WorkerThread.call(DataflowBatchWorkerHarness.java:102) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > Caused by: io.grpc.StatusRuntimeException: NOT_FOUND: Database not found: > projects/apache-beam-testing/instances/beam-test/databases/beam-testdb-vkf2iqc72tevvroaop > resource_type: "type.googleapis.com/google.spanner.admin.database.v1.Database" > resource_name: > "projects/apache-beam-testing/instances/beam-test/databases/beam-testdb-vkf2iqc72tevvroaop" > description: "Database does not exist." > at io.grpc.Status.asRuntimeException(Status.java:526) > at > io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:468) > at > io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39) > at > io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23) > at > io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40) > at > com.google.cloud.spanner.spi.v1.SpannerErrorInterceptor$1$1.onClose(SpannerErrorInterceptor.java:100) > at > io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39) > at > io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23) > at > io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40) > at > com.google.cloud.spanner.spi.v1.WatchdogInterceptor$MonitoredCall$1.onClose(WatchdogInterceptor.java:190) > at > io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39) > at > io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23) > at > io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40) > at > io.grpc.internal.CensusStatsModule$StatsClientInterceptor$1$1.onClose(CensusStatsModule.java:684) > at > io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39) > at > io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23) > at > io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40) > at > io.grpc.internal.CensusTracingModule$TracingClientInterceptor$1$1.onClose(CensusTracingModule.java:403) > at > io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:459) > at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:63) > at > io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.close(ClientCallImpl.java:546) > at > io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl.access$600(ClientCallImpl.java:467) > at > io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:584) > at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) > at > io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)