描述

我目前正在使用apache光束实现一个带有数据流的批处理作业，当我使用直接运行器时，这工作得很好。更改此设置会引发以下异常，不确定错误来自哪里。

代码片段

在此处输入图像描述

错误：

Raceback（最近一次调用最后一次）：File"/usr/local/lib/python3.9/site-包/beam_mysql/连接器/client.py"，第179行，在enter self. conn=mysql.连接器.connect（**self._config）File"/usr/local/lib/python3.9/site-包/mysql/连接器/pooling.py"，第286行，在connect返回CMySQLConnection（*args，**kwargs）File"/usr/local/lib/python3.9/site-包/mysql/连接器/connection_cext.py"，第101行，在init self.connect（**kwargs）File"/usr/local/lib/python3.9/site-包/mysql/连接器/abstracts.py"，第1095行，在connect self._open_connection（）File"/usr/local/lib/python3.9/site-包/mysql

在处理上述异常期间，发生了另一个异常：