This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git
commit 92d4cc396e94751a5280c78c6d439fd13b7bf921 Author: Nishadi Kirielle <[email protected]> AuthorDate: Mon Mar 23 13:11:45 2020 +1100 Fix Checkstyle issue (#532) (#533) * Update Checkstyle file * Fix RocketMQSource Checkstyle issue --- .../org/apache/rocketmq/flink/RocketMQSource.java | 2 +- style/rmq_checkstyle.xml | 41 ++++++++++++---------- 2 files changed, 24 insertions(+), 19 deletions(-) diff --git a/src/main/java/org/apache/rocketmq/flink/RocketMQSource.java b/src/main/java/org/apache/rocketmq/flink/RocketMQSource.java index e289b49..b3b37dc 100644 --- a/src/main/java/org/apache/rocketmq/flink/RocketMQSource.java +++ b/src/main/java/org/apache/rocketmq/flink/RocketMQSource.java @@ -331,7 +331,7 @@ public class RocketMQSource<OUT> extends RichParallelSourceFunction<OUT> this.unionOffsetStates = context.getOperatorStateStore().getUnionListState(new ListStateDescriptor<>( OFFSETS_STATE_NAME, TypeInformation.of(new TypeHint<Tuple2<MessageQueue, Long>>() { - }))); + }))); this.restored = context.isRestored(); if (restored) { diff --git a/style/rmq_checkstyle.xml b/style/rmq_checkstyle.xml index d5d591d..15c267e 100644 --- a/style/rmq_checkstyle.xml +++ b/style/rmq_checkstyle.xml @@ -1,19 +1,19 @@ <?xml version="1.0" encoding="UTF-8"?> <!-- - ~ Licensed to the Apache Software Foundation (ASF) under one or more - ~ contributor license agreements. See the NOTICE file distributed with - ~ this work for additional information regarding copyright ownership. - ~ The ASF licenses this file to You under the Apache License, Version 2.0 - ~ (the "License"); you may not use this file except in compliance with - ~ the License. You may obtain a copy of the License at - ~ - ~ http://www.apache.org/licenses/LICENSE-2.0 - ~ - ~ Unless required by applicable law or agreed to in writing, software - ~ distributed under the License is distributed on an "AS IS" BASIS, - ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - ~ See the License for the specific language governing permissions and - ~ limitations under the License. + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. --> <!DOCTYPE module PUBLIC @@ -30,6 +30,12 @@ <!-- header --> <module name="RegexpHeader"> <property name="header" value="/\*\nLicensed to the Apache Software Foundation*"/> + <property name="fileExtensions" value="java"/> + </module> + + <module name="RegexpHeader"> + <property name="header" value="#[\s]*Licensed to the Apache Software Foundation*"/> + <property name="fileExtensions" value="properties"/> </module> <!-- @@ -122,9 +128,8 @@ <!--whitespace--> <module name="GenericWhitespace"/> - <module name="NoWhitespaceBefore"/> - <module name="WhitespaceAfter"/> - <module name="NoWhitespaceAfter"/> + <!--<module name="NoWhitespaceBefore"/>--> + <!--<module name="NoWhitespaceAfter"/>--> <module name="WhitespaceAround"> <property name="allowEmptyConstructors" value="true"/> <property name="allowEmptyMethods" value="true"/> @@ -134,4 +139,4 @@ <module name="ParenPad"/> <module name="TypecastParenPad"/> </module> -</module> +</module> \ No newline at end of file
