PyFlink基础应用之kafka运行环境PyFlink需要特定的Python版本（3.5、3.6或3.7）。运行一下命令，以确保Python版本满足要求。$ python -VPyFlink已经发布到PyPi，可以直接安装：$ python -m pip install apache-flink拷贝三个jar包到FLINK_HOME/lib下。flink-connector-kafka_2.11

分析Flink通过JdbcCatalog发起查询过程源代码，必定调用tableExists方法，该方法中级联调用获取数据库和每个库的表，如果表非常多，有一定的性能损耗（OracleCatalog实现中做了优化）。在getLimitClause方法中使用oracle12（"FETCH FIRST " + limit + " ROWS ONLY"）的语法，而产品线大量使用oracle11版本，需要改造