Hi Rohith,
I guess the `word_count.py` you tried to execute is from flink release-1.15
or master branch. For pyflink 1.14 you are using, you need to change
`t_env.get_config().set_string("parallelism.default", "1")` to
`t_env.get_config().get_configuration().set_string("parallelism.default",
"1")`
Hi,
I set up pyflink on my system for python version 3.7.5 and pyflink version
1.14.4.
When i try to run word_count.py using command "python word_count.py" I get
this error
Traceback (most recent call last):
File "word_count.py", line 146, in
word_count(known_args.input, known_args.output)
