我写了测试数据到kafka 为什么upsert-kafka 没有数据打印?

测试代码

package com.yy.state.OperatorStateTTLimport org.apache.flink.configuration.{Configuration, RestOptions}
import org.apache.flink.runtime.state.filesystem.FsStateBackend
import org.apache.flink.streaming.api.CheckpointingMode
import org.apache.flink.streaming.api.environment.CheckpointConfig
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.table.api.bridge.scala.StreamTableEnvironmentimport java.time.ZoneId/*** desc: 用来测试 flink1.18 支持双流 regular join 分别控制两个流各自state的ttl, 老版本只能全局控制所有state的ttl*/
object TTLDemoV1 {def main(args: Array[String]): Unit = {val conf = new Configurationconf.setInteger(RestOptions.PORT, 28080)// 从指定的checkpoint启动 不配置则无状态启动//    conf.setString("executi