Ted Yu created BEAM-1950: ---------------------------- Summary: Access to static field shouldn't be protected by lock on non-static MicrobatchSource.this Key: BEAM-1950 URL: https://issues.apache.org/jira/browse/BEAM-1950 Project: Beam Issue Type: Bug Components: runner-spark Reporter: Ted Yu Assignee: Amit Sela Priority: Minor
In MicrobatchSource : {code} private synchronized void initReaderCache(long readerCacheInterval) { if (readerCache == null) { LOG.info("Creating reader cache. Cache interval = " + readerCacheInterval + " ms."); readerCache = CacheBuilder.newBuilder() {code} readerCache is static. Access to readerCache shouldn't be protected by lock on non-static MicrobatchSource.this -- This message was sent by Atlassian JIRA (v6.3.15#6346)