240 发简信
IP属地:浙江
  • 你的意思是手动在resources里加入org.apache.flink.table.factories.TableFactory这个文件?我加了后,重新编译成jar包,他还是只有一行。你是怎么做的?求指导

    Flink:注册Table Kafka Sink报错处理

    实现 实现Flink Job:读取阿里云LogService日志,统计事件后将指标写入搭建的Kafka中。JAVA 示例代码如下: 使用了TableAPI处理后,注册了一个K...