Remove unused code

apache · Dec 30, 2024 · 1961a53 · 1961a53
1 parent 3a901de
commit 1961a53
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/...esting/load-tests/src/main/java/org/apache/beam/sdk/loadtests/SyntheticDataPublisher.java b/...esting/load-tests/src/main/java/org/apache/beam/sdk/loadtests/SyntheticDataPublisher.java
@@ -193,12 +193,6 @@ private static void writeToKinesis(PCollection<KV<byte[], byte[]>> collection) {
             KinesisIO.<byte[]>write()
                 .withStreamName(options.getKinesisStreamName())
                 .withPartitioner(p -> options.getKinesisPartitionKey())
-                // .withPartitionKey(options.getKinesisPartitionKey())
-                // .withAWSClientsProvider(
-                //     options.getKinesisAwsKey(),
-                //     options.getKinesisAwsSecret(),
-                //     Regions.fromName(options.getKinesisAwsRegion())
-                // ));
                 .withClientConfiguration(
                     ClientConfiguration.builder()
                         .credentialsProvider(provider)