From f1d60ec1a6c9eb5af2a0593ab814531fdd730989 Mon Sep 17 00:00:00 2001 From: Justin Pfifer Date: Tue, 12 Jun 2018 14:29:22 -0700 Subject: [PATCH] Remove tests that no longer work (#346) The new version of the SDK no longer returns null on an unknown region. There's not much we can do but run with whatever region is configured --- pom.xml | 2 +- .../worker/KinesisClientLibConfiguration.java | 9 ---- .../KinesisClientLibConfigurationTest.java | 49 ------------------- 3 files changed, 1 insertion(+), 59 deletions(-) diff --git a/pom.xml b/pom.xml index 0224a6b7..a0a237cb 100644 --- a/pom.xml +++ b/pom.xml @@ -25,7 +25,7 @@ - 1.11.319 + 1.11.344 1.0.392 libsqlite4java ${project.build.directory}/test-lib diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java index f7ca6b1d..cc0d6a4b 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java @@ -458,7 +458,6 @@ public class KinesisClientLibConfiguration { checkIsValuePositive("MetricsBufferTimeMills", metricsBufferTimeMillis); checkIsValuePositive("MetricsMaxQueueSize", (long) metricsMaxQueueSize); checkIsValuePositive("ShutdownGraceMillis", shutdownGraceMillis); - checkIsRegionNameValid(regionName); this.applicationName = applicationName; this.tableName = applicationName; this.streamName = streamName; @@ -567,7 +566,6 @@ public class KinesisClientLibConfiguration { checkIsValuePositive("TaskBackoffTimeMillis", taskBackoffTimeMillis); checkIsValuePositive("MetricsBufferTimeMills", metricsBufferTimeMillis); checkIsValuePositive("MetricsMaxQueueSize", (long) metricsMaxQueueSize); - checkIsRegionNameValid(regionName); this.applicationName = applicationName; this.tableName = applicationName; this.streamName = streamName; @@ -630,12 +628,6 @@ public class KinesisClientLibConfiguration { return config; } - private void checkIsRegionNameValid(String regionNameToCheck) { - if (regionNameToCheck != null && RegionUtils.getRegion(regionNameToCheck) == null) { - throw new IllegalArgumentException("The specified region name is not valid"); - } - } - /** * @return Name of the application */ @@ -1214,7 +1206,6 @@ public class KinesisClientLibConfiguration { */ // CHECKSTYLE:IGNORE HiddenFieldCheck FOR NEXT 2 LINES public KinesisClientLibConfiguration withRegionName(String regionName) { - checkIsRegionNameValid(regionName); this.regionName = regionName; return this; } diff --git a/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfigurationTest.java b/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfigurationTest.java index d30c9e57..7184c9a3 100644 --- a/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfigurationTest.java +++ b/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfigurationTest.java @@ -281,56 +281,7 @@ public class KinesisClientLibConfigurationTest { Mockito.verify(kclConfig, Mockito.times(2)).getKinesisEndpoint(); } - @Test - public void testKCLConfigurationWithMultiRegionWithIlligalRegionName() { - // test with illegal region name - AWSCredentialsProvider credentialsProvider = Mockito.mock(AWSCredentialsProvider.class); - KinesisClientLibConfiguration kclConfig = - new KinesisClientLibConfiguration("Test", "Test", credentialsProvider, "0"); - try { - kclConfig = kclConfig.withRegionName("abcd"); - Assert.fail("No expected Exception is thrown."); - } catch (IllegalArgumentException e) { - System.out.println(e.getMessage()); - } - } - - @Test - public void testKCLConfigurationWithMultiRegionWithIlligalRegionNameInFullConstructor() { - // test with illegal region name - Mockito.mock(AWSCredentialsProvider.class); - try { - new KinesisClientLibConfiguration(TEST_STRING, - TEST_STRING, - TEST_STRING, - TEST_STRING, - null, - null, - null, - null, - TEST_VALUE_LONG, - TEST_STRING, - 3, - TEST_VALUE_LONG, - false, - TEST_VALUE_LONG, - TEST_VALUE_LONG, - true, - new ClientConfiguration(), - new ClientConfiguration(), - new ClientConfiguration(), - TEST_VALUE_LONG, - TEST_VALUE_LONG, - 1, - skipCheckpointValidationValue, - "abcd", - TEST_VALUE_LONG); - Assert.fail("No expected Exception is thrown."); - } catch(IllegalArgumentException e) { - System.out.println(e.getMessage()); - } - } @Test public void testKCLConfigurationMetricsDefaults() {