Remove the exception handling in JRH at
|
windowingStrategy = WindowingStrategy.globalDefault(); |
And subsequently fix Reshuffle transform to use _IdentityWindowFn in
|
def restore_timestamps(element, window=DoFn.WindowParam): |
Imported from Jira BEAM-8104. Original Jira may contain additional context.
Reported by: angoenka.