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
Hello,
Just wanted to verify if the default build of pyflink available from PyPi
is compatible with flink - scala version 2.12. I have noticed that the PyPi
pyflink version comes with apache-flink-libraries targeted for scala 2.11
only and I was wondering if this might be the cause of some issues
