Thank you for the clarification. This was very helpful!
Kind regards
Kamil
On Wed, 10 Nov 2021, 02:26 Dian Fu, wrote:
> Hi Kamil,
>
> You are right that it comes with JAR packages of scala 2.11 in the PyFlink
> package as it has to select one version of JARs to bundle, either 2.11 or
> 2.12. Wh
Hi Kamil,
You are right that it comes with JAR packages of scala 2.11 in the PyFlink
package as it has to select one version of JARs to bundle, either 2.11 or
2.12. Whether it works with scala 2.12 depends on how you submit your job.
- If you execute the job locally, then it will use the JARs bund
