Hi Phil,
AFAIK, the error indicated your path was incorrect.
your should use '/opt/flink/checkpoints/1875588e19b1d8709ee62be1cdcc' or
'file:///opt/flink/checkpoints/1875588e19b1d8709ee62be1cdcc' instead.
Best.
Jiadong.Lu
On 5/18/24 2:37 AM, Phil Stavridis wrote:
Hi,
I am trying to test how
Hi, Fidea.
The ElasticsearchSinkFunction Class has already marked as deprecated[1],
please try to use ElasticsearchSink Class.
Hope to help you.
Best.
Jiadong.Lu
1.
https://github.com/apache/flink-connector-elasticsearch/blob/153b8fc23e14c03c4bacf2c24fbe0fee286ec6e2/flink-connector
maybe you should try @Shammon's solution.
By the way, I have been submitting my Flink application by
RestClusterClient for a long time.
Or you can use the CLI by starting a subprocess.
Best
Jiadong Lu
On 2023/8/17 23:07, jiadong.lu wrote:
Hi Patricia
Have you tried the url path of '/v1/j
://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/
<https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/>
Screenshot 2023-08-16 at 1.18.25 PM.png
On Tue, Aug 15, 2023 at 12:31 AM jiadong.lu <http://jiadong.lu>
mailto:archzi...@gmail.com>&g
On Tue, Aug 15, 2023, 12:31 AM jiadong.lu <http://jiadong.lu>
mailto:archzi...@gmail.com>> wrote:
Hi, Patricia
I think you should have a look the REST API[1].
> "Even it is disabled sessions clusters still accept jobs through
REST
requests (Http calls). T
