时来时去时不返
2021-08-18 11:07
采纳率: 100%
浏览 54

关于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

    已采纳该答案
    1 打赏 评论
  • 时来时去时不返 2021-08-18 15:54

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

    打赏 评论

相关推荐 更多相似问题