metrics.latency.interval指标应该如何查看？

[陶浩然 <ta...@hdec.com>]

我使用的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();
    }
}