Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5362
Thanks for the reviews!
Will merge after Travis gives green.
---
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5362
I think this is good to go now. ð ð
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5362
@aljoscha As discussed offline, I've:
- replaced `ByteArrayPrependedInputStream` with Java's `PushbackInputStream`
- use negative values in `VERSIONED_IDENTIFIER` to be extra safe
---
