Debug info

apache · Dec 24, 2024 · c8caf0c · c8caf0c
1 parent 30fd605
commit c8caf0c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java b/...-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientBuilderFactory.java
@@ -165,6 +165,7 @@ public <BuilderT extends AwsClientBuilder<BuilderT, ClientT>, ClientT> BuilderT
       boolean skipCertificateVerification = false;
       if (config.skipCertificateVerification() != null) {
         skipCertificateVerification = config.skipCertificateVerification();
+        throw new RuntimeException("config was non-null " + skipCertificateVerification);
       }
       if (proxyConfig != null || httpConfig != null || skipCertificateVerification) {
         if (builder instanceof SdkSyncClientBuilder) {

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,6 +120,9 @@ public PTransform<PCollection<byte[]>, KinesisIO.Write.Result> buildExternal(
                   "Service endpoint must be URI format, got: %s", configuration.serviceEndpoint));
         }
       }
+      if (configuration.verifyCertificate) {
+        throw new RuntimeException("This is the problem");
+      }
       KinesisIO.Write<byte[]> writeTransform =
           KinesisIO.<byte[]>write()
               .withStreamName(configuration.streamName)