Merge Java Code with SDK 2.7 and 3.1


Currently I’m using flink for streaming data to couchbase
My existing code is using SDK 2.7

I need to develop new flink job using SDK 3.1

Is it possible to deploy both different SDK version in 1 flink server instance?
Is it backward compatible?


Hi Hans,

I haven’t tried it, but I think each Flink plugin runs in an isolated classloader. If that’s true, then you should be able to use SDK 2.7 in one plugin, and SDK 3 in another.

What’s impossible at the moment is to use both SDK 2.7 and SDK 3 in the same project, since these libraries contain conflicting classes.

Incidentally, there’s an experimental Flink connector on couchbaselabs. Would be great to get your feedback if you want to try it out.


1 Like