We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 55d1fb9 commit 90cacb2Copy full SHA for 90cacb2
google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/readrows/StateMachine.java
@@ -277,6 +277,10 @@ State handleLastScannedRow(ByteString rowKey) {
277
278
@Override
279
State handleChunk(CellChunk chunk) {
280
+ // Make sure to populate the rowKey before validations so that validation failures include
281
+ // the new key
282
+ rowKey = chunk.getRowKey();
283
+
284
validate(!chunk.getResetRow(), "AWAITING_NEW_ROW: can't reset");
285
validate(!chunk.getRowKey().isEmpty(), "AWAITING_NEW_ROW: rowKey missing");
286
validate(chunk.hasFamilyName(), "AWAITING_NEW_ROW: family missing");
0 commit comments