This is an automated email from the ASF dual-hosted git repository. jqin pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1b3f2bee1222164f9ff3c4883975c950a3598f59 Author: Stephan Ewen <[email protected]> AuthorDate: Mon Nov 23 18:55:17 2020 +0100 [hotfix][runtime] Minor style warning cleanups in SourceCoordinatorContext --- .../flink/runtime/source/coordinator/SourceCoordinatorContext.java | 5 ++--- .../runtime/source/coordinator/SourceCoordinatorProviderTest.java | 3 +-- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java index 6d7d860..037b643 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java @@ -104,9 +104,9 @@ public class SourceCoordinatorContext<SplitT extends SourceSplit> SourceCoordinatorProvider.CoordinatorExecutorThreadFactory coordinatorThreadFactory, int numWorkerThreads, OperatorCoordinator.Context operatorCoordinatorContext, - SimpleVersionedSerializer<SplitT> splitSerializser) { + SimpleVersionedSerializer<SplitT> splitSerializer) { this(coordinatorExecutor, coordinatorThreadFactory, numWorkerThreads, operatorCoordinatorContext, - splitSerializser, new SplitAssignmentTracker<>()); + splitSerializer, new SplitAssignmentTracker<>()); } // Package private method for unit test. @@ -268,7 +268,6 @@ public class SourceCoordinatorContext<SplitT extends SourceSplit> * @param in the input from which the states are read. * @throws Exception when the restoration failed. */ - @SuppressWarnings("unchecked") void restoreState( SimpleVersionedSerializer<SplitT> splitSerializer, DataInputStream in) throws Exception { diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorProviderTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorProviderTest.java index dbb6a41..eae6d24 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorProviderTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorProviderTest.java @@ -42,10 +42,9 @@ import static org.junit.Assert.assertTrue; /** * Unit tests for {@link SourceCoordinatorProvider}. */ -@SuppressWarnings("serial") public class SourceCoordinatorProviderTest { + private static final OperatorID OPERATOR_ID = new OperatorID(1234L, 5678L); - private static final String OPERATOR_NAME = "SourceCoordinatorProviderTest"; private static final int NUM_SPLITS = 10; private SourceCoordinatorProvider<MockSourceSplit> provider;
