Merge branch 'main' into conformance-tests

Author: mpeddada1

google/cloud/bigtable/ci/run_conformance_tests_proxy_bazel.sh

@@ -51,7 +51,7 @@ exit_status=$?
 # CloseClient
 go test -v \
   -run "TestExecuteQuery|TestExecuteQuery_PlanRefresh$|TestExecuteQuery_PlanRefresh_WithMetadataChange|TestExecuteQuery_PlanRefresh_Retries|TestExecuteQuery_FailsOnSuccesfulStreamWithNoToken" \
-  -skip "CloseClient|FailsOnEmptyMetadata|FailsOnExecuteQueryMetadata|FailsOnInvalidType|FailsOnNotEnoughData|FailsOnNotEnoughDataWithCompleteRows|FailsOnSuccesfulStreamWithNoToken|FailsOnTypeMismatch|FailsOnTypeMismatchWithinMap|FailsOnTypeMismatchWithinArray|FailsOnTypeMismatchWithinStruct|FailsOnStructMissingField|TestExecuteQuery_PlanRefresh_AfterResumeTokenCausesError|TestExecuteQuery_RetryTest_WithPlanRefresh|TestExecuteQuery_PlanRefresh_RespectsDeadline|TestExecuteQuery_PlanRefresh_RecoversAfterPermanentError" \
+  -skip "CloseClient|FailsOnEmptyMetadata|FailsOnExecuteQueryMetadata|FailsOnInvalidType|FailsOnTypeMismatch|FailsOnTypeMismatchWithinMap|FailsOnTypeMismatchWithinArray|FailsOnTypeMismatchWithinStruct|FailsOnStructMissingField|TestExecuteQuery_PlanRefresh_AfterResumeTokenCausesError|TestExecuteQuery_RetryTest_WithPlanRefresh|TestExecuteQuery_PlanRefresh_RespectsDeadline|TestExecuteQuery_PlanRefresh_RecoversAfterPermanentError" \
   -proxy_addr=:9999
 exit_status=$?
 
@@ -65,12 +65,6 @@ exit_status=$?
 #  -proxy_addr=:9999
 #exit_status=$?
 
-# Stream reading tests b/461232110
-#go test -v \
-#  -run "FailsOnNotEnoughData|FailsOnNotEnoughDataWithCompleteRows" \
-#  -proxy_addr=:9999
-#exit_status=$?
-
 # Response/Metadata mismatches b/461233335
 #go test -v \
 #  -run "FailsOnTypeMismatch|FailsOnTypeMismatchWithinMap|FailsOnTypeMismatchWithinArray|FailsOnTypeMismatchWithinStruct|FailsOnStructMissingField" \
@@ -79,7 +73,7 @@ exit_status=$?
 
 # QueryPlan refresh tests b/461233613
 #go test -v \
-#  -run "RetryTest_WithPlanRefresh|PlanRefresh" \
+#  -run "RetryTest_WithPlanRefresh|PlanRefresh|PlanRefresh_RecoversAfterPermanentError" \
 #  -proxy_addr=:9999
 #exit_status=$?
 

google/cloud/bigtable/internal/partial_result_set_source.cc

@@ -215,9 +215,10 @@ Status PartialResultSetSource::BufferProtoRows() {
           GCP_ERROR_INFO());
     }
     if (proto_values.size() % columns_size != 0) {
+      state_ = State::kFinished;
       return internal::InternalError(
           "The number of values in ProtoRows is not a multiple of the "
-          "number of columns in the schema.",
+          "number of columns in the schema or received incomplete row",
           GCP_ERROR_INFO());
     }