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