reuvenlax commented on issue #23291: URL: https://github.com/apache/beam/issues/23291#issuecomment-1327993726
Unfortunately a precondition of the sink is that the schema passed into BigQueryIO.write (in your case via getSchema) is (or is compatible with) the schema of the BigQuery table. In this particular case, the failure doesn't come when we write any specific record. The failure comes when we first open the connection to BigQuery - the connection object takes in the expected schema as a parameter and fails if the schema isn't compatible. Since this is before we start writing records, there is nothing to send to getFailedStorageApiInserts -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
