e
Flink classes? (for example by setting the Flink dependencies to provided when
using the maven-shade-plugin).
For the issue while submitting the job, I can not provide you any further help,
because you haven't posted the exception that occurred in the REST handler.
Could you post this
environment:
flinksql 1.12.2
k8s session mode
description:
I got follow error log when my kafka connector port was wrong
>
2021-04-25 16:49:50
org.apache.kafka.common.errors.TimeoutException: Timeout of 6ms expired
before the position for partition filebeat_json_install_log-3 could
Hi all, I deployed the flink in K8S by session cluster [1]
the default plugin path is /opt/flink/plugins,
the default lib path is /opt/flink/lib,
the default usrlib path is /opt/flink/usrlib,
I wonder if it is possible for change the default path.
For example, I wish flink don't load libs from /o