---

elisheva-qlogic · sduskis · commit f074ba8aca3d · 2019-01-25T13:26:28.000-05:00
yaml --- r: 15239 b: refs/heads/autosynth-bigtable c: b92a48b h: refs/heads/master i: 15237: e620966 15235: 0bd6ed9 15231: cb2661d
diff --git a/[refs] b/[refs]
@@ -126,7 +126,7 @@ refs/heads/autosynth-asset: cd8251de8c40e239ad24dcf9ed93ea2708a3eed5
 refs/heads/autosynth-automl: cced2f56bbef0499609073edbca6253e1df5e535
 refs/heads/autosynth-bigquerydatatransfer: a6667617707608b1dbfb02d59c22b5152f208da7
 refs/heads/autosynth-bigquerystorage: 14ab055598b943ae3f33f484e9fb1653355d08e7
-refs/heads/autosynth-bigtable: 9c47e1b4ff84f5ac07b0b38848e662c0e7eb3dad
+refs/heads/autosynth-bigtable: b92a48b90f0f6b5b0749afe30523a9097958229b
 refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
 refs/heads/autosynth-containeranalysis: 781fdb430a60f9a6491f116e31e4e10118157bdb
 refs/heads/autosynth-datastore: af1fb76aa3eee02fe6f31f8fa1c72a4f048d149b
diff --git a/branches/autosynth-bigtable/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/mutaterows/MutateRowsAttemptCallable.java b/branches/autosynth-bigtable/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/mutaterows/MutateRowsAttemptCallable.java
@@ -185,7 +185,8 @@ public Void call() {
 
       // Handle RPC level errors by wrapping them in a MutateRowsException
       ApiFuture<List<MutateRowsResponse>> catching =
-          ApiFutures.catching(innerFuture, Throwable.class, attemptFailedCallback);
+          ApiFutures.catching(
+              innerFuture, Throwable.class, attemptFailedCallback, MoreExecutors.directExecutor());
 
       // Inspect the results and either propagate the success, or prepare to retry the failed
       // mutations
diff --git a/branches/autosynth-bigtable/google-cloud-clients/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/env/Emulator.java b/branches/autosynth-bigtable/google-cloud-clients/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/env/Emulator.java
@@ -172,10 +172,8 @@ private void waitForPort(int port) throws InterruptedException, TimeoutException
   }
 
   private ManagedChannel createChannel(int port) {
-    // NOTE: usePlaintext is currently @ExperimentalAPI. In grpc 1.11 it be became parameterless.
-    // In 1.12 it should be stable. See https://github.com/grpc/grpc-java/issues/1772 for discussion
     return ManagedChannelBuilder.forAddress("localhost", port)
-        .usePlaintext(true)
+        .usePlaintext()
         .maxInboundMessageSize(256 * 1024 * 1024)
         .build();
   }
diff --git a/branches/autosynth-bigtable/google-cloud-clients/google-cloud-core/src/main/java/com/google/cloud/ServiceOptions.java b/branches/autosynth-bigtable/google-cloud-clients/google-cloud-core/src/main/java/com/google/cloud/ServiceOptions.java
@@ -349,7 +349,8 @@ private static String getActiveGoogleCloudConfig(File configDir) {
     String activeGoogleCloudConfig = null;
     try {
       activeGoogleCloudConfig =
-          Files.readFirstLine(new File(configDir, "active_config"), Charset.defaultCharset());
+          Files.asCharSource(new File(configDir, "active_config"), Charset.defaultCharset())
+              .readFirstLine();
     } catch (IOException ex) {
       // ignore
     }

Original file line number	Diff line number	Diff line change
`@@ -172,10 +172,8 @@ private void waitForPort(int port) throws InterruptedException, TimeoutException`
`172`	`172`	`}`
`173`	`173`
`174`	`174`	`private ManagedChannel createChannel(int port) {`
`175`		`- // NOTE: usePlaintext is currently @ExperimentalAPI. In grpc 1.11 it be became parameterless.`
`176`		`- // In 1.12 it should be stable. See https://github.com/grpc/grpc-java/issues/1772 for discussion`
`177`	`175`	`return ManagedChannelBuilder.forAddress("localhost", port)`
`178`		`- .usePlaintext(true)`
	`176`	`+ .usePlaintext()`
`179`	`177`	`.maxInboundMessageSize(256 * 1024 * 1024)`
`180`	`178`	`.build();`
`181`	`179`	`}`