使用FLINK CDC获取数据，引用flink-connector-dm-cdc-2.4.1.jar，涉及表名user类似的表名,出错

Caused by: java.lang.RuntimeException: dm.jdbc.driver.DMException: 第 1 行, 第 30 列[user]附近出现错误: 

出错代码位于DMScanFetchTask类，

statement.execute(String.format("LOCK TABLE %s IN SHARE MODE", tableId.schema() + "." + tableId.table()));

希望改为增加引号转义符的语句

statement.execute(String.format("LOCK TABLE %s IN SHARE MODE", tableId.schema() + ".\"" + tableId.table() + "\""));