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 cc7319328d..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("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