Re: Using flink-connector-kafka-1.9.1 with flink-core-1.7.2

2020-05-18 Thread Arvid Heise
Hi Nick, yes, you can be lucky that no involved classes have changed (much), but there is no guarantee. You could try to fiddle around and add the respective class ( *ClosureCleanerLevel)* from Flink 1.9 in your jar, but it's hacky at best. Another option is to bundle Flink 1.9 with your code if

Re: Using flink-connector-kafka-1.9.1 with flink-core-1.7.2

2020-05-06 Thread Arvid Heise
Hi Nick, all Flink dependencies are only compatible with the same major version. You can workaround it by checking out the code [1] and manually set the dependency of the respective module to your flink-core version and revert all changes that are not compiling. But there is no guarantee that thi