diff --git a/google-cloud-spanner/src/test/java/com/google/cloud/spanner/IntegrationTestWithClosedSessionsEnv.java b/google-cloud-spanner/src/test/java/com/google/cloud/spanner/IntegrationTestWithClosedSessionsEnv.java index 66e0893be7b..07e6a08e045 100644 --- a/google-cloud-spanner/src/test/java/com/google/cloud/spanner/IntegrationTestWithClosedSessionsEnv.java +++ b/google-cloud-spanner/src/test/java/com/google/cloud/spanner/IntegrationTestWithClosedSessionsEnv.java @@ -114,7 +114,8 @@ private void awaitDeleted(Session session) { Thread.sleep(500L); } catch (SpannerException e) { if (e.getErrorCode() == ErrorCode.NOT_FOUND - && e.getMessage().contains("Session not found")) { + && (e.getMessage().contains("Session not found") + || e.getMessage().contains("Session was concurrently deleted"))) { break; } else { throw e;