flink数据流 单(kafka)流根据id去重

方法1 不推荐

package com.yy.uniq

import org.apache.flink.configuration.{Configuration, RestOptions}
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment

import 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 Configuration
    conf.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