Retry transient NOT_FOUND on Storage API default stream

Author: aIbrahiim

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java

@@ -850,7 +850,7 @@ long flush(
               boolean hasPersistentErrors =
                   failedContext.getError() instanceof Exceptions.StreamFinalizedException
                       || statusCode.equals(Status.Code.INVALID_ARGUMENT)
-                      || statusCode.equals(Status.Code.NOT_FOUND)
+                      || (!this.useDefaultStream && statusCode.equals(Status.Code.NOT_FOUND))
                       || statusCode.equals(Status.Code.FAILED_PRECONDITION);
               if (hasPersistentErrors) {
                 throw new RuntimeException(