Merge branch 'main' into generate-libraries-main

Author: igorbernstein2

.kokoro/presubmit/integration.cfg

@@ -8,7 +8,7 @@ env_vars: {
 
 env_vars: {
     key: "INTEGRATION_TEST_ARGS"
-    value: "-P bigtable-emulator-it,bigtable-prod-it,bigtable-prod-batch-it,enable-verbose-grpc-logs -Dbigtable.project=gcloud-devel -Dbigtable.instance=google-cloud-bigtable -Dbigtable.table=integration-tests -Dbigtable.kms_key_name=projects/gcloud-devel/locations/us-east1/keyRings/cmek-test-key-ring/cryptoKeys/cmek-test-key -Dbigtable.wait-for-cmek-key-status=true"
+    value: "-P bigtable-prod-it,enable-verbose-grpc-logs -Dbigtable.project=gcloud-devel -Dbigtable.instance=google-cloud-bigtable -Dbigtable.table=integration-tests -Dbigtable.kms_key_name=projects/gcloud-devel/locations/us-east1/keyRings/cmek-test-key-ring/cryptoKeys/cmek-test-key -Dbigtable.wait-for-cmek-key-status=true"
 }
 
 env_vars: {

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionPoolImpl.java

@@ -325,7 +325,7 @@ private int getMaxConsecutiveFailures(ClientConfigurationManager configManager)
 
   private synchronized void createSession(OpenParams openParams) {
     if (!budget.tryReserveSession()) {
-      debugTagTracer.record(TelemetryConfiguration.Level.DEBUG, "session_pool_no_budget");
+      debugTagTracer.record(TelemetryConfiguration.Level.WARN, "session_pool_no_budget");
       logger.fine(
           String.format(
               "Refusing to add a new session due to exhausted %s concurrent create session"

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStubSettings.java

@@ -100,8 +100,10 @@ public class EnhancedBigtableStubSettings extends StubSettings<EnhancedBigtableS
 
   // TODO change this to true when enabling directpath by default
   // For now, Only runs Direct Access Checker if user explicitly sets CBT_ENABLE_DIRECTPATH=true
-  private static final DirectPathConfig DIRECT_PATH_CONFIG =
-      Optional.ofNullable(System.getenv("CBT_ENABLE_DIRECTPATH"))
+  private static DirectPathConfig DIRECT_PATH_CONFIG =
+      Optional.ofNullable(
+              Optional.ofNullable(System.getenv("CBT_ENABLE_DIRECTPATH"))
+                  .orElse(System.getProperty("bigtable.internal.enable-directpath")))
           .map(Boolean::parseBoolean)
           .map(b -> b ? DirectPathConfig.FORCED_ON : DirectPathConfig.FORCED_OFF)
           .orElse(DirectPathConfig.DEFAULT);

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/internal/session/SessionImplTest.java

@@ -443,7 +443,15 @@ void testHeartbeat() throws Exception {
                         SessionParametersResponse.newBuilder()
                             .setKeepAlive(Durations.fromMillis(keepAliveDurationMs))
                             .build())
-                    .putVrpcActions(0, ActionList.getDefaultInstance())
+                    .putVrpcActions(
+                        0,
+                        ActionList.newBuilder()
+                            .addActions(
+                                Action.newBuilder()
+                                    .setDelay(Durations.fromMillis(500))
+                                    .setResponse(VirtualRpcResponse.getDefaultInstance())
+                                    .build())
+                            .build())
                     .build()
                     .toByteString())
             .build();