I created <https://issues.apache.org/jira/browse/F...
# troubleshootinga
Ari Huttunen
03/01/2023, 7:53 AMAri Huttunen
03/01/2023, 8:08 AMExample code should also be run, so it actually works. Here I'm trying to run the code in the complete example so far on https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/python/table_api_tutorial/
and this results in
Copy code
python word-count.py
Traceback (most recent call last):
File "word-count.py", line 129, in <module>
word_count(known_args.input, known_args.output)
File "word-count.py", line 51, in word_count
t_env.get_config().set("parallelism.default", "1")
AttributeError: 'TableConfig' object has no attribute 'set'd
Dian Fu
03/01/2023, 9:00 AM@Ari Huttunen I believe this example should work. Could you double check which PyFlink version you are using? This method is added in Flink 1.15.
a
Ari Huttunen
03/01/2023, 9:01 AMWe have Flink 1.16.
Ari Huttunen
03/01/2023, 9:02 AMπ¬
Ari Huttunen
03/01/2023, 9:02 AM Copy code
(base) pip list
Package Version
---------------------- ---------
apache-beam 2.27.0
apache-flink 1.14.0
apache-flink-libraries 1.14.0
apache-flink-ml 2.0.0Ari Huttunen
03/01/2023, 9:03 AMI found the problem. π
π 1
Ari Huttunen
03/01/2023, 9:09 AMThis may explain some other problems I've been having. Too bad there is no warning in capital letters like:
CHECK YOUR FLINK VERSIONS.
3 Views