The TableAggregateFunction javadocs indicate that either "emitValue" or
"emitUpdateWithRetract" is required.
But if I implement my TableAggregateFunction with "emitUpdateWithRetract",
I get a validation error. If I implement both methods it works, but
emitUpdateWithRetract is not used.
Peering in
Hi Arthur,
Delegation tokens were enabled all the time which is not changed since it
would be a breaking change. I would personally turn it off by default but
it's important to keep original behavior.
The manager is loading providers at the very beginning of the init process.
It loads and initial
Hi all,
I'm upgrading an application from Flink 1.16.1 to 1.17.0 and I noticed that
delegation tokens (DTs) configuration [1] seems to have started to be
mandatory. Is my understanding correct?
I found this announcement [2] saying that from 1.17.0 version DTs are
enabled by default [3] but it wou
Nice đź‘Ť
P.S and forgot to mention I use Kafka as the source
On Fri, Apr 7, 2023 at 11:03 AM Weihua Hu wrote:
> Hi,
> Thanks for reporting this issue.
>
> I created a ticket to track this[1].
>
> [1]https://issues.apache.org/jira/browse/FLINK-31752
>
> Best,
> Weihua
>
>
> On Fri, Apr 7, 2023 at 1
Hi,
Thanks for reporting this issue.
I created a ticket to track this[1].
[1]https://issues.apache.org/jira/browse/FLINK-31752
Best,
Weihua
On Fri, Apr 7, 2023 at 12:54 AM Ioannis Polyzos
wrote:
> Any chance something is broken in the Records Sent metrics in the UI in
> the 1.17 release? I
