From 38c8d4f92d00bb85c98ee683143e6c13cc2e5c49 Mon Sep 17 00:00:00 2001
From: Cody Rioux <crioux@stripe.com>
Date: Mon, 7 Oct 2024 17:04:21 -0700
Subject: [PATCH] Call correct peer constructor in KeyValueStageConfig instead
 of super

---
 .../src/main/java/io/mantisrx/runtime/KeyValueStageConfig.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/mantis-runtime/src/main/java/io/mantisrx/runtime/KeyValueStageConfig.java b/mantis-runtime/src/main/java/io/mantisrx/runtime/KeyValueStageConfig.java
index 756639400..4e0cd6907 100644
--- a/mantis-runtime/src/main/java/io/mantisrx/runtime/KeyValueStageConfig.java
+++ b/mantis-runtime/src/main/java/io/mantisrx/runtime/KeyValueStageConfig.java
@@ -33,8 +33,7 @@ public abstract class KeyValueStageConfig<T, K, R> extends StageConfig<T, R> {
     private final Codec<K> keyCodec;
 
     public KeyValueStageConfig(String description, Codec<?> inputKeyCodec, Codec<T> inputCodec, Codec<K> outputKeyCodec, Codec<R> outputCodec, INPUT_STRATEGY inputStrategy, List<ParameterDefinition<?>> params) {
-        super(description, inputKeyCodec, inputCodec, outputCodec, inputStrategy, params, DEFAULT_STAGE_CONCURRENCY);
-        this.keyCodec = outputKeyCodec;
+        this(description, inputKeyCodec, inputCodec, outputKeyCodec, outputCodec, inputStrategy, params, DEFAULT_STAGE_CONCURRENCY);
     }
 
     public KeyValueStageConfig(String description, Codec<?> inputKeyCodec, Codec<T> inputCodec, Codec<K> outputKeyCodec, Codec<R> outputCodec, INPUT_STRATEGY inputStrategy, List<ParameterDefinition<?>> params, int concurrency) {