MarcoRob commented on issue #22372:
URL: https://github.com/apache/beam/issues/22372#issuecomment-1312215843

   > Looks like the problem is in this [deleted code 
block](https://github.com/apache/beam/pull/17365/files#diff-3edb3abd8909e7075e679e8b93420d4119858d6a9418b6ec10a204a592f062abL682-L692).
 The create disposition in WriteTables has always been 
`CreateDisposition.CREATE_IF_NEEDED`, because that's necessary when creating 
temp tables. However, in the case the schema isn't provided, this would cause 
the problem we're seeing here.
   > 
   > That code block used to handle this case by fetching the schema of the 
final destination table and using it as the schema for the temp tables. I think 
bringing that code back would solve this issue, unless there's a particular 
reason it was deleted @MarcoRob?
   
   The change was part of a fix made due the following 
[ticket](https://issues.apache.org/jira/browse/BEAM-12482).
   I am taking a look at this now to validate the issue and fix the bug. I will 
be updating the bug with more info. 


-- 
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]

Reply via email to