From 7cebd2b7c1d964aab4f77de7162ad2cdd3c9b863 Mon Sep 17 00:00:00 2001 From: Becket Qin Date: Wed, 17 Jan 2024 17:20:50 -0800 Subject: [PATCH] Fix formating. --- .../flink/translation/types/TypeInformationCoder.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/TypeInformationCoder.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/TypeInformationCoder.java index de80120bfdb3..61b43e9f304c 100644 --- a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/TypeInformationCoder.java +++ b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/TypeInformationCoder.java @@ -7,7 +7,7 @@ * "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 + * 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, @@ -15,7 +15,6 @@ * See the License for the specific language governing permissions and * limitations under the License. */ - package org.apache.beam.runners.flink.translation.types; import java.io.IOException; @@ -31,10 +30,7 @@ import org.apache.flink.core.memory.DataInputViewStreamWrapper; import org.apache.flink.core.memory.DataOutputViewStreamWrapper; - -/** - * Create a Beam {@link Coder} from a Flink {@link TypeInformation}. - */ +/** Create a Beam {@link Coder} from a Flink {@link TypeInformation}. */ public class TypeInformationCoder extends Coder { private final TypeSerializer serializer;