[hotfix] Refactor callers that use deprecated get/setXXX of Configura…

…tion
apache · Sep 14, 2024 · d9bb2cf · d9bb2cf
1 parent b37a8b3
commit d9bb2cf
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java b/...pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java
@@ -61,9 +61,9 @@ public SinkConfiguration(Configuration configuration) {
         super(configuration);
 
         this.deliveryGuarantee = get(PULSAR_WRITE_DELIVERY_GUARANTEE);
-        this.transactionTimeoutMillis = getLong(PULSAR_WRITE_TRANSACTION_TIMEOUT);
-        this.topicMetadataRefreshInterval = getLong(PULSAR_TOPIC_METADATA_REFRESH_INTERVAL);
-        this.partitionSwitchSize = getInteger(PULSAR_BATCHING_MAX_MESSAGES);
+        this.transactionTimeoutMillis = get(PULSAR_WRITE_TRANSACTION_TIMEOUT);
+        this.topicMetadataRefreshInterval = get(PULSAR_TOPIC_METADATA_REFRESH_INTERVAL);
+        this.partitionSwitchSize = get(PULSAR_BATCHING_MAX_MESSAGES);
         this.messageKeyHash = get(PULSAR_MESSAGE_KEY_HASH);
         this.enableSchemaEvolution = get(PULSAR_WRITE_SCHEMA_EVOLUTION);
         this.maxRecommitTimes = get(PULSAR_MAX_RECOMMIT_TIMES);

diff --git a/...ar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java b/...ar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java
@@ -72,7 +72,7 @@ public class SourceConfiguration extends PulsarConfiguration {
     public SourceConfiguration(Configuration configuration) {
         super(configuration);
 
-        this.messageQueueCapacity = getInteger(ELEMENT_QUEUE_CAPACITY);
+        this.messageQueueCapacity = get(ELEMENT_QUEUE_CAPACITY);
         this.partitionDiscoveryIntervalMs = get(PULSAR_PARTITION_DISCOVERY_INTERVAL_MS);
         this.enableAutoAcknowledgeMessage = get(PULSAR_ENABLE_AUTO_ACKNOWLEDGE_MESSAGE);
         this.autoCommitCursorInterval = get(PULSAR_AUTO_COMMIT_CURSOR_INTERVAL);