我有一个这样的 SQL 查询
String ipdetailsSql = "select sid, _zpsbd6 as ip_address, ssresp, reason, " +
"SUM(CASE WHEN botcode='r1' THEN 1 ELSE 0 END ) as icf_count, " +
"SUM(CASE WHEN botcode='r2' THEN 1 ELSE 0 END ) as dc_count, " +
"SUM(CASE WHEN botcode='r5' THEN 1 ELSE 0 END ) as badua_count, " +
"COUNT(*) as hits, TUMBLE_START(ts, INTERVAL '1' MINUTE) AS fseen " +
"from sourceTopic " +
"GROUP BY TUMBLE(ts, INTERVAL '1' MINUTE), sid, _zpsbd6, ssresp, reason";
根据用户输入,我想将 botcode='r1' 更改为给定输入。说 botcode='r10' 而不重新启动作业。有没有办法做到这一点。我在使用流 env 的 flink 1.7 上。我尝试配置流来读取输入。但停留在如何即时更改查询。谁能帮我这个?提前致谢