【详述】执行bin/sql-client.sh -f flink-create.1.sql，之后，starrocks数仓里没有数据
【导入/导出方式】执行bin/sql-client.sh -f flink-create.1.sql
执行bin/flink list，查看任务显示No scheduled jobs.
【背景】做过哪些操作？
【业务影响】
【StarRocks版本】例如：1.18.2
【集群规模】例如：1fe（1 follower+2observer）+1be（fe与be混部）
【机器信息】CPU虚拟核/内存/网卡，例如：16C/32G/万兆
【附件】
你好，当前flink-cdc需要升级starrock版本到1.19.0，并且需要使用primary key数据模型
我重新部署了1.19的starrocks，使用./sql-client.sh -f …/…/smt/result/flink-create.1.sql同步数据后，还是未有数据。
我使用的各个根本：
Flink StarRocks connector V1.1.10-1.13
Fink 1.13.1
Flink CDC connector 2.0.2
Flink CDC connector 需要 1.4 版本
已换成cdc1.4版本，现在是./flink list 查看任务，有许多running的任务（之前是没有的），但是starrocks数仓里还是没有数据啊。我是用navicat连进数仓看的，没有数据。
job跑完后，数仓里还是未有数据。
看看flink日志中的错误信息
2021-11-02 17:23:57,586 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Disconnect job manager 00000000000000000000000000000000@akka.tcp://flink@localhost:6123/user/rpc/jobmanager_89 for job bdb959727a08e78fe9ef04c5453ebbab from the resource manager.
2021-11-02 17:24:00,202 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: TableSourceScan(table=[[default_catalog, jumper, vip_hospital_round_src]], fields=[id, hospital_id, code, name, sort_id, begin_week, end_week, is_empty, description, remind, status, create_id, create_time, modify_id, modify_time]) -> NotNullEnforcer(fields=[id]) -> Sink: Sink(table=[default_catalog.jumper.vip_hospital_round_sink], fields=[id, hospital_id, code, name, sort_id, begin_week, end_week, is_empty, description, remind, status, create_id, create_time, modify_id, modify_time]) (1/1) (51416593ec79d2a47c15aa5d70f038a4) switched from RUNNING to FAILED on 172.18.157.184:33374-b9c004 @ data-etl (dataPort=41628).
org.apache.kafka.connect.errors.ConnectException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation Error code: 1227; SQLSTATE: 42000.
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:857) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_201]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_201]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_201]
Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1323) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:483) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
… 3 more
2021-11-02 17:24:00,203 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job 0d6658922ca0878366f79d61e6d2a02f
2021-11-02 17:24:00,203 INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - Calculating tasks to restart to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_0.
2021-11-02 17:24:00,203 INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy [] - 1 tasks should be restarted to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_0.
2021-11-02 17:24:00,203 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job insert-into_default_catalog.jumper.vip_hospital_round_sink (0d6658922ca0878366f79d61e6d2a02f) switched from state RUNNING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:207) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:197) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:188) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:677) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:435) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at sun.reflect.GeneratedMethodAccessor46.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_201]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_201]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) [flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) [flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) [flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.11-1.13.1.jar:1.13.1]
Caused by: org.apache.kafka.connect.errors.ConnectException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation Error code: 1227; SQLSTATE: 42000.
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:857) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_201]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_201]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_201]
Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1323) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:483) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_201]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_201]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_201]
2021-11-02 17:24:00,204 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job insert-into_default_catalog.jumper.vip_hospital_round_sink (0d6658922ca0878366f79d61e6d2a02f) switched from state FAILING to FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:207) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:197) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:188) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:677) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:435) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at sun.reflect.GeneratedMethodAccessor46.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_201]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_201]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) [flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) [flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) [flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.11-1.13.1.jar:1.13.1]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.actor.Actor$class.aroundReceive(Actor.scala:517) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.actor.ActorCell.invoke(ActorCell.scala:561) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.Mailbox.run(Mailbox.scala:225) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.Mailbox.exec(Mailbox.scala:235) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [flink-dist_2.11-1.13.1.jar:1.13.1]
at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.11-1.13.1.jar:1.13.1]
Caused by: org.apache.kafka.connect.errors.ConnectException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation Error code: 1227; SQLSTATE: 42000.
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:857) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_201]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_201]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_201]
Caused by: java.sql.SQLSyntaxErrorException: Access denied; you need (at least one of) the RELOAD privilege(s) for this operation
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:120) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.StatementImpl.executeInternal(StatementImpl.java:764) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at com.mysql.cj.jdbc.StatementImpl.execute(StatementImpl.java:648) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.jdbc.JdbcConnection.executeWithoutCommitting(JdbcConnection.java:1323) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:483) ~[flink-sql-connector-mysql-cdc-1.4.0.jar:1.4.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_201]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_201]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_201]
2021-11-02 17:24:00,205 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Stopping checkpoint coordinator for job 0d6658922ca0878366f79d61e6d2a02f.
2021-11-02 17:24:00,205 INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore [] - Shutting down
2021-11-02 17:24:00,205 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job 0d6658922ca0878366f79d61e6d2a02f reached terminal state FAILED.
2021-11-02 17:24:00,207 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Stopping the JobMaster for job insert-into_default_catalog.jumper.vip_hospital_round_sink(0d6658922ca0878366f79d61e6d2a02f).
2021-11-02 17:24:00,207 INFO org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool [] - Releasing slot [1d843542a7c2a5b87dad7d8fa51d132d].
2021-11-02 17:24:00,207 INFO org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job 0d6658922ca0878366f79d61e6d2a02f
2021-11-02 17:24:00,207 INFO org.apache.flink.runtime.jobmaster.JobMaster [] - Close ResourceManager connection 618e815bb1f606f05c17b7044ebad0af: Stopping JobMaster for job insert-into_default_catalog.jumper.vip_hospital_round_sink(0d6658922ca0878366f79d61e6d2a02f)…
2021-11-02 17:24:00,207 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Disconnect job manager 00000000000000000000000000000000@akka.tcp://flink@localhost:6123/user/rpc/jobmanager_111 for job 0d6658922ca0878366f79d61e6d2a02f from the resource manager.
确认下 mysql 的连通性及用户权限
grant select, reload, show databases, replication slave, replication client on xx.xx to ‘xx’@‘xx’;
我快要抓狂了，rds用的是超级管理员的用户，拥有一切的权限，starrocks用的是root，不存在权限不够的。为什么会这样呢？
show grants for mysqladmin
试下 flink cdc 2.0.2 吧，不需要 reload 权限。
https://ververica.github.io/flink-cdc-connectors/release-2.0/content/connectors/mysql-cdc.html
不要用1.x版本，1.x MySQL cdc要锁表