This is an automated email from the ASF dual-hosted git repository.
tison pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 2bab5adc1a1 [FLINK-29580][Connector/Pulsar] Remove
pulsar.consumer.autoUpdatePartitionsIntervalSeconds option. (#21070)
2bab5adc1a1 is described below
commit 2bab5adc1a1d36d35ed971a007db9e311dc0363b
Author: Yufan Sheng <[email protected]>
AuthorDate: Tue Oct 18 13:27:38 2022 +0800
[FLINK-29580][Connector/Pulsar] Remove
pulsar.consumer.autoUpdatePartitionsIntervalSeconds option. (#21070)
---
.../shortcodes/generated/pulsar_consumer_configuration.html | 6 ------
.../apache/flink/connector/pulsar/source/PulsarSourceOptions.java | 7 -------
.../connector/pulsar/source/config/PulsarSourceConfigUtils.java | 5 -----
3 files changed, 18 deletions(-)
diff --git
a/docs/layouts/shortcodes/generated/pulsar_consumer_configuration.html
b/docs/layouts/shortcodes/generated/pulsar_consumer_configuration.html
index e206ff4f20f..41f0b24b329 100644
--- a/docs/layouts/shortcodes/generated/pulsar_consumer_configuration.html
+++ b/docs/layouts/shortcodes/generated/pulsar_consumer_configuration.html
@@ -32,12 +32,6 @@
<td>Boolean</td>
<td>Buffering a large number of outstanding uncompleted chunked
messages can bring memory pressure and it can be guarded by providing this
<code class="highlighter-rouge">pulsar.consumer.maxPendingChunkedMessage</code>
threshold. Once a consumer reaches this threshold, it drops the outstanding
unchunked-messages by silently acknowledging if <code
class="highlighter-rouge">pulsar.consumer.autoAckOldestChunkedMessageOnQueueFull</code>
is true. Otherwise, it marks them for redel [...]
</tr>
- <tr>
-
<td><h5>pulsar.consumer.autoUpdatePartitionsIntervalSeconds</h5></td>
- <td style="word-wrap: break-word;">60</td>
- <td>Integer</td>
- <td>The interval (in seconds) of updating partitions. This only
works if autoUpdatePartitions is enabled.</td>
- </tr>
<tr>
<td><h5>pulsar.consumer.consumerName</h5></td>
<td style="word-wrap: break-word;">(none)</td>
diff --git
a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java
b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java
index 440e96b4f71..d0ef6dea11a 100644
---
a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java
+++
b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java
@@ -584,13 +584,6 @@ public final class PulsarSourceOptions {
.defaultValue(false)
.withDescription("If enabled, the consumer will
automatically retry messages.");
- public static final ConfigOption<Integer>
PULSAR_AUTO_UPDATE_PARTITIONS_INTERVAL_SECONDS =
- ConfigOptions.key(CONSUMER_CONFIG_PREFIX +
"autoUpdatePartitionsIntervalSeconds")
- .intType()
- .defaultValue(60)
- .withDescription(
- "The interval (in seconds) of updating partitions.
This only works if autoUpdatePartitions is enabled.");
-
public static final ConfigOption<Boolean>
PULSAR_REPLICATE_SUBSCRIPTION_STATE =
ConfigOptions.key(CONSUMER_CONFIG_PREFIX +
"replicateSubscriptionState")
.booleanType()
diff --git
a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java
b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java
index 063d588decc..d76ba0a92cc 100644
---
a/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java
+++
b/flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java
@@ -35,7 +35,6 @@ import java.util.concurrent.TimeUnit;
import static java.util.concurrent.TimeUnit.MICROSECONDS;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
-import static java.util.concurrent.TimeUnit.SECONDS;
import static
org.apache.flink.connector.pulsar.common.config.PulsarOptions.PULSAR_ADMIN_URL;
import static
org.apache.flink.connector.pulsar.common.config.PulsarOptions.PULSAR_AUTH_PARAMS;
import static
org.apache.flink.connector.pulsar.common.config.PulsarOptions.PULSAR_AUTH_PARAM_MAP;
@@ -44,7 +43,6 @@ import static
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSA
import static
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_ACK_RECEIPT_ENABLED;
import static
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_ACK_TIMEOUT_MILLIS;
import static
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_AUTO_ACK_OLDEST_CHUNKED_MESSAGE_ON_QUEUE_FULL;
-import static
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_AUTO_UPDATE_PARTITIONS_INTERVAL_SECONDS;
import static
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_CONSUMER_NAME;
import static
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_CONSUMER_PROPERTIES;
import static
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_CRYPTO_FAILURE_ACTION;
@@ -121,9 +119,6 @@ public final class PulsarSourceConfigUtils {
configuration.useOption(PULSAR_READ_COMPACTED, builder::readCompacted);
configuration.useOption(PULSAR_PRIORITY_LEVEL, builder::priorityLevel);
createDeadLetterPolicy(configuration).ifPresent(builder::deadLetterPolicy);
- configuration.useOption(
- PULSAR_AUTO_UPDATE_PARTITIONS_INTERVAL_SECONDS,
- v -> builder.autoUpdatePartitionsInterval(v, SECONDS));
configuration.useOption(PULSAR_RETRY_ENABLE, builder::enableRetry);
configuration.useOption(
PULSAR_MAX_PENDING_CHUNKED_MESSAGE,
builder::maxPendingChunkedMessage);
