You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/11/23 20:51:20 UTC
[flink] 03/04: [hotfix][runtime] Minor style warning cleanups in
SourceCoordinatorContext
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5645b69c188d044f1aed5ea2d34596778957f872
Author: Stephan Ewen <se...@apache.org>
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;