[13]hudi RocketMQDynamicTableSink had format violations

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.

https://rocketmq.apache.org/

Apache License 2.0

141 stars 89 forks source link

[13]hudi RocketMQDynamicTableSink had format violations #14

Closed yiduwangkai closed 2 years ago

yiduwangkai commented 2 years ago

RocketMQDynamicTableSink has format violations

Tips Thank you very much for contributing to Apache rocketmq-flink. What is the purpose of the pull request *solve RocketMQDynamicTableSink has format violations

Brief change log (for example:)

*Modify RocketMQDynamicTableSink.java Verify this pull request RocketMQDynamicTableSink.java