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 <module>
    word_count(known_args.input, known_args.output)
  File "word_count.py", line 68, in word_count
    t_env.get_config().set_string("parallelism.default", "1")
AttributeError: 'TableConfig' object has no attribute 'set'

Can you help in resolving this issue?

Best
Rohith.

Reply via email to