Hi,
Have you followed the documentation at
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#security
?
Best regards,
Martijn
On Fri, Apr 21, 2023 at 3:00 AM Shammon FY wrote:
> Hi Naga
>
> Could you provide detailed error information? I think it may be us
Hello!
When we use flink version 1.14 to commit tasks to kubernetes, we get an error
using Session mode. The following error is reported some time after the task is
submitted .
2023-04-18 17:23:56,818 INFO
org.apache.flink.client.program.rest.RestClusterClient
[] - Submitting job 'Fl
Hi Flink community,
We have a quite complex sql job, it unions 5 topics, deduplicates by key and
does some daily aggregations. The state TTL is 40 days. We want to be able to
bootstrap its state from s3 or clickhouse. We want to have a general solution
to this, to use for other SQL jobs as well
Hi,
Currently we have a streaming use case where we have a flink application
which runs on a session cluster which is responsible for reading data from
Kafka source which is basically table transaction events getting ingested
into the upstream kafka topic which is converted to a row and then
dedup
Hi,
It's a DEBUG level log.
Does this submission failed?
Best,
Weihua
On Fri, Apr 21, 2023 at 5:44 PM “岁月飞扬” <1639467...@qq.com> wrote:
>
> Hello!
>
> When we use flink version 1.14 to commit tasks to kubernetes, we get an
> error using Session mode. The following error is reported some time a
Hello
I have started to play around with Flink recently and I had a question
about the behavior of the Flink application mode.
When we start a Flink application using the command
flink run-application -t yarn-application my.jar, is it possible for the
client process that submits the Flink applica
Hello,
Today, we received an alert because the operator appeared to be down. Upon
further investigation, we realized the alert was triggered because the
endpoint for Prometheus metrics (which we enabled) stopped responding, so
it seems the endpoint used for the liveness probe wasn't affected and t
Hi Alexis,
We have recently added support for canary deployments which allows the
liveness probe to detect general operator problems.
https://issues.apache.org/jira/browse/FLINK-31219
It's not completely automatic and you have to deploy the canaries yourself
but I think it will be helpful :)
Thi
