[INFO] Submitting SQL update statement to the cluster...
[ERROR] Could not execute SQL statement. Reason:
java.lang.NoSuchMethodError: org.apache.flink.formats.json.JsonRowDataSerializationSchema.(Lorg/apache/flink/table/types/logical/RowType;Lorg/apache/flink/formats/json/TimestampFormat;)V
zhp8341
commented
3 years ago
您好, 我看你基于flink 1.12的例子,都是读kafka 写mysql之类的,有没有读mysql写kafka例子发我一下看看?
我读mysql写kafka报错了,
[INFO] Submitting SQL update statement to the cluster... [ERROR] Could not execute SQL statement. Reason: java.lang.NoSuchMethodError: org.apache.flink.formats.json.JsonRowDataSerializationSchema.(Lorg/apache/flink/table/types/logical/RowType;Lorg/apache/flink/formats/json/TimestampFormat;)V