Kim Gräsman
Kim Gräsman
Added a multi-threaded testcase. It fails on average 50% of the time before the bugfix, succeeds consistently after. Runtime on my system is ~5 seconds. Let me know what you...
@becketqin Gentle holiday ping!
@becketqin Rebase ping.
@becketqin Rebase ping
@becketqin Rebased again. We actually ran into this issue again in Flink 1.17.2, so I'm anxious to eliminate the bug for the future. Please reopen.
Thanks! Sorry I never got around to this, something more urgent came up. Meanwhile, I read about narrow vs wide contracts [1] and started to think that maybe the `DateTime`...
The current state is mostly wrappers around `API` `Marshal`/`Unmarshal`. I was hoping to be able to decorate/wrap `avro.Encoder` and `avro.Decoder` too, but I don't think that's easily done since they're...