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: Unresolved dependencies path:
[error] stack trace is suppressed; run last update for the full output
[error] (update) sbt.librarymanagement.ResolveException: Error
downloading org.apache.flink:flink-connector-kafka:3.0.2-18
[error] Not found
[error] Not found
[error] not found:
/home/swissbib/.ivy2/local/org.apache.flink/flink-connector-kafka/3.0.2-18/ivys/ivy.xml
[error] not found:
https://repo1.maven.org/maven2/org/apache/flink/flink-connector-kafka/3.0.2-18/flink-connector-kafka-3.0.2-18.pom
On 24.11.23 18:30, Tzu-Li (Gordon) Tai wrote:
Hi all,
I've cherry-picked FLINK-30400 onto v3.0 branch of flink-connector-kafka.
Treating this thread as justification to start a vote for 3.0.2 RC #1
immediately so we can get out a new release ASAP. Please see the vote
thread here [1].
@guenterh.lists <guenterh.li...@bluewin.ch> Would you be able to test this
RC and see if the issue is resolved for you? It should work simply by
having a dependency on flink-streaming-java and flink-clients for 1.18.0,
as well as flink-connector-kafka 3.0.2-18. The flink-connector-base
dependency you added in the end as a workaround should not be needed.
Thanks,
Gordon
[1] https://lists.apache.org/thread/34zb5pnymfltrz607wqcb99h7675zdpj
On Fri, Nov 24, 2023 at 5:16 AM Leonard Xu <xbjt...@gmail.com> wrote:
- built a fat uber jar from quickstart with Flink 1.18.0 for
flink-streaming-java and flink-clients, and flink-connector-kafka version
3.0.1-1.18
- then submitted to local Flink cluster 1.18.0. Things worked as
expected and the job ran fine.
Hey，@Gordan
I guess things may work as expected when you submit your fat jar job to
cluster, because flink-connector-base （1.18.0 in this case) has been
included to flink-dist jar [1] which will appear in your classpath, but it
may meet issue when you run in local IDE environment, maybe you can have a
local test to verify this.
In the end, I think we need to backport FLINK-30400 to the Flink Kafka
connector 3.0 branch and prepare a 3.0.2 soon.
Best,
Leonard
[1]
https://github.com/apache/flink/blob/977463cce3ea0f88e2f184c30720bf4e8e97fd4a/flink-dist/pom.xml#L156
--
Günter Hipler
https://openbiblio.social/@vog61
https://twitter.com/vog61
