为什么我的flink upsert-kafka 没有数据输出

2024-01-09 14:31:16

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

测试代码

package com.yy.state.OperatorStateTTL

import 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.StreamTableEnvironment

import java.time.ZoneId

/**
 * desc: 用来测试 flink1.18 支持双流 regular join 分别控制两个流各自state的ttl, 老版本只能全局控制所有state的ttl
 */
object TTLDemoV1 {
  def main(args: Array[String]): Unit = {
    val conf = new Configuration
    conf.setInteger(RestOptions.PORT, 28080)

    // 从指定的checkpoint启动 不配置则无状态启动
    //    conf.setString("executi

文章来源:https://blog.csdn.net/qq_35515661/article/details/135410609
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。