pvary
pvary
## Feature Request Working on the Flink Kubernetes Operator (https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/), and we would like to extend the operator with probes detecting the health of the deployment. We have observed cases...
Backport of #20474, needed for backporting #20710
## What is the purpose of the change Add new SinkV2 API interfaces, set inheritance and deprecation for the old interfaces. ## Brief change log All the new API's defined...
## What is the purpose of the change Mixin based implementation for [FLIP-372](https://cwiki.apache.org/confluence/display/FLINK/FLIP-372%3A+Allow+TwoPhaseCommittingSink+WithPreCommitTopology+to+alter+the+type+of+the+Committable) For now, just checking backward compatibility of the API changes ## Brief change log - Moving inner...
## What is the purpose of the change Add new SinkV2 API interfaces, set inheritance and deprecation for the old interfaces. Added fix for the concurrent commit ## Brief change...
We discussed in #1465 that it would be good to find a way to update the version-hint.txt atomically > The version file should not be corrupt and we should make...
The responsibility of the Trigger Manager is to start the Maintenance Tasks based on the incoming Table Change messages and prevent overlapping Maintenance Task runs. The event time of the...
Operator to remove the lock at the end of the Maintenance flow. https://docs.google.com/document/d/16g3vR18mVBy8jbFaLjf2JwAANuYOmIwr15yDDxovdnA/edit#heading=h.lt9eaimi6zyz
Trying to use VSCode with the extension to build/test the Apache Iceberg project, but the dependency handling is not working as expected. The gradle projects view shows all the gradle...
The interface part of the changes from #12298 Interfaces which have to be implemented by the File Formats: - `ReadBuilder` - Builder for reading data from data files - `AppenderBuilder`...