You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Right now the audit operator is initialized on ScanTableSource.getScanRuntimeProvider which is run on flink client. which means all objects in DAG should be serialized.
So the job cannot be submitted,the error log as follows:
also the mysql mysql jdbc connector should be added to the connector fat jar
dockerzhang
changed the title
[Bug] The audit operator in mysql connector cannot be serialized and the job cannot submit to jobmanager
[Bug][Sort] The audit operator in mysql connector cannot be serialized and the job cannot submit to jobmanager
May 29, 2024
What happened
The audit operator cannot be serialized
Right now the audit operator is initialized on ScanTableSource.getScanRuntimeProvider which is run on flink client. which means all objects in DAG should be serialized.
So the job cannot be submitted,the error log as follows:
also the mysql mysql jdbc connector should be added to the connector fat jar
What you expected to happen
job can submit to flink cluster
How to reproduce
submit flink mysql source to flink cluster
Environment
flink 1.15
InLong version
master
InLong Component
InLong Sort
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: