You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/07/17 11:16:04 UTC
[2/2] flink git commit: [FLINK-9692] [kinesis] Harmonize style of
config variable names
[FLINK-9692] [kinesis] Harmonize style of config variable names
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c3d3ff37
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c3d3ff37
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c3d3ff37
Branch: refs/heads/release-1.6
Commit: c3d3ff37de47e9302ba2a7397bef7933fab82f81
Parents: 8005a2e
Author: Stephan Ewen <se...@apache.org>
Authored: Tue Jul 17 10:16:50 2018 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Jul 17 10:16:50 2018 +0200
----------------------------------------------------------------------
.../connectors/kinesis/config/ConsumerConfigConstants.java | 2 +-
.../streaming/connectors/kinesis/internals/ShardConsumerTest.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/c3d3ff37/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
index bcbc284..48a0b3c 100644
--- a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
+++ b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
@@ -135,7 +135,7 @@ public class ConsumerConfigConstants extends AWSConfigConstants {
public static final String SHARD_DISCOVERY_INTERVAL_MILLIS = "flink.shard.discovery.intervalmillis";
/** The config to turn on adaptive reads from a shard. */
- public static final String SHARD_USE_ADAPTIVE_READS = "flink.shard.adaptive.read.records.enabled";
+ public static final String SHARD_USE_ADAPTIVE_READS = "flink.shard.adaptivereads";
// ------------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/c3d3ff37/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumerTest.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumerTest.java b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumerTest.java
index c2924e2..dbc7118 100644
--- a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumerTest.java
+++ b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumerTest.java
@@ -171,7 +171,7 @@ public class ShardConsumerTest {
@Test
public void testCorrectNumOfCollectedRecordsAndUpdatedStateWithAdaptiveReads() {
Properties consumerProperties = new Properties();
- consumerProperties.put("flink.shard.adaptive.read.records.enabled", "true");
+ consumerProperties.put("flink.shard.adaptivereads", "true");
StreamShardHandle fakeToBeConsumedShard = getMockStreamShard("fakeStream", 0);