NO-SNOW Ignore OAuth test

snowflakedb · Aug 7, 2024 · c393b47 · c393b47
1 parent 4bff462
commit c393b47
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 7 deletions.
diff --git a/src/test/java/com/snowflake/kafka/connector/SnowflakeSinkTaskForStreamingIT.java b/src/test/java/com/snowflake/kafka/connector/SnowflakeSinkTaskForStreamingIT.java
@@ -68,7 +68,9 @@ public void afterEach() {
  }
 
  private static Stream<Arguments> oAuthAndSingleBufferParameters() {
- return TestUtils.nBooleanProduct(2);
+ return Stream.of(Arguments.of(false, false), Arguments.of(false, true));
+ // OAuth tests are temporary disabled
+ // return TestUtils.nBooleanProduct(2);
  }
 
  @ParameterizedTest(name = "useOAuth: {0}, useSingleBuffer: {1}")

diff --git a/src/test/java/com/snowflake/kafka/connector/UtilsTest.java b/src/test/java/com/snowflake/kafka/connector/UtilsTest.java
@@ -6,6 +6,7 @@
 import java.util.HashMap;
 import java.util.Map;
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.contrib.java.lang.system.EnvironmentVariables;
@@ -283,6 +284,8 @@ public void testGetExceptionMessage() throws Exception {
  }
 
  @Test
+ @Ignore
+ // OAuth tests are temporary disabled
  public void testGetSnowflakeOAuthAccessToken() {
  Map<String, String> config = TestUtils.getConfForStreamingWithOAuth();
  if (config != null) {

diff --git a/...va/com/snowflake/kafka/connector/internal/streaming/DirectStreamingClientHandlerTest.java b/...va/com/snowflake/kafka/connector/internal/streaming/DirectStreamingClientHandlerTest.java
@@ -31,13 +31,11 @@
 public class DirectStreamingClientHandlerTest {
  private StreamingClientHandler streamingClientHandler;
  private Map<String, String> connectorConfig;
- private Map<String, String> connectorConfigWithOAuth;
 
  @Before
  public void setup() {
  this.streamingClientHandler = new DirectStreamingClientHandler();
  this.connectorConfig = TestUtils.getConfForStreaming();
- this.connectorConfigWithOAuth = TestUtils.getConfForStreamingWithOAuth();
  }
 
  @Test
@@ -67,9 +65,10 @@ public void testCreateClient() throws Exception {
  @Test
  @Ignore // TODO: Remove ignore after SNOW-859929 is released
  public void testCreateOAuthClient() {
- if (this.connectorConfigWithOAuth != null) {
+ Map<String, String> connectorConfigWithOAuth = TestUtils.getConfForStreamingWithOAuth();
+ if (connectorConfigWithOAuth != null) {
  this.streamingClientHandler.createClient(
- new StreamingClientProperties(this.connectorConfigWithOAuth));
+  new StreamingClientProperties(connectorConfigWithOAuth));
  }
  }
 

diff --git a/src/test/java/com/snowflake/kafka/connector/internal/streaming/SnowflakeSinkServiceV2IT.java b/src/test/java/com/snowflake/kafka/connector/internal/streaming/SnowflakeSinkServiceV2IT.java
@@ -79,7 +79,9 @@ private static Stream<Arguments> singleBufferParameters() {
  }
 
  private static Stream<Arguments> oAuthAndSingleBufferParameters() {
- return TestUtils.nBooleanProduct(2);
+ return Stream.of(Arguments.of(false, false), Arguments.of(false, true));
+ // OAuth tests are temporary disabled
+ // return TestUtils.nBooleanProduct(2);
  }
 
  @ParameterizedTest(name = "useOAuth: {0}, useSingleBuffer: {1}")

diff --git a/src/test/resources/log4j.properties b/src/test/resources/log4j.properties
@@ -1,4 +1,4 @@
-log4j.rootLogger=ALL, STDOUT, file
+log4j.rootLogger=INFO, STDOUT, file
 log4j.logger.deng=INFO
 log4j.appender.STDOUT=org.apache.log4j.ConsoleAppender
 log4j.appender.STDOUT.layout=org.apache.log4j.PatternLayout