Hi, Dominik.

It seems that you only used Paimon's version number, But actually you
should include the version number of Flink, like
org.apache.paimon:paimon-flink-1.19:1.0.0.

You can see the main difference from the content of the two links below:
[1] https://mvnrepository.com/artifact/org.apache.paimon/paimon-flink/1.0.0
[2]
https://mvnrepository.com/artifact/org.apache.paimon/paimon-flink-1.19/1.0.0

<dominik.buen...@swisscom.com> 于2025年1月31日周五 22:57写道:

> Hi Flink Community
>
>
>
> I’m currently trying to get Paimon running in our k8s environment with
> Flink SQL (v1.19.1). I added the dependencies to our Flink SQL-Runner as
> well as the lib folder of the docker image:
>
>
>
> "org.apache.paimon"           %   "paimon-flink"              % "1.0.0",
> "org.apache.paimon"           %   "paimon-s3"                 % "1.0.0"
>
>
>
> runRaw(s"curl --output-dir /opt/flink/lib/ -sLO 
> https://artifactory.company.com/artifactory/maven-remote/org/apache/paimon/paimon-flink/*$*paimonVersion/paimon-flink-*$*paimonVersion.jar
>  
> <https://artifactory.company.com/artifactory/maven-remote/org/apache/paimon/paimon-flink/$paimonVersion/paimon-flink-$paimonVersion.jar>")
> runRaw(s"curl --output-dir /opt/flink/lib/ -sLO 
> https://artifactory.company.com/artifactory/maven-remote/org/apache/paimon/paimon-s3/*$*paimonVersion/paimon-s3-*$*paimonVersion.jar
>  
> <https://artifactory.swisscom.com/artifactory/maven-remote/org/apache/paimon/paimon-s3/$paimonVersion/paimon-s3-$paimonVersion.jar>")
>
>
>
> Then I try to create a Catalog like:
>
>
>
> tEnv.executeSql(
>   """CREATE CATALOG paimon WITH (
>     | 'type'='paimon',
>     | 'warehouse'='s3://tmp/paimon',
>     | 's3.access-key'='xxxx',
>     | 's3.secret-key'='yyyy'
>     |);
>     |""".stripMargin)
>
>
>
> Unfortunately, what I end up with is the following error message:
>
>
>
> Caused by: org.apache.flink.table.api.ValidationException: Could not find
> any factory for identifier 'paimon' that implements
> 'org.apache.flink.table.factories.CatalogFactory' in the classpath.
>
>
>
> Available factory identifiers are:
>
>
>
> generic_in_memory
>
>                 at
> org.apache.flink.table.factories.FactoryUtil.discoverFactory(FactoryUtil.java:617)
>
>                 at
> org.apache.flink.table.factories.FactoryUtil.getCatalogFactory(FactoryUtil.java:795)
>
>                 at
> org.apache.flink.table.factories.FactoryUtil.createCatalog(FactoryUtil.java:492)
>
>
>
>
>
> The error is the same when running in a TableEnvironment test or when
> running on k8s.
>
>
>
> Does anyone have an idea what is wrong here? Somehow it seems that my job
> can’t find the appropriate META-INF.services ->
> org.apache.flink.table.factories.Factory entry of the Paimon dependency?
>
>
>
> Kind Regards
>
> Dominik
>

Reply via email to