方法1 不推荐

package com.yy.uniqimport org.apache.flink.configuration.{Configuration, RestOptions}
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.table.api.bridge.scala.StreamTableEnvironmentimport java.time.ZoneId/*** desc:*       stream1 join id去重后的stream1 on l.时间戳=r.时间戳 确保同一个id只输出一行.*       通过group by也可以.* {"order_id":9999,"ts":1627660800000}*/
object KafkaSchemaUniqIdDemo1 {def main(args: Array[String]): Unit = {val conf = new Configurationconf.setInteger(RestOptions.PORT, 28080)val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf)val tEnv: StreamTableEnvironment = StreamTableEnvironment.create(env)//    val tEnv: TableEnvironment = TableEnvironment.create(EnvironmentSettings.newInstance().build())tEnv.getConfig.setLocalTimeZone(ZoneId.of("Asia/Shanghai"))//    val Use