[rdbsink表名与注册表名称一致][flinkSQL任务，设置结果表，提交运行中，停止该任务修改结果表，再次提交运行中，数据曲线变成两条，且新的结果表数据不正确][18063]

Author: todd5167

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/RdbSink.java

@@ -69,6 +69,8 @@ public abstract class RdbSink implements RetractStreamTableSink<Row>, Serializab
 
     protected String tableName;
 
+    protected String registerTabName;
+
     protected String sql;
 
     protected List<String> primaryKeys;
@@ -112,6 +114,7 @@ public RdbSink genStreamSink(TargetTableInfo targetTableInfo) {
         String tmpUserName = rdbTableInfo.getUserName();
         String tmpPassword = rdbTableInfo.getPassword();
         String tmpTableName = rdbTableInfo.getTableName();
+        String tmpRegisterName = rdbTableInfo.getName();
 
         Integer tmpSqlBatchSize = rdbTableInfo.getBatchSize();
         if (tmpSqlBatchSize != null) {
@@ -136,6 +139,7 @@ public RdbSink genStreamSink(TargetTableInfo targetTableInfo) {
         this.userName = tmpUserName;
         this.password = tmpPassword;
         this.tableName = tmpTableName;
+        this.registerTabName = tmpRegisterName;
         this.primaryKeys = rdbTableInfo.getPrimaryKeys();
         this.dbType = rdbTableInfo.getType();
 
@@ -193,7 +197,7 @@ protected void buildSqlTypes(List<Class> fieldTypeArray) {
     public void emitDataStream(DataStream<Tuple2<Boolean, Row>> dataStream) {
         RichSinkFunction richSinkFunction = createJdbcSinkFunc();
         DataStreamSink streamSink = dataStream.addSink(richSinkFunction);
-        streamSink.name(tableName);
+        streamSink.name(registerTabName);
         if (parallelism > 0) {
             streamSink.setParallelism(parallelism);
         }