scott-strong commented on issue #21882:
URL: https://github.com/apache/beam/issues/21882#issuecomment-1291007537
Hi @sshahar1 @Abacn,
I ran into the same issue in my java pipeline. We upgraded to Apache Beam
2.39 and started getting the exact error message from above. I can't post the
exact pipeline, but we're streaming Pub/Sub events, transforming and windowing,
then writing them to MySQL. Below is the windowing function:
```
Window.<SimplifiedEvent>into(FixedWindows.of(Duration.standardMinutes(options.getWindowDurationMinutes())))
.discardingFiredPanes()
```
I'm curious if Sigal has resolved this since this post, or if there have
been any other reports of this error message occurring. I know there was a test
case where this is passing, but following the stacktrace I don't see how the
`GlobalWindow` would work when passed to the `IntervalWindowCoder`. Any info is
appreciated. Thanks.
--
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]
