kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: remove unused log field from KStreamTransformValuesProcessor
Date Tue, 21 Mar 2017 23:17:35 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 3d294533c -> 6e2698b25


MINOR: remove unused log field from KStreamTransformValuesProcessor

remove unused log field from KStreamTransformValuesProcessor

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #2717 from dguy/remove-unused-log-para

(cherry picked from commit c2653754d9dbc232ae5f2052993611b26ed62693)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6e2698b2
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6e2698b2
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6e2698b2

Branch: refs/heads/0.10.2
Commit: 6e2698b25587b71dcec6d42d82516fc986a3ebd4
Parents: 3d29453
Author: Damian Guy <damian.guy@gmail.com>
Authored: Tue Mar 21 16:17:17 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Mar 21 16:17:32 2017 -0700

----------------------------------------------------------------------
 .../kafka/streams/kstream/internals/KStreamTransformValues.java   | 3 ---
 1 file changed, 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/6e2698b2/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java
index f689c95..acc013f 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java
@@ -28,8 +28,6 @@ import org.apache.kafka.streams.processor.ProcessorSupplier;
 import org.apache.kafka.streams.processor.StateRestoreCallback;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TaskId;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.io.File;
 import java.util.Map;
@@ -49,7 +47,6 @@ public class KStreamTransformValues<K, V, R> implements ProcessorSupplier<K,
V>
 
     public static class KStreamTransformValuesProcessor<K, V, R> implements Processor<K,
V> {
 
-        private static final Logger log = LoggerFactory.getLogger(KStreamTransformValuesProcessor.class);
         private final ValueTransformer<V, R> valueTransformer;
         private ProcessorContext context;
 


Mime
View raw message