diff --git a/hydra-filters/src/main/java/com/addthis/hydra/data/filter/value/ValueFilterRandom.java b/hydra-filters/src/main/java/com/addthis/hydra/data/filter/value/ValueFilterRandom.java
index e1dba4350..58944def1 100644
--- a/hydra-filters/src/main/java/com/addthis/hydra/data/filter/value/ValueFilterRandom.java
+++ b/hydra-filters/src/main/java/com/addthis/hydra/data/filter/value/ValueFilterRandom.java
@@ -39,6 +39,7 @@
  */
 public class ValueFilterRandom extends AbstractValueFilter {
 
+    private static final Object lock = new Object();
     private final Random random = new Random();
 
     /**
@@ -91,7 +92,7 @@ public class ValueFilterRandom extends AbstractValueFilter {
     @Override
     public ValueObject filterValue(ValueObject value) {
         if (gaussian) {
-            synchronized (nextGaussian) {
+            synchronized (lock) {
                 return ValueFactory.create(nextGaussian(mu, sigma));
             }
         }
diff --git a/hydra-task/src/main/java/com/addthis/hydra/task/source/FactoryInputStream.java b/hydra-task/src/main/java/com/addthis/hydra/task/source/FactoryInputStream.java
index 2d83d99eb..b0faa6a81 100644
--- a/hydra-task/src/main/java/com/addthis/hydra/task/source/FactoryInputStream.java
+++ b/hydra-task/src/main/java/com/addthis/hydra/task/source/FactoryInputStream.java
@@ -84,12 +84,13 @@ public InputStream createInputStream() throws IOException {
      */
     public static final class InjectorStreamSource extends FactoryInputStream {
 
+        private static final Object lock = new Object();
         public static final String DefautlInjectorKey = "secretDefaultInjectorKey";
         private static final IdentityHashMap<String, LinkedBlockingQueue<InputStream>> park = new IdentityHashMap<>();
 
         public static final void inject(String key, InputStream in) {
             key = key.intern();
-            synchronized (key) {
+            synchronized (lock) {
                 try {
                     LinkedBlockingQueue<InputStream> queue = null;
                     synchronized (park) {
@@ -120,7 +121,7 @@ public InputStream createInputStream() throws IOException {
             try {
                 while (queue == null) {
                     key = key.intern();
-                    synchronized (key) {
+                    synchronized (lock) {
                         synchronized (park) {
                             queue = park.get(key);
                         }