Unsubscribe
nt. You can
create your `RestClusterClient` to do that or use the existing jdbc-driver
and sql-gateway.".
It would be helpful for me if you could provide more information on how I
could achieve it using *RestClusterClient*. Thanks and Regards Muazim Wani
On Tue, 5 Sept 2023 at 22:01, Mu
disables all handlers related
to web submission. This statement appears to contradict the information in
the Flink documentation.
Could you please provide some guidance or insights on how to correctly
configure Flink to disable UI job submissions while allowing submissions
via REST APIs? Any assistance on this matter would be greatly appreciated.
Thank you for your help.
Best regards, Muazim Wani
ou get the header, you can flush all reduced data, and no longer
> buffer it.
>
> When timer fires, you can flush the footer.
>
> — Ken
>
>
>
> On Aug 10, 2023, at 10:14 PM, Muazim Wani wrote:
>
> Thank you so much for taking the time to provide me with such
ream is a Bounded DataStream with Dynamic Headers and
Aggregated value.
DataStream headerStream = addHeaderRows(sinkStream);
DataStream footerStream = addFooterRows(finalStream);
DataStream sinkStream;
Thanks a lot for your time and the advice.
Muazim Wani
On Fri, 11 Aug 2023 at 07:45, Hang Rua
which you know for
> sure that stream 1 is done).
>
> And this in turn means stream 2 would be buffered forever in state, thus
> growing unbounded.
>
> I would suggest elaborating on your use case.
>
> Regards,
>
> — Ken
>
>
> On Aug 10, 2023, at 10:11 AM, Muazim W
Hi Team,
I have a use case where I have two streams and want to join them in
stateful manner .
E.g data of stream 1 should be emitted before stream2.
I tried to store the data in ListState in KeyedProcessFunction but I am not
able to access state outside proccessElement().
Is there any way I could
Hi Team,
I am new to Flink. I have this use case where I have a dataStream of
Doubles and I am trying to get the total sum of whole DataStream.
I have used ReduceFunction and AggregateFunction.
Case 1: In Reduced function the output is dataStream of rolling Sum. To get
the final Sum I have to tra
