This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 9a93f74b17e7d45de293946fa1d733e3500653af Author: Tzu-Li (Gordon) Tai <[email protected]> AuthorDate: Wed Nov 11 15:53:35 2020 +0800 [FLINK-20085] [core] Remove statefun.remote.migrate-legacy-state config This closes #172. --- .../statefun/flink/core/StatefulFunctionsConfig.java | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java index a38d9a5..07cd436 100644 --- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java +++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java @@ -100,13 +100,6 @@ public class StatefulFunctionsConfig implements Serializable { .withDescription( "The max number of async operations per task before backpressure is applied."); - public static final ConfigOption<Boolean> MIGRATE_LEGACY_REMOTE_FN_STATE = - ConfigOptions.key("statefun.remote.migrate-legacy-state") - .booleanType() - .defaultValue(false) - .withDescription( - "Indicates whether or not legacy remote function state should be migrated. This should be true only if you are restoring from a savepoint taken with version <= 2.1.x."); - /** * Creates a new {@link StatefulFunctionsConfig} based on the default configurations in the * current environment set via the {@code flink-conf.yaml}. @@ -132,8 +125,6 @@ public class StatefulFunctionsConfig implements Serializable { private int maxAsyncOperationsPerTask; - private boolean migrateLegacyRemoteFunctionState; - private Map<String, String> globalConfigurations = new HashMap<>(); /** @@ -148,7 +139,6 @@ public class StatefulFunctionsConfig implements Serializable { this.flinkJobName = configuration.get(FLINK_JOB_NAME); this.feedbackBufferSize = configuration.get(TOTAL_MEMORY_USED_FOR_FEEDBACK_CHECKPOINTING); this.maxAsyncOperationsPerTask = configuration.get(ASYNC_MAX_OPERATIONS_PER_TASK); - this.migrateLegacyRemoteFunctionState = configuration.get(MIGRATE_LEGACY_REMOTE_FN_STATE); for (String key : configuration.keySet()) { if (key.startsWith(MODULE_CONFIG_PREFIX)) { @@ -216,11 +206,6 @@ public class StatefulFunctionsConfig implements Serializable { this.maxAsyncOperationsPerTask = maxAsyncOperationsPerTask; } - /** Flag indicating whether or not legacy remote function state should be migrated. */ - public boolean shouldMigrateLegacyRemoteFnState() { - return this.migrateLegacyRemoteFunctionState; - } - /** * Retrieves the universe provider for loading modules. *
