ahmedabu98 commented on issue #33238: URL: https://github.com/apache/beam/issues/33238#issuecomment-2521121430
After investigating a little, I found this doesn't actually have to do with dynamic destinations. The issue is when the sink creates a new StreamWriter after the schema has been updated. Looks like we create the StreamWriter with a fixed schema. A StreamWriter returns an updated schema only if it was created before such an update. So it doesn't pull the updated schema and continues using the old schema it was created with. -- 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]
