"DROP FUNCTION IF EXISTS not_exists" cause job dead #853

mysql> GRANT CREATE ROUTINE, SUPER ON *.* TO 'test_dest'@'%';

{
  "job_id": "ddl_function",
  "is_password_encrypted": true,
  "task_step_name": "all",
  "failover": true,
  "retry": 2,
  "src_task": {
    "task_name": "src",
    "node_id": "6bb58ed5-d845-3867-c4e8-165e3d1a7531",
    "mysql_src_task_config": {
      "gtid": "",
      "binlog_relay": false,
      "expand_syntax_support": true
    },
    "drop_table_if_exists": true,
    "skip_create_db_table": false,
    "repl_chan_buffer_size": 120,
    "chunk_size": 2000,
    "group_max_size": 1,
    "group_timeout": 100,
    "connection_config": {
      "database_type": "MySQL",
      "host": "172.100.9.3",
      "port": 3306,
      "user": "test_src",
      "password": "Wk6cdmBGfccREf7T6krFwsmgBL0X2MJ7tjzf7kINyAqUlwT1omW76IBsB2de1SReNTHcKgknbIuaus8wv0asNSl/L0QrW+iyCHXyN7VgxzVpr06QnVPxeK4+/XNdMEVyDbKiSbw+JDxdr7pIKAMn6YPyj8Gyi2fKOO9JesNEAQI="
    },
    "replicate_do_db": [
      {
        "table_schema": "action_db_1"
      }
    ]
  },
  "dest_task": {
    "task_name": "dest",
    "node_id": "519342ac-bc81-8740-9a35-dbaae5c94255",
    "mysql_dest_task_config": {
      "use_my_sql_dependency": false,
      "dependency_history_size": 2500,
      "parallel_workers": 32
    },
    "connection_config": {
      "database_type": "MySQL",
      "host": "172.100.9.2",
      "port": 3306,
      "user": "test_dest",
      "password": "ZITUZbQDOMv8h4FC0w3sRfQLOKr/JuomDpbyrz+OYJteAf5ojUPBfbrz6fDD9/6EyPVMahQ6BGB4DV0wz7oK4OE3nWGKaKyUgrxaJYLKe6chYXX1RryCB+wQdrpvGuGjV807cEpCwm98jYMWOjj9fejWqd7ozEgMwWRCA2Z0ouA="
    }
  }
}

DROP FUNCTION IF EXISTS not_exists;

# src dtle log
2021-12-31T13:45:47.837+0800 [DEBUG] client.driver_mgr.dtle: publish: driver=dtle gno=134 job=ddl_function-migration partLen=244 @module=dtle.extractor iSeg=0 subject=ddl_function-migration_incr_hete timestamp=2021-12-31T13:45:47.837+0800
2021-12-31T13:45:47.837+0800 [DEBUG] client.driver_mgr.dtle: publish.after: driver=dtle n=1 @module=dtle.extractor gno=134 job=ddl_function-migration timestamp=2021-12-31T13:45:47.837+0800
2021-12-31T13:45:47.838+0800 [ERROR] client.driver_mgr.dtle: onError: driver=dtle @module=dtle.extractor err="applier error/restart: tx.Exec. gno 134 iEvent 0 queryBegin DROP FUNCT workerIdx 0: Error 1370: alter routine command denied to user 'test_dest'@'%' for routine 'action_db_1.not_exists'" job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.839+0800 [DEBUG] client.driver_mgr.dtle: extractor shutdown: driver=dtle @module=dtle.extractor job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.839+0800 [INFO]  client.driver_mgr.dtle: extractor shutdown: driver=dtle @module=dtle.extractor job=ddl_function-migration timestamp=2021-12-31T13:45:47.839+0800
2

# dest dtle log
2021-12-31T13:45:47.838+0800 [DEBUG] client.driver_mgr.dtle: execQuery: driver=dtle @module=dtle.applier job=ddl_function-migration query="USE `action_db_1`" timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [DEBUG] client.driver_mgr.dtle: ParseQueryEventFlags: driver=dtle @module=dtle.applier.ApplyBinlogEvent.ParseQueryEventFlags bytes=0000000000012000a055000000000603737464042d002d000800 job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [DEBUG] client.driver_mgr.dtle: execQuery: driver=dtle @module=dtle.applier job=ddl_function-migration query="DROP FUNCTION IF EXISTS not_exists /*dtle_gtid1 ddl_function-migration 11a020af-69f9-11ec-8f22-0242ac640903 134 dtle_gtid*/" timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [ERROR] client.driver_mgr.dtle: Exec sql error: driver=dtle @module=dtle.applier.ApplyBinlogEvent err="tx.Exec. gno 134 iEvent 0 queryBegin DROP FUNCT workerIdx 0: Error 1370: alter routine command denied to user 'test_dest'@'%' for routine 'action_db_1.not_exists'" job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [ERROR] client.driver_mgr.dtle: onError: driver=dtle err="tx.Exec. gno 134 iEvent 0 queryBegin DROP FUNCT workerIdx 0: Error 1370: alter routine command denied to user 'test_dest'@'%' for routine 'action_db_1.not_exists'" job=ddl_function-migration @module=dtle.applier timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [DEBUG] client.driver_mgr.dtle: onError. nats published: driver=dtle job=ddl_function-migration @module=dtle.applier timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [INFO]  client.driver_mgr.dtle: Shutting down: driver=dtle @module=dtle.applier job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [DEBUG] client.driver_mgr.dtle: Shutdown. a.ai.wg.Wait. after: driver=dtle @module=dtle.applier job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [DEBUG] client.driver_mgr.dtle: Shutdown. a.wg.Wait. after: driver=dtle @module=dtle.applier job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [DEBUG] client.driver_mgr.dtle: Shutdown. CloseDB. after: driver=dtle @module=dtle.applier job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [DEBUG] client.driver_mgr.dtle: Shutdown. CloseConns. after: driver=dtle @module=dtle.applier job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
2021-12-31T13:45:47.838+0800 [INFO]  client.driver_mgr.dtle: Shutdown: driver=dtle @module=dtle.applier job=ddl_function-migration timestamp=2021-12-31T13:45:47.838+0800
20

9.9.9.9-master-92cc3be