flink-rookie
flink-rookie copied to clipboard
Flink 菜鸟公众号代码地址
大佬,在CustomDebeziumDeserializationSchema 里面的 parseRecord这个方法 里面的 枚举值 好像列举的不全吧? 假如我mysql端的数据类型(decimal、date、datetime)在这个枚举里面找不到,数据就会被丢弃,比如我一行数据有三列,假如有一列数据类型匹配不上,就会变成两列 。。。。 从而导入失败(ps:不知道我这样理解的对不对。。。)
Bumps [io.lettuce:lettuce-core](https://github.com/lettuce-io/lettuce-core) from 5.0.5.RELEASE to 6.5.1.RELEASE. Release notes Sourced from io.lettuce:lettuce-core's releases. 6.5.1.RELEASE What's Changed Bump to netty 4.1.115.Final to consume the security fix for CVE-2024-47535 by @tishun Restore API...
Bumps org.apache.hadoop:hadoop-common from 3.1.1 to 3.4.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...