From 1c2b5c1ef478305fe7f3d9f1843750cec18ba9f8 Mon Sep 17 00:00:00 2001
From: Yiru Tang <yiru@google.com>
Date: Wed, 13 Jan 2021 10:41:42 -0800
Subject: [PATCH] fix: default stream integration test failures due to
 production expected change (#791)

---
 .../storage/v1beta2/it/ITBigQueryWriteManualClientTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryWriteManualClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryWriteManualClientTest.java
index d818d66368..af665eb35b 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryWriteManualClientTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryWriteManualClientTest.java
@@ -352,8 +352,8 @@ public void testJsonStreamWriterBatchWriteWithDefaultStream()
       ApiFuture<AppendRowsResponse> response2 = jsonStreamWriter.append(jsonArr2, -1);
       LOG.info("Sending one more message");
       ApiFuture<AppendRowsResponse> response3 = jsonStreamWriter.append(jsonArr3, -1);
-      assertEquals(1, response2.get().getAppendResult().getOffset().getValue());
-      assertEquals(3, response3.get().getAppendResult().getOffset().getValue());
+      Assert.assertFalse(response2.get().getAppendResult().hasOffset());
+      Assert.assertFalse(response3.get().getAppendResult().hasOffset());
 
       TableResult result =
           bigquery.listTableData(