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
