.

googleapis · Sep 23, 2022 · dd5f00c · dd5f00c
1 parent 242fc04
commit dd5f00c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriter.java b/...-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriter.java
@@ -130,7 +130,11 @@ private Message buildMessage(JSONObject json)
       // Backend cache for GetWriteStream schema staleness can be 30 seconds, wait a bit before
       // trying to get the table schema to increase the chance of succeed. This is to avoid
       // client's invalid data caused storm of GetWriteStream.
-      Thread.sleep(3500);
+      LOG.warning(
+          "Saw Json unknown field "
+              + ex.getFieldName()
+              + ", try to refresh the writer with updated schema");
+      Thread.sleep(35000);
       GetWriteStreamRequest writeStreamRequest =
           GetWriteStreamRequest.newBuilder()
               .setName(this.streamName)