kingbase->kingbase 开启增量同步，脚本使用Flink SQL模式提交报告'connector'='tis-kingbase-x'无法找到

[baisui1981]

kingbase->kingbase 开启增量同步，脚本使用Flink SQL模式提交任务报告'connector'='tis-kingbase-x'无法找到

Table options are:

'connector'='tis-kingbase-x'
'dataxName'='kingbase_kingbase'
'fromTableName'='king_orderdetail'
        at com.qlangtech.plugins.incr.flink.launch.TISFlinkCDCStreamFactory.deploy(TISFlinkCDCStreamFactory.java:221)
        at com.qlangtech.tis.coredefine.module.action.TISK8sDelegate.deploy(TISK8sDelegate.java:149)
        at com.qlangtech.tis.coredefine.module.action.CoreAction.lambda$getFlinkJobWorkingOrchestrate$9(CoreAction.java:836)
        at com.qlangtech.tis.datax.job.JobResName$1.accept(JobResName.java:54)
        at com.qlangtech.tis.datax.job.SubJobResName.execute(SubJobResName.java:36)
        at com.qlangtech.tis.datax.job.JobResName.execSubJob(JobResName.java:71)
        at com.qlangtech.tis.coredefine.module.action.LaunchIncrSyncChannel.lambda$executeLaunch$1(LaunchIncrSyncChannel.java:96)
        at com.qlangtech.tis.datax.job.ServerLaunchToken.writeLaunchToken(ServerLaunchToken.java:431)
        ... 168 common frames omitted
Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Unable to create a sink for writing table 'default_catalog.default_database.king_king_orderdetail'.

Table options are:

'connector'='tis-kingbase-x'
'dataxName'='kingbase_kingbase'
'fromTableName'='king_orderdetail'
        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:373)
        at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:223)
        at org.apache.flink.client.program.PackagedProgramUtils.getPipelineFromProgram(PackagedProgramUtils.java:158)
        at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:82)
        at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:117)
        at com.qlangtech.tis.plugins.flink.client.FlinkClient.submitJar(FlinkClient.java:85)
        at com.qlangtech.plugins.incr.flink.launch.clustertype.AbstractClusterType.deploy(AbstractClusterType.java:86)
        at com.qlangtech.plugins.incr.flink.launch.TISFlinkCDCStreamFactory.deploy(TISFlinkCDCStreamFactory.java:230)
        at com.qlangtech.plugins.incr.flink.launch.TISFlinkCDCStreamFactory.deploy(TISFlinkCDCStreamFactory.java:214)
        ... 175 common frames omitted
Caused by: org.apache.flink.table.api.ValidationException: Unable to create a sink for writing table 'default_catalog.default_database.king_king_orderdetail'.

Table options are:

'connector'='tis-kingbase-x'
'dataxName'='kingbase_kingbase'
'fromTableName'='king_orderdetail'
        at org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:338)
        at org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:450)
        at org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:227)
        at org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:177)
        at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
        at scala.collection.Iterator.foreach(Iterator.scala:937)
        at scala.collection.Iterator.foreach$(Iterator.scala:937)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
        at scala.collection.IterableLike.foreach(IterableLike.scala:70)
        at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
        at scala.collection.TraversableLike.map(TraversableLike.scala:233)
        at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
        at scala.collection.AbstractTraversable.map(Traversable.scala:104)
        at org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:177)
        at org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1308)
        at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:874)
        at org.apache.flink.table.api.internal.StatementSetImpl.execute(StatementSetImpl.java:109)
        at com.qlangtech.tis.realtime.TISTableEnvironment.executeMultiStatment(TISTableEnvironment.java:53)
        at com.qlangtech.tis.realtime.TableRegisterFlinkSourceHandle.processTableStream(TableRegisterFlinkSourceHandle.java:105)
        at com.qlangtech.tis.realtime.BasicFlinkSourceHandle.consume(BasicFlinkSourceHandle.java:111)
        at com.qlangtech.plugins.incr.flink.TISFlinkCDCStart.deploy(TISFlinkCDCStart.java:119)
        at com.qlangtech.plugins.incr.flink.TISFlinkCDCStart.main(TISFlinkCDCStart.java:67)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.base/java.lang.reflect.Method.invoke(Method.java:566)
        at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:356)
        ... 183 common frames omitted
Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a connector using option: 'connector'='tis-kingbase-x'
        at org.apache.flink.table.factories.FactoryUtil.enrichNoMatchingConnectorError(FactoryUtil.java:814)
        at org.apache.flink.table.factories.FactoryUtil.discoverTableFactory(FactoryUtil.java:788)
        at org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:333)
        ... 210 common frames omitted
Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'tis-kingbase-x' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.

[baisui1981]

已经完善，添加了对应的Connector