shunping commented on issue #36387: URL: https://github.com/apache/beam/issues/36387#issuecomment-3373074015
Prism has some hack when handling the encoded bytes from TestStream: https://github.com/apache/beam/blob/09aa10c52f1d24846ab30e791c3e5bd544e9321f/sdks/go/pkg/beam/runners/prism/internal/execute.go#L288-L297 However, it only works for element type of String. If we have a nested type like `KV<String, String>` (the ones used in `org.apache.beam.sdk.transforms.GroupIntoBatchesTest.testInStreamingMode` and `org.apache.beam.sdk.transforms.GroupIntoBatchesTest.testBufferingTimerInFixedWindow`), the hack won't work. I think the way to resolve this is to modify TestStream in Java to always use nested context instead. -- 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]
