Gentlemen,
I don't if dev is the right place to ask questions about pyflink mismatch problems. If this is not the case kindly guide me where can i register to ask these matters. I have problem with some apache-flink modules. I am running a 1.17.0 apache- flink and I write codes in Colab I faced a problem for import modules from pyflink.table import DataTypes from pyflink.table.descriptors import Schema, Kafka, Json, Rowtime from pyflink.table.catalog import FileSystem not working for me (python version 3.10) All other modules importing fine. I checked with your Github but didn't find these on yours too which means modules are not inside your descriptor.py too. I think it needed installation of connectors but it failed too. Please see the link below: https://github.com/aomidvar/scrapper-price-comparison/blob/d8a10f74101bf96974e769813c33b83d7a71f02b/kafkaconsumer1.ipynb I am running a test after producing the stream ( https://github.com/aomidvar/scrapper-price-comparison/blob/main/kafkaproducer1.ipynb) to Confluent server and I like to do a flink job but the above mentioned modules are not found with the following error in python: --------------------------------------------------------------------------- ImportError Traceback (most recent call last) <ipython-input-1-203af9e2c559> in <cell line: 2>() 1 from pyflink.table import DataTypes ----> 2 from pyflink.table.descriptors import Schema, Kafka, Json, Rowtime 3 from pyflink.table.catalog import FileSystem ImportError: cannot import name 'Kafka' from 'pyflink.table.descriptors' (/usr/local/lib/python3.10/dist-packages/pyflink/table/descriptors.py) --------------------------------------------------------------------------- NOTE: If your import is failing due to a missing package, you can manually install dependencies using either !pip or !apt. To view examples of installing some common dependencies, click the "Open Examples" button below. --------------------------------------------------------------------------- I have doubt that if current error is related to a version and dependencies then I have to ask the developer if I do this python 3.8 env is that possible to get solved? Thanks for your time , Alireza Omidvar
