[clickhouse] mysql-> clickhouse 使用k8s 集群同步方式

[baisui1981]

mysql-> clickhouse ,启动过程中报错

Caused by: com.qlangtech.tis.lang.TisException: java.lang.RuntimeException: java.lang.InstantiationException: java.lang.NoClassDefFoundError: com/qlangtech/tis/realtime/DefaultFlinkSourceHandle
	at com.qlangtech.tis.coredefine.module.action.CoreAction.doDeployIncrSyncChannal(CoreAction.java:575)
	... 124 common frames omitted
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: java.lang.InstantiationException: java.lang.NoClassDefFoundError: com/qlangtech/tis/realtime/DefaultFlinkSourceHandle
	at com.qlangtech.plugins.incr.flink.TISFlinkClassLoaderFactory.lambda$buildClientLoaderFactory$1(TISFlinkClassLoaderFactory.java:120)
	at org.apache.flink.client.ClientUtils.buildUserCodeClassLoader(ClientUtils.java:87)
	at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:145)
	at org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:65)
	at org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:691)
	at com.qlangtech.tis.plugins.flink.client.FlinkClient.submitJar(FlinkClient.java:80)
	at com.qlangtech.plugins.incr.flink.launch.FlinkTaskNodeController.deploy(FlinkTaskNodeController.java:179)
	at com.qlangtech.plugins.incr.flink.launch.FlinkTaskNodeController.deploy(FlinkTaskNodeController.java:144)
	at com.qlangtech.tis.coredefine.module.action.TISK8sDelegate.deploy(TISK8sDelegate.java:136)
	at com.qlangtech.tis.coredefine.module.action.CoreAction.doDeployIncrSyncChannal(CoreAction.java:569)
	... 124 common frames omitted
Caused by: java.lang.RuntimeException: java.lang.InstantiationException: java.lang.NoClassDefFoundError: com/qlangtech/tis/realtime/DefaultFlinkSourceHandle
	at com.qlangtech.tis.extension.ExtensionFinder$Sezpoz.removeByType(ExtensionFinder.java:168)
	at com.qlangtech.tis.extension.impl.ClassicPluginStrategy.lambda$removeByClassNameInFinders$0(ClassicPluginStrategy.java:64)
	at java.util.Collections$SingletonList.forEach(Collections.java:4822)
	at com.qlangtech.tis.extension.impl.ClassicPluginStrategy.removeByClassNameInFinders(ClassicPluginStrategy.java:63)
	at com.qlangtech.plugins.incr.flink.TISFlinkClassLoaderFactory.lambda$buildClientLoaderFactory$1(TISFlinkClassLoaderFactory.java:105)
	... 133 common frames omitted
Caused by: java.lang.InstantiationException: java.lang.NoClassDefFoundError: com/qlangtech/tis/realtime/DefaultFlinkSourceHandle
	at net.java.sezpoz.IndexItem.element(IndexItem.java:146)
	at com.qlangtech.tis.extension.ExtensionFinder$Sezpoz.removeByType(ExtensionFinder.java:160)
	... 137 common frames omitted
Caused by: java.lang.NoClassDefFoundError: com/qlangtech/tis/realtime/DefaultFlinkSourceHandle
	at java.lang.ClassLoader.defineClass1(Native Method)
	at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
	at org.apache.tools.ant.AntClassLoader.defineClassFromData(AntClassLoader.java:1150)
	at org.apache.tools.ant.AntClassLoader.getClassFromStream(AntClassLoader.java:1318)
	at org.apache.tools.ant.AntClassLoader.findClassInComponents(AntClassLoader.java:1374)
	at org.apache.tools.ant.AntClassLoader.findClass(AntClassLoader.java:1335)
	at sun.reflect.GeneratedMethodAccessor18.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at com.qlangtech.tis.extension.util.ClassLoaderReflectionToolkit.invoke(ClassLoaderReflectionToolkit.java:62)
	at com.qlangtech.tis.extension.util.ClassLoaderReflectionToolkit._findClass(ClassLoaderReflectionToolkit.java:91)
	at com.qlangtech.tis.extension.UberClassLoader.findClass(UberClassLoader.java:103)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
	at net.java.sezpoz.IndexItem.element(IndexItem.java:134)
	... 138 common frames omitted
Caused by: java.lang.ClassNotFoundException: by mysql2ch.tpi,for:com.qlangtech.tis.realtime.DefaultFlinkSourceHandle
	at com.qlangtech.tis.extension.impl.ClassicPluginStrategy$DependencyClassLoader.findClass(ClassicPluginStrategy.java:589)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
	at org.apache.tools.ant.AntClassLoader.findBaseClass(AntClassLoader.java:1405)
	at org.apache.tools.ant.AntClassLoader.loadClass(AntClassLoader.java:1102)
	at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
	... 153 common frames omitted

[baisui1981]

complete