xuanbo / flink-cdc

CDC（变化数据捕获）实时同步方案，秒级延迟。

Hi there, I'm xuanbo! 👋

• 😄 后端开发工程师

Languages and Tools:

⚡ Technologies

These are some of the technologies and tools that I work with:

📚 Most Use

flink-cdc's Issues

集群模式报错

java.lang.NoSuchMethodError: org.apache.flink.table.api.EnvironmentSettings$Builder.useBlinkPlanner()Lorg/apache/flink/table/api/EnvironmentSettings$Builder;
at tk.fishfish.cdc.Application.main(Application.java:76)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:851)
at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:245)
at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1095)
at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)
at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)
什么原因呢？ 谢谢

问题

想请教下，
checkpoint:
dir: /Users/xuanbo/temp/checkpoint
这个地址是根据什么来配置的，
还有就是Flink Local 是在本地环境安装 Flink么？

能否支持读取达梦归档

能否支持读取达梦归档

job.yaml例子

能给给job.yaml的例子吗？