Re: Required context properties mismatch in connecting the flink with mysql database

2020-10-14 Thread Dawid Wysakowicz
Hi, I think the problem is that you are using BatchTableEnvironment which is deprecated and does not support newer features such as e.g. FLIP-95 sources/sinks. I am sorry it is not more prominent in the documentation. I am not too familiar with the python API, and I am not sure if a unified

Required context properties mismatch in connecting the flink with mysql database

2020-10-13 Thread xi sizhe
I am using flink latest (1.11.2) to work with a sample mysql database, which the database is working fine. Additionally, i have added the flink-connector-jdbc_2.11-1.11.2, mysql-connector-java-8.0.21.jar, postgresql-42.2.17.jar to the {FLINK}/lib Here is my code T_CONFIG = TableConfig()