Jason Zhang
Jason Zhang
感谢您的贡献，@idleyui 能帮忙看下这个 PR 吗？
是的，由于 SDK 使用 Apache Arrow 作为数据传输协议（之一）。 在 JDK 9+ 的版本，需要增加 --add-opens=java.base/java.nio=org.apache.arrow.memory.core,ALL-UNNAMED 当然，在环境变量里增加也可以
> What's more, considering that the number of buckets and parallelism may not be consistent, should we remove the constraint on [EventPartitioner](https://github.com/apache/flink-cdc/blob/2bd2e4ce24ec0cc6a11129e3e3b32af6a09dd977/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/EventPartitioner.java#L25)? Although the number of buckets and parallelism will...
Can this PR be merged before the other [PR](https://github.com/apache/flink-cdc/pull/3254)? Both PRs are marked for inclusion in version 3.2, but the other PR depends on this one. I will need some...
hi, @leonardBang, can you help to review again and merge this?
> > hi, @leonardBang, can you help to review again and merge this? > > I append one commit to polish the interface and package, Could you also take a...