登录mysql后我的mysql版本是5.7.x但是我的sqoop的mysql-connect驱动是5.1.x的版本，所以使用下面命令时报错了：报错：Caused by: javax.net.ssl.SSLException: Received fatal alert: internal_error在连接的时候，加上?useSSL=false

【代码】flink 读取kafka 数据写入mysql。

window系统下和linux下的java环境冲突了，在python代码指定java的环境变量即可。