[flink] 02/02: [hotfix][metrics] Remove unnecessary @Nullable annotation

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit cb3bd047a9681da5d3efb02e0e27f4450758e794
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Fri Mar 12 12:44:40 2021 +0100

    [hotfix][metrics] Remove unnecessary @Nullable annotation
---
 .../apache/flink/runtime/metrics/groups/TaskMetricGroup.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java
index b99cccc..ebdcbd3 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java
@@ -54,9 +54,9 @@ public class TaskMetricGroup extends 
ComponentMetricGroup<TaskManagerJobMetricGr
      */
     private final ExecutionAttemptID executionId;
 
-    @Nullable protected final JobVertexID vertexId;
+    protected final JobVertexID vertexId;
 
-    @Nullable private final String taskName;
+    private final String taskName;
 
     protected final int subtaskIndex;
 
@@ -67,9 +67,9 @@ public class TaskMetricGroup extends 
ComponentMetricGroup<TaskManagerJobMetricGr
     public TaskMetricGroup(
             MetricRegistry registry,
             TaskManagerJobMetricGroup parent,
-            @Nullable JobVertexID vertexId,
+            JobVertexID vertexId,
             ExecutionAttemptID executionId,
-            @Nullable String taskName,
+            String taskName,
             int subtaskIndex,
             int attemptNumber) {
         super(
@@ -86,8 +86,8 @@ public class TaskMetricGroup extends 
ComponentMetricGroup<TaskManagerJobMetricGr
                 parent);
 
         this.executionId = checkNotNull(executionId);
-        this.vertexId = vertexId;
-        this.taskName = taskName;
+        this.vertexId = checkNotNull(vertexId);
+        this.taskName = checkNotNull(taskName);
         this.subtaskIndex = subtaskIndex;
         this.attemptNumber = attemptNumber;