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:20 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk c74eec96c -> c2653754d


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


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

Branch: refs/heads/trunk
Commit: c2653754d9dbc232ae5f2052993611b26ed62693
Parents: c74eec9
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:17 2017 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/c2653754/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 8260d23..2e3211c 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
@@ -27,8 +27,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;
@@ -48,7 +46,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