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";) 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
