kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch 2.6 updated: HOTFIX: checkstyle error in ProcessorStateManager (#8874)
Date Mon, 15 Jun 2020 19:22:50 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.6 by this push:
     new b4c2861  HOTFIX: checkstyle error in ProcessorStateManager (#8874)
b4c2861 is described below

commit b4c2861dc89b64585ed967e5c1f644da8f1567ab
Author: Chia-Ping Tsai <chia7712@gmail.com>
AuthorDate: Tue Jun 16 03:21:36 2020 +0800

    HOTFIX: checkstyle error in ProcessorStateManager (#8874)
    
    Reviewers: Guozhang Wang <wangguoz@gmail.com>
---
 .../apache/kafka/streams/processor/internals/ProcessorStateManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
index 8d80901..fefbfbc 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
@@ -510,7 +510,7 @@ public class ProcessorStateManager implements StateManager {
             throw new IllegalStateException("Tried to recycle state for task type conversion
but new type was the same.");
         }
 
-        TaskType oldType = taskType;
+        final TaskType oldType = taskType;
         taskType = newType;
         log = logContext.logger(ProcessorStateManager.class);
         logPrefix = logContext.logPrefix();


Mime
View raw message