Hi there Clenens.
This one might be a little bit tricky.
You can take a look: at
https://github.com/getindata/flink-http-connector/blob/main/src/main/java/com/getindata/connectors/http/internal/table/lookup/AsyncHttpTableLookupFunction.java
We implemented our http connector using assuncLookup the
hi, how do I implement AsyncLookupFunctions correctly? I implemented a
AsyncLookupFunction, the eval function has the following signature:
https://nightlies.apache.org/flink/flink-docs-release-1.17/api/java/org/apache/flink/table/functions/AsyncLookupFunction.html
eval(CompletableFuture> future, Ob
Now I see the intention and then you must have a V2 sink, right? Maybe you
look for the following:
final String writerHash = "f6b178ce445dc3ffaa06bad27a51fead";
final String committerHash = "68ac8ae79eae4e3135a54f9689c4aa10";
final CustomSinkOperatorUidHashes operatorsUidHashes =
CustomSin
Hi Salva,
The SinkV2 transformation will be translated to multiple operators at the
physical level. When setting a UID, Flink will automatically generate UID for
sub-operators by filling the configured UID in a pre-defined naming template.
The naming template is carefully maintained to ensure c
