Hi Ramana,
The method appearing in the exception message was updated in Flink 1.15,
see [1] for more details. So I believe there must be jars of version 1.15
in your environment and could you double check that?
Regards,
Dian
[1]
https://github.com/apache/flink/commit/dd1fddb13b2d08ade580e5b3ec6b
Hi Xingbo
I have double checked on this, both the flink and pyflink versions that i
have are 1.14.4 on Jobmanager and task manager.
However, I still get this error.
Thanks
Ramana
On Tue, Sep 6, 2022, 14:23 Xingbo Huang wrote:
> Hi Raman,
>
> This problem comes from the inconsistency between
Hi Raman,
This problem comes from the inconsistency between your flink version and
pyflink version
Best,
Xingbo
Ramana 于2022年9月6日周二 15:08写道：
> Hello there,
>
> I have a pyflink setup of 1 : JobManager - 1 : Task Manager.
>
> Trying to run a pyflink job and no matter what i do, i get the follow
