Repository: beam Updated Branches: refs/heads/master dc672f420 -> 21a2b96a1
[BEAM-1950] Add missing 'static' keyword to MicrobatchSource#initReaderCache Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdabd41a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fdabd41a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fdabd41a Branch: refs/heads/master Commit: fdabd41ae7bf0faaae979a12bb50720ae2ed24ce Parents: dc672f4 Author: Aviem Zur <aviem...@gmail.com> Authored: Wed Apr 12 20:41:11 2017 +0300 Committer: Aviem Zur <aviem...@gmail.com> Committed: Thu Apr 13 07:36:20 2017 +0300 ---------------------------------------------------------------------- .../java/org/apache/beam/runners/spark/io/MicrobatchSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/fdabd41a/runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java ---------------------------------------------------------------------- diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java index 002eb34..847de19 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java @@ -141,7 +141,7 @@ public class MicrobatchSource<T, CheckpointMarkT extends UnboundedSource.Checkpo } } - private synchronized void initReaderCache(long readerCacheInterval) { + private static synchronized void initReaderCache(long readerCacheInterval) { if (readerCache == null) { LOG.info("Creating reader cache. Cache interval = " + readerCacheInterval + " ms."); readerCache =
