search

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

RocketMQDynamicTableSink format violations #13

Closed yiduwangkai closed 1 year ago

yiduwangkai commented 2 years ago

The following files had format violations: [ERROR] src/main/java/org/apache/rocketmq/flink/sink/table/RocketMQDynamicTableSink.java [ERROR] @@ -199,7 +199,8 @@ [ERROR] ········return·producerProps; [ERROR] ····} [ERROR] [ERROR] -····protected·static·RowTypeInfo·convertToRowTypeInfo(DataType·fieldsDataType,·String[]·fieldNames)·{ [ERROR] +····protected·static·RowTypeInfo·convertToRowTypeInfo( [ERROR] +············DataType·fieldsDataType,·String[]·fieldNames)·{ [ERROR] ········final·TypeInformation<?>[]·fieldTypes·= [ERROR] ················fieldsDataType.getChildren().stream() [ERROR] ························.map(LegacyTypeInfoDataTypeConverter::toLegacyTypeInfo) [ERROR] Run 'mvn spotless:apply' to fix these violations.