From dd342ac97f924d02566e948a8f679240b28e8685 Mon Sep 17 00:00:00 2001 From: Jack Dingilian Date: Thu, 28 Sep 2023 16:13:42 -0400 Subject: [PATCH 1/2] fix: Make change stream unknown mod error more actionable --- .../data/v2/stub/changestream/ChangeStreamStateMachine.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/changestream/ChangeStreamStateMachine.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/changestream/ChangeStreamStateMachine.java index 2aa9c537db..3ce9845261 100644 --- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/changestream/ChangeStreamStateMachine.java +++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/changestream/ChangeStreamStateMachine.java @@ -477,7 +477,7 @@ State handleDataChange(ReadChangeStreamResponse.DataChange dataChange) { mod.getDeleteFromColumn().getTimeRange().getEndTimestampMicros())); continue; } - throw new IllegalStateException("AWAITING_NEW_DATA_CHANGE: Unexpected mod type"); + throw new IllegalStateException("Received unknown mod type. You may need to upgrade your Bigtable client."); } // After adding all mods from this DataChange to the state machine, finish the current From 0ca3926d2d734e4df5e363ee137d22951e7b5f92 Mon Sep 17 00:00:00 2001 From: Owl Bot Date: Wed, 5 Jun 2024 15:02:06 +0000 Subject: [PATCH 2/2] =?UTF-8?q?=F0=9F=A6=89=20Updates=20from=20OwlBot=20po?= =?UTF-8?q?st-processor?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --- .../data/v2/stub/changestream/ChangeStreamStateMachine.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/changestream/ChangeStreamStateMachine.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/changestream/ChangeStreamStateMachine.java index 1fd76cda33..912b55eceb 100644 --- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/changestream/ChangeStreamStateMachine.java +++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/changestream/ChangeStreamStateMachine.java @@ -486,7 +486,8 @@ State handleDataChange(ReadChangeStreamResponse.DataChange dataChange) { Value.fromProto(mod.getAddToCell().getTimestamp()), Value.fromProto(mod.getAddToCell().getInput())); } - throw new IllegalStateException("Received unknown mod type. You may need to upgrade your Bigtable client."); + throw new IllegalStateException( + "Received unknown mod type. You may need to upgrade your Bigtable client."); } // After adding all mods from this DataChange to the state machine, finish the current