Add Support for Flink 1.13

[wey-gu]

The maintainer doesn't have the bandwidth for this now, hopefully, anyone could help/volunteer on this.

[JimWen]

please check this pr
Add Support up to Flink 1.14
#52

[markjoin123]

May I ask when will you merge spending flink 1.14 version?

[spike-liu]

@wey-gu another implementation has been included in #57. Please feel free to review.

[wey-gu]

@wey-gu another implementation has been included in #57. Please feel free to review.

Amazing, this is extra awesome! Thanks!!

[spike-liu]

@wey-gu another implementation has been included in #57. Please feel free to review.

Amazing, this is extra awesome! Thanks!!

It is our pleasure, Wey.

Currently we are working on a project which using flink SQL to process data like Kafka -> join nebula -> write nebula. We would like to contribute more codes to community in the future. Hence any comments are appreciated:)

[wey-gu]

Thank you so much @spike-liu !

It's so lucky to have you in the community, and if you don't mind, it's more than welcome to share your work in our meetup/blog, too :)

cc @tian-zhong @lisahui @Nicole00

[spike-liu]

Thank you so much @spike-liu !

It's so lucky to have you in the community, and if you don't mind, it's more than welcome to share your work in our meetup/blog, too :)

cc @tian-zhong @lisahui @Nicole00

Definitely, best practice would also be scheduled in community.

[liuxiaocs7]

I noticed that Flink has updated the source and sink function interfaces, just as FLIP-27: Refactor Source Interface and FLIP-143: Unified Sink API, should we update the interfaces if we want to support more higher version of flink.

[Nicole00]

I noticed that Flink has updated the source and sink function interfaces, just as FLIP-27: Refactor Source Interface and FLIP-143: Unified Sink API, should we update the interfaces if we want to support more higher version of flink.

Great idea! @spike-liu could you take up your precious time to discuss this idea together if you are interested in it? We'll be very glad to hear from you and your team.

[spike-liu]

I noticed that Flink has updated the source and sink function interfaces, just as FLIP-27: Refactor Source Interface and FLIP-143: Unified Sink API, should we update the interfaces if we want to support more higher version of flink.

Great idea! @spike-liu could you take up your precious time to discuss this idea together if you are interested in it? We'll be very glad to hear from you and your team.

This is our honor, @Nicole00.

There are a lot of information in these two proposals. Please give us some time to read them.

@liuxiaocs7 Thanks for bring it on.

[spike-liu]

created separate issues to discuss.

[spike-liu]

@wey-gu this issue could be closed and completed in 93df7a1

[wey-gu]

Roger that :) Thanks a lot, @spike-liu !

Thanks a lot for @liuxiaocs7 and @JimWen , too!

[spike-liu]

Roger that :) Thanks a lot, @spike-liu !

Thanks a lot for @liuxiaocs7 and @JimWen , too!

My pleasure, Wey.