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

本文介绍: 我写了测试数据到kafka 为什么upsert-kafka 没有数据打印?

我写了测试数据到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

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。

如若转载，请注明出处：http://www.7code.cn/show_53586.html

如若内容造成侵权/违法违规/事实不符，请联系代码007邮箱：suwngjj01@126.com进行投诉反馈，一经查实，立即删除！

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。