---

elisheva-qlogic · sduskis · commit d73ecd9001a2 · 2019-01-25T13:26:28.000-05:00
yaml --- r: 15099 b: refs/heads/autosynth-bigquerydatatransfer c: b92a48b h: refs/heads/master i: 15097: 917f24d 15095: 515451d
diff --git a/[refs] b/[refs]
@@ -124,7 +124,7 @@ refs/tags/v0.68.0: 9cc799fcf68c82ab431d425fefa58ef615ce8e5b
 refs/tags/v0.69.0: 78f67a29e8b9c46ba01de566a2eae0fd1c03edea
 refs/heads/autosynth-asset: cd8251de8c40e239ad24dcf9ed93ea2708a3eed5
 refs/heads/autosynth-automl: cced2f56bbef0499609073edbca6253e1df5e535
-refs/heads/autosynth-bigquerydatatransfer: 9c47e1b4ff84f5ac07b0b38848e662c0e7eb3dad
+refs/heads/autosynth-bigquerydatatransfer: b92a48b90f0f6b5b0749afe30523a9097958229b
 refs/heads/autosynth-bigquerystorage: 99aee05df348f39d98b6fb23c292006f1d2a6c28
 refs/heads/autosynth-bigtable: fa0d1de9e264d7ecac8a3abc3de7a8364cfaf427
 refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
diff --git a/branches/autosynth-bigquerydatatransfer/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/mutaterows/MutateRowsAttemptCallable.java b/branches/autosynth-bigquerydatatransfer/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-bigquerydatatransfer/google-cloud-clients/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/env/Emulator.java b/branches/autosynth-bigquerydatatransfer/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-bigquerydatatransfer/google-cloud-clients/google-cloud-core/src/main/java/com/google/cloud/ServiceOptions.java b/branches/autosynth-bigquerydatatransfer/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`	`}`