Kim Gräsman

Hey, Thanks for go-ais! I ran into a little surprise this week when we noticed that type 9 `StandardSearchAndRescueAircraftReport` does not encode its `Sog` field like the others: https://github.com/BertoldVdb/go-ais/blob/fd4fd5b2687ae6ab50065f6702d2645c54d32c98/messages.go#L126 It...

Update all tests to use the right constructor

1

In 395d1ecdab441b1ad7b728cadc69f4dfb49dcd6f, the CodecNew constructor was reverted to only take two booleans, and a new CodecNewFast with an option for fast parsing was added. That caused all tests to fail...

Poco::DateTime uses assertions for validation

4

We're unit-testing some code based on `Poco::DateTime`. When we throw invalid dates at our code, this is printed to the console: ``` %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% Assertion violation: month >= 1 && month

[FLINK-36146][connector] Fix SingleThreadFetcherManager race condition

3

This issue triggered when running a highly parallel batch job with FileSource pointed at a large S3 bucket. The visible symptom was: java.util.NoSuchElementException at java.base/java.util.concurrent.ConcurrentHashMap$ValueIterator.next(ConcurrentHashMap.java:3471) at org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager.getRunningFetcher(SingleThreadFetcherManager.java:94) at org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager.addSplits(SingleThreadFetcherManager.java:82) at...

feat: add SOE codecs

11

Here's an early draft of some ideas I have for Avro Single Object Encoding. * Encoder/Decoder follows Marshal/Unmarshal but adds/parses SOE header * GenericEncoder/Decoder is a type-safe version that works...

Single Object Encoding codecs

3

As mentioned in https://github.com/hamba/avro/issues/489, we consume and produce Avro SOE encoding, which is a minimal framing to carry a schema identifier with each record. We have numerous half-baked implementations of...