Skip to content
代码片段 群组 项目
未验证 提交 cad3dc01 编辑于 作者: Robert Bradshaw's avatar Robert Bradshaw 提交者: GitHub
浏览文件

Merge pull request #34150 Don't attempt to cache the bulk multimap lookup call.

This fixes a cache pollution bug.
No related branches found
No related tags found
无相关合并请求
......@@ -115,7 +115,9 @@ public class MultimapSideInput<K, V> implements MultimapView<K, V> {
try {
Iterator<KV<K, Iterable<V>>> entries =
StateFetchingIterators.readAllAndDecodeStartingFrom(
Caches.subCache(cache, "ValuesForKey", encodedKey),
// TOOD(https://github.com/apache/beam/issues/34149):
// Use the shared cache.
Caches.noop(),
beamFnStateClient,
bulkReadRequest,
KvCoder.of(keyCoder, IterableCoder.of(valueCoder)))
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册