pyalink连接mysql问题

[suochen123]

运行代码 mysql=MySqlCatalog("mysql_test_catalog", "alink_test","5.7.11", "jdbc:mysql://ip:port/alink_test", "port",user,password) catalogObject = CatalogObject(mysql, ObjectPath("alink_test", "adult_train")) adult_batch=CatalogSourceBatchOp().setCatalogObject(catalogObject)

报错： Py4JJavaError: An error occurred while calling z:com.alibaba.alink.operator.batch.BatchOperator.execute. : java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: Could not find the mysql catelog factory.

相关plugin已经下载 在pyalink的 lib/plugins/flink-1.12/mysql-5.1.27 目录下

该问题需要如何解决

[shaomengwang]

可能需要调用一下 useLocalEnv()

[suochen123]

可能需要调用一下 useLocalEnv()

前面有调用的，结果还是刚刚那个

[GuarderS]

Hi bro, mysql = MySqlCatalog("mysql_test_catalog", "databaseName", "5.1.27", "ip", "port", "username", "password")