Allow configuration to be serialized

apache · Dec 20, 2024 · 1b79da4 · 1b79da4
1 parent d278434
commit 1b79da4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ervices2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisTransformRegistrar.java b/...ervices2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisTransformRegistrar.java
@@ -120,7 +120,7 @@ public PTransform<PCollection<byte[]>, KinesisIO.Write.Result> buildExternal(
               .withClientConfiguration(
                   ClientConfiguration.builder()
                       .credentialsProvider(provider)
-                      .region(Regions.fromName(configuration.region))
+                      .region(Region.of(configuration.region))
                       .endpoint(endpoint)
                       .build())
               .withPartitioner(p -> configuration.partitionKey)
@@ -230,7 +230,7 @@ public PTransform<PBegin, PCollection<byte[]>> buildExternal(
               .withClientConfiguration(
                   ClientConfiguration.builder()
                       .credentialsProvider(provider)
-                      .region(Regions.fromName(configuration.region))
+                      .region(Region.of(configuration.region))
                       .endpoint(endpoint)
                       .build());