kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: temp fix for ktable look up
Date Thu, 04 Feb 2016 18:16:05 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 99956f56c -> 77683c3cb


HOTFIX: temp fix for ktable look up

guozhangwang
Temporarily disabled state store access checking.

Author: Yasuhiro Matsuda <yasuhiro@confluent.io>

Reviewers: Guozhang Wang

Closes #864 from ymatsuda/fix_table_lookup


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

Branch: refs/heads/trunk
Commit: 77683c3cb0eab8c85eb13d0e1397cf9ee32586b6
Parents: 99956f5
Author: Yasuhiro Matsuda <yasuhiro@confluent.io>
Authored: Thu Feb 4 10:16:01 2016 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu Feb 4 10:16:01 2016 -0800

----------------------------------------------------------------------
 .../kafka/streams/processor/internals/ProcessorContextImpl.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/77683c3c/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
index 7931a6f..4b72394 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
@@ -132,8 +132,9 @@ public class ProcessorContextImpl implements ProcessorContext, RecordCollector.S
         if (node == null)
             throw new TopologyBuilderException("Accessing from an unknown node");
 
-        if (!node.stateStores.contains(name))
-            throw new TopologyBuilderException("Processor " + node.name() + " has no access
to StateStore " + name);
+        // TODO: restore this once we fix the ValueGetter initialiation issue
+        //if (!node.stateStores.contains(name))
+        //    throw new TopologyBuilderException("Processor " + node.name() + " has no access
to StateStore " + name);
 
         return stateMgr.getStore(name);
     }


Mime
View raw message