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 <[email protected]> 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 <[email protected]> Authored: Thu Feb 4 10:16:01 2016 -0800 Committer: Guozhang Wang <[email protected]> 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); }
