Re: dependency error with latest Kafka connector

2023-11-25 Thread guenterh.lists
Hi Gordon, thanks for working on it. How can I reference the repository for the new artifact. Referencing 3.0.2-18 I get an unresolved dependency error. Thanks for a hint. Günter sbt:flink_essential_swrapper> compile [info] Updating [info] Resolved  dependencies [warn] [warn]     Note: Unre

Operator ids

2023-11-25 Thread rania duni
Hello! I would like to know how can I get the operator ids of a running job. I know how can I get the task ids but I want the operator ids! I couldn’t find something to the REST API docs. Thank you.

Re: Operator ids

2023-11-25 Thread Oscar Perez via user
You, unfortunately, just cant AFAIK On Sat, 25 Nov 2023 at 14:45, rania duni wrote: > Hello! > > I would like to know how can I get the operator ids of a running job. I > know how can I get the task ids but I want the operator ids! I couldn’t > find something to the REST API docs. > Thank you.

Re: dependency error with latest Kafka connector

2023-11-25 Thread Tzu-Li (Gordon) Tai
Hi Günter, With Maven you'd list the staged repository holding the RC artifacts as a repository: ``` test_kafka_rc Apache Flink Kafka Connector v3.0.2 https://repository.apache.org/content/repositories/orgapacheflink-1675/ ``` With SBT, I think the equivalent is usi

Re: dependency error with latest Kafka connector

2023-11-25 Thread guenterh.lists
Thanks Gordon! I didn't know the name of the repository https://repository.apache.org/content/repositories/orgapacheflink-1675/ Additionally something learned. Yes, with the new version I can add the dependency "org.apache.flink" % "flink-connector-kafka" % "3.0.2-1.18", and compile it without

Re: dependency error with latest Kafka connector

2023-11-25 Thread Tzu-Li (Gordon) Tai
No problem, glad to hear that it's working now! With release candidates, we always publish the url for staged artifacts in the release candidate vote threads so that you can point your code to compile against those for testing purposes. Would be great to have your +1 on the vote thread for 3.0.2

Re: Operator ids

2023-11-25 Thread Zhanghao Chen
It is not supported yet. Curious why do you need to get the operator IDs? They are usually only used internally. Best, Zhanghao Chen From: rania duni Sent: Saturday, November 25, 2023 20:44 To: user@flink.apache.org Subject: Operator ids Hello! I would like to