From b5f68d6b5a8f898382920174c3571aeb13edc012 Mon Sep 17 00:00:00 2001 From: Jhora Zakaryan Date: Mon, 9 Aug 2021 11:46:28 -0700 Subject: [PATCH] Fixed issue with config key --- .../assignment/LoadBasedPartitionAssignmentStrategyConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategyConfig.java b/datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategyConfig.java index 71c860f85..3622e3a38 100644 --- a/datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategyConfig.java +++ b/datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategyConfig.java @@ -22,7 +22,7 @@ public class LoadBasedPartitionAssignmentStrategyConfig extends PartitionAssignm public static final String CFG_THROUGHPUT_INFO_FETCH_RETRY_PERIOD_MS = "throughputInfoFetchRetryPeriodMs"; public static final String CFG_TASK_CAPACITY_MBPS = "taskCapacityMBps"; public static final String CFG_TASK_CAPACITY_UTILIZATION_PCT = "taskCapacityUtilizationPct"; - public static final String CFG_ENABLE_THROUGHPUT_BASED_PARTITION_ASSIGNMENT = "enableThroughputBasedPartitionAssignemnt"; + public static final String CFG_ENABLE_THROUGHPUT_BASED_PARTITION_ASSIGNMENT = "enableThroughputBasedPartitionAssignment"; public static final String CFG_ENABLE_PARTITION_NUM_BASED_TASK_COUNT_ESTIMATION = "enablePartitionNumBasedTaskCountEstimation"; private static final int DEFAULT_THROUGHPUT_INFO_FETCH_TIMEOUT_MS = (int) Duration.ofSeconds(10).toMillis();