lostluck commented on issue #31122: URL: https://github.com/apache/beam/issues/31122#issuecomment-2152964611
Agreed, that filtering is the right move here. Those tests do use strings which is one of the affected datatypes Flink's TestStream corrupts. ---- At some point we determined that Flink does with TestStream and mutates those coders (adding length prefixes where they weren't previously) without making the equivalent mutations to the equivalent bytes, but we weren't able to pin down where it was coming from. This we filtered out those tests here: https://github.com/apache/beam/blob/master/sdks/go/test/integration/integration.go#L181 Ideally we fix the Flink test stream implementation, but until then, we filter, since it's not commonly used. -- 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: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
