Fix SamzaStoreStateInternalsTest to reflect updated signature

Author: tkaymak

runners/samza/src/test/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternalsTest.java

@@ -75,7 +75,6 @@
 import org.apache.samza.storage.kv.KeyValueStoreMetrics;
 import org.apache.samza.storage.kv.inmemory.InMemoryKeyValueStorageEngineFactory;
 import org.apache.samza.storage.kv.inmemory.InMemoryKeyValueStore;
-import org.apache.samza.system.SystemStreamPartition;
 import org.junit.BeforeClass;
 import org.junit.Rule;
 import org.junit.Test;
@@ -309,11 +308,10 @@ public void processElement(
   public static class TestStorageEngine extends InMemoryKeyValueStorageEngineFactory {
 
     @Override
-    public KeyValueStore<byte[], byte[]> getKVStore(
+    protected KeyValueStore<byte[], byte[]> getKVStore(
         String storeName,
         File storeDir,
         MetricsRegistry registry,
-        SystemStreamPartition changeLogSystemStreamPartition,
         JobContext jobContext,
         ContainerContext containerContext,
         StorageEngineFactory.StoreMode readWrite) {