我使用的flink版本是1.14.0,在flink-conf.yaml里添加了latency的配置
但是我在web-ui中没有找到这个指标

请问下是哪里出问题了。
flink任务是从kafka中读数据写入mysql中


public class FlinkSqlTask {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = 
StreamExecutionEnvironment.createRemoteEnvironment("10.215.142.175", 7080);
        env.getConfig().setParallelism(1);
        EnvironmentSettings streamSettings = 
EnvironmentSettings.newInstance().inStreamingMode().useBlinkPlanner().build();
        StreamTableEnvironment tableEnvironment 
=StreamTableEnvironment.create(env, streamSettings);
        
tableEnvironment.getConfig().setSqlDialect(SqlDialect.DEFAULT);
        StatementSet stmtSet = 
tableEnvironment.createStatementSet();
        String originSql = "create table class0 (id 
int,name string) with 
('connector'='kafka','topic'='test.280.91.test.class','properties.bootstrap.servers'='10.215.142.175:9092','debezium-json.schema-include'='true','scan.startup.mode'
 = 
'latest-offset','properties.group.id'='test.280.91-dbhistory','format'='debezium-json')";
        String targetSql = "create table class_test (id 
int,name string,primary key(id) NOT ENFORCED) with 
('connector'='jdbc','url'='jdbc:mysql://10.215.142.98:43306/test?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true','username'='root','password'
 ='ecidi@2019+Ecidi@2019','table-name'='class_test')";
        String insertSql = "insert into class_test(id,name) 
select id,name from class0 where 1=1";
        tableEnvironment.executeSql(originSql);
        tableEnvironment.executeSql(targetSql);
        stmtSet.addInsertSql(insertSql);
        stmtSet.execute();
    }
}

回复