tests: fix ITs for emulator

@@ -18,6 +18,7 @@
 
 import static com.google.common.truth.Truth.assertThat;
 import static org.junit.Assert.fail;
+import static org.junit.Assume.assumeFalse;
 
 import com.google.api.core.ApiFuture;
 import com.google.cloud.spanner.AsyncResultSet;
@@ -278,6 +279,9 @@ public void columnNotFound() throws Exception {
 
 @Test
 public void asyncRunnerFireAndForgetInvalidUpdate() throws Exception {
+assumeFalse(
+"errors in read/write transactions on emulator are sticky",
+env.getTestHelper().isEmulator());
 try {
 assertThat(client.singleUse().readRow("TestTable", Key.of("k999"), ALL_COLUMNS)).isNull();
 AsyncRunner runner = client.runAsync();

@@ -33,17 +33,20 @@
 import com.google.cloud.spanner.ErrorCode;
 import com.google.cloud.spanner.IntegrationTestEnv;
 import com.google.cloud.spanner.Key;
+import com.google.cloud.spanner.KeySet;
 import com.google.cloud.spanner.Mutation;
 import com.google.cloud.spanner.SpannerException;
 import com.google.cloud.spanner.Struct;
 import com.google.cloud.spanner.TransactionContext;
 import com.google.cloud.spanner.TransactionManager.TransactionState;
+import com.google.common.collect.ImmutableList;
 import com.google.common.util.concurrent.MoreExecutors;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executor;
 import java.util.concurrent.Executors;
+import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.ClassRule;
 import org.junit.Test;
@@ -84,6 +87,11 @@ public static void setUpDatabase() {
 client = env.getTestHelper().getDatabaseClient(db);
 }
 
+@Before
+public void clearTable() {
+client.write(ImmutableList.of(Mutation.delete("T", KeySet.all())));
+}
+
 @Test
 public void testSimpleInsert() throws ExecutionException, InterruptedException {
 try (AsyncTransactionManager manager = client.transactionManagerAsync()) {