You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/02/04 19:16:05 UTC
kafka git commit: HOTFIX: temp fix for ktable look up
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 <ya...@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 <ya...@confluent.io>
Authored: Thu Feb 4 10:16:01 2016 -0800
Committer: Guozhang Wang <wa...@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);
}