Skip to content

Commit 1ddbd61

Browse files
committed
[hotfix] Apply fixes to satisfy Checkstyle 9+
1 parent 023c9c8 commit 1ddbd61

File tree

6 files changed

+9
-6
lines changed

6 files changed

+9
-6
lines changed

flink-core/src/main/java/org/apache/flink/api/common/operators/util/ListKeyGroupedIterator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public ListKeyGroupedIterator(
6464
this.serializer = serializer;
6565
this.comparator = comparator;
6666

67-
this.done = input.isEmpty() ? true : false;
67+
this.done = input.isEmpty();
6868
}
6969

7070
/**

flink-core/src/main/java/org/apache/flink/core/memory/ByteArrayOutputStreamWithPos.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ public void reset() {
8888
count = 0;
8989
}
9090

91-
public byte toByteArray()[] {
91+
public byte[] toByteArray() {
9292
return Arrays.copyOf(buffer, count);
9393
}
9494

flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReader.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
package org.apache.flink.runtime.checkpoint.channel;
21
/*
32
* Licensed to the Apache Software Foundation (ASF) under one or more
43
* contributor license agreements. See the NOTICE file distributed with
@@ -16,6 +15,8 @@
1615
* limitations under the License.
1716
*/
1817

18+
package org.apache.flink.runtime.checkpoint.channel;
19+
1920
import org.apache.flink.annotation.Internal;
2021
import org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter;
2122
import org.apache.flink.runtime.io.network.partition.consumer.InputGate;

flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobPlanHandler.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
package org.apache.flink.runtime.rest.handler.job;
21
/*
32
* Licensed to the Apache Software Foundation (ASF) under one
43
* or more contributor license agreements. See the NOTICE file
@@ -17,6 +16,8 @@
1716
* limitations under the License.
1817
*/
1918

19+
package org.apache.flink.runtime.rest.handler.job;
20+
2021
import org.apache.flink.api.common.time.Time;
2122
import org.apache.flink.runtime.executiongraph.AccessExecutionGraph;
2223
import org.apache.flink.runtime.rest.handler.HandlerRequest;

flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogState.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
package org.apache.flink.state.changelog;
21
/*
32
* Licensed to the Apache Software Foundation (ASF) under one or more
43
* contributor license agreements. See the NOTICE file distributed with
@@ -16,6 +15,8 @@
1615
* limitations under the License.
1716
*/
1817

18+
package org.apache.flink.state.changelog;
19+
1920
import org.apache.flink.annotation.Internal;
2021
import org.apache.flink.state.changelog.restore.ChangelogApplierFactory;
2122
import org.apache.flink.state.changelog.restore.StateChangeApplier;

flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -783,7 +783,7 @@ public ResultFetcher callShowJobsOperation(
783783
* @param handle the specified operation handle
784784
* @param clusterAction the cluster action to run against the retrieved {@link ClusterClient}.
785785
* @param <ClusterID> type of the cluster id
786-
* @param <Result>> type of the result
786+
* @param <Result> type of the result
787787
* @throws SqlExecutionException if something goes wrong
788788
*/
789789
private <ClusterID, Result> Result runClusterAction(

0 commit comments

Comments
 (0)