lostluck commented on PR #30072: URL: https://github.com/apache/beam/pull/30072#issuecomment-1971988535
Found them. `--- FAIL: TestTestStreamInt16Sequence (10.52s)` Basically, the Flink runner does nonsense with TestStream whenever there's a LengthPrefix, leading to an *extra* length prefix being added to custom coders, strings, byte slices etc. We've never successfully found where/why this gets added. But ultimately it means the data is being corrupted, since the extra length prefixing occurs flink side, but the *coder* received back by the SDK doesn't include it, causing decode failures. The problem in this case is that I didn't filter out *all* the new tests I added too. I'll have a PR to fix shortly. -- 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]
