You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2022/11/04 08:13:22 UTC
[flink] 01/02: [hotfix] Add final modifier to taskName
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b0864c81d83ae160b5150a9e7b644c89c7db3bed
Author: 1996fanrui <19...@gmail.com>
AuthorDate: Sat Oct 22 21:42:43 2022 +0800
[hotfix] Add final modifier to taskName
---
.../flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java | 2 +-
.../checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java
index 8b3a9f9c569..c858896c5d5 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java
@@ -73,7 +73,7 @@ class ChannelStateCheckpointWriter {
private boolean allOutputsReceived = false;
private final RunnableWithException onComplete;
private final int subtaskIndex;
- private String taskName;
+ private final String taskName;
ChannelStateCheckpointWriter(
String taskName,
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java
index 474d0f515c2..6ab7b4bec9a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java
@@ -41,7 +41,7 @@ final class ChannelStateWriteRequestDispatcherImpl implements ChannelStateWriteR
private final CheckpointStorageWorkerView streamFactoryResolver;
private final ChannelStateSerializer serializer;
private final int subtaskIndex;
- private String taskName;
+ private final String taskName;
ChannelStateWriteRequestDispatcherImpl(
String taskName,