Flink报错Table is not an append-only table. Use the toRetractStream() in order to handle add and retract messages 有更新!

  |   0 评论   |   19 浏览

    报错:

    Table is not an append-only table. Use the toRetractStream() in order to handle add and retract messages
    

    解决方案:
    这个是因为动态表不是append-only模式的,需要用toRetractStream(回撤流)处理就好了.

    tableEnv.toRetractStream[Person](result).print()
    

    评论

    发表评论

    validate