Hi Kamil, I have checked that this method exists in 1.12.3: https://github.com/apache/flink/blob/release-1.12.3/flink-python/src/main/java/org/apache/flink/python/util/PythonConfigUtil.java#L137
Could you double check whether the Flink version is 1.12.3 (not just the PyFlink version)? Regards, Dian On Tue, Oct 5, 2021 at 11:34 PM Nicolaus Weidner < nicolaus.weid...@ververica.com> wrote: > Hi Kamil, > > On Tue, Oct 5, 2021 at 9:03 AM Kamil ty <kamilt...@gmail.com> wrote: > >> Hello, >> >> I'm trying to run a pyflink job in cluster mode (with yarn). My job >> contains source and sink definitions using Table API which are converted to >> a datastream and back. Unfortunately I'm getting an unusual exception at: >> *table = t_env.from_data_stream(ds, 'user_id, first_name, last_name).* >> > > Just to make sure: Is the missing quotation mark just a typo in your mail, > or your code (right before the closing bracket)? > *table = t_env.from_data_stream(ds, 'user_id, first_name, last_name['])* > > Best regards, > Nico >
