时来时去时不返 2021-08-18 11:07 采纳率: 100%
浏览 66
已结题

关于Flink接收Kafka流数据使用Table API和SQL处理的问题

img
你好,为什么我这边把你的代码复制过来报错呢?麻烦帮忙看看,包和依赖都导入了

  • 写回答

2条回答 默认 最新

  • CSDN专家-sinJack 2021-08-18 11:50
    关注

    你的包是不是导错了。删除你导入的包,把下面的包复制放你程序中。

    import org.apache.flink.api.common.typeinfo.TypeInformation;
    import org.apache.flink.streaming.api.TimeCharacteristic;
    import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
    import org.apache.flink.streaming.connectors.kafka.Kafka09TableSource;
    import org.apache.flink.streaming.util.serialization.*;
    import org.apache.flink.table.api.Table;
    import org.apache.flink.table.api.TableEnvironment;
    import org.apache.flink.table.api.Types;
    import org.apache.flink.table.api.java.StreamTableEnvironment;
    import org.apache.flink.table.sources.TableSource;
    import org.apache.flink.types.Row;
    import java.util.Properties;
    

    img

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
  • 时来时去时不返 2021-08-18 15:54
    关注

    img
    你的能启动嘛?我的怎么报错了

    评论
查看更多回答(1条)

报告相同问题?

问题事件

  • 系统已结题 8月26日
  • 已采纳回答 8月18日
  • 创建了问题 8月18日

悬赏问题

  • ¥15 请教一下simulink中S函数相关问题
  • ¥15 Hadoop中eclipse运行问题
  • ¥15 在二层网络中,掩码存在包含关系即可通信
  • ¥15 端口转发器解析失败不知道电脑设置了啥
  • ¥15 Latex算法流程图行号自定义
  • ¥15 关于#python#的问题:我在自己的电脑上运行起来总是报错,希望能给我一个详细的教程,(开发工具-github)
  • ¥40 基于51单片机实现球赛计分器功能
  • ¥15 cs2游戏画面卡住,应用程序sid与指挥者sid不匹配
  • ¥15 实验七:Pandas要有实验截图和代码
  • ¥15 TypeError: Make sure that the iterable only contains strings.