Я пытаюсь отправить задание на платформу Ververica, развернутую в Kubernates, но я получил сообщение ниже, я отправляю тот же код в автономный Flink, и он работает нормально !! Я использую Flink 1.10.1 и код Scala 2.12.
Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSinkFactory' in
the classpath.
Reason: Required context properties mismatch.
The following properties are requested:
connector.driver=com.mysql.jdbc.Driver
connector.password=******
connector.table=*****
connector.type=jdbc
connector.url=jdbc:mysql://**********
connector.username=********
schema.0.data-type=VARCHAR(255)
schema.0.name=**********
schema.1.data-type=BIGINT
schema.1.name=****
schema.2.data-type=VARCHAR(255)
schema.2.name=*****
schema.3.data-type=DATE
schema.3.name=******
schema.4.data-type=BIGINT
schema.4.name=******
schema.5.data-type=VARCHAR(255)
schema.5.name=************
schema.6.data-type=DATE
schema.6.name=*********
The following factories have been considered:
org.apache.flink.table.sinks.CsvBatchTableSinkFactory
org.apache.flink.table.sinks.CsvAppendTableSinkFactory
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:335)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:205)
at org.apache.flink.client.program.OptimizerPlanEnvironment.getPipeline(OptimizerPlanEnvironment.java:80)
at org.apache.flink.client.program.PackagedProgramUtils.getPipelineFromProgram(PackagedProgramUtils.java:108)
at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:58)
at org.apache.flink.container.entrypoint.ClassPathJobGraphRetriever.retrieveJobGraph(ClassPathJobGraphRetriever.java:104)
... 9 more
Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSinkFactory' in
the classpath.