jwtryg

[FLINK-33466][Connectors/Kafka]: Bounded Kafka source never finishes after restore from savepoint

3

This fix snapshots the noMoreNewPartitionSplits variable. This is done to make sure that the signalNoMoreSplits signal is sent after restoring from a snapshot. At the current state, a bounded kafka...

logicalType - keep property

3

Currently when parsing an avro schema, the [schema.go file](https://github.com/hamba/avro/blob/main/schema.go) contains a number of reserved properties that are removed from the schemas. These reserved properties include the `logicalType` property. However, some...

Hi @zeroshade I think it's really cool that you are working on a golang-iceberg implementation, and I would like to contribute if I can. I have tried to finish the...

Add custom logical types

2

closes #435 Hi @nrwiersma This PR adds the possibility to register custom logical types for the schema. These logicaltypes are primitive, and does not include logic for handling custom encoding/decoding,...

table.doCommit call fails when metadata file is already removed

1

### Apache Iceberg version main (development) ### Please describe the bug 🐞 When `write.metadata.delete-after-commit.enabled` is set to true, the [deleteOldMetadata](https://github.com/apache/iceberg-go/blob/5cf1bdba4ee442bd61f2a8d9e5c64d3f42a75763/table/table.go#L222) function will delete the old metadata files from the underlying...