NO-SNOW Ignore OAuth test (snowflakedb#906)

(cherry picked from commit 30d2e8b)

src/test/java/com/snowflake/kafka/connector/ConnectorIT.java

@@ -11,6 +11,7 @@
 import java.util.concurrent.Executors;
 import org.apache.kafka.common.config.Config;
 import org.apache.kafka.common.config.ConfigValue;
+import org.junit.Ignore;
 import org.junit.Test;
 
 public class ConnectorIT {
@@ -139,6 +140,7 @@ public void testValidateCorrectConfig() {
  }
 
  @Test
+ @Ignore("OAuth tests are temporary disabled")
  public void testValidateCorrectConfigWithOAuth() {
  Map<String, ConfigValue> validateMap = toValidateMap(getCorrectConfigWithOAuth());
  assertPropHasError(validateMap, new String[] {});
@@ -209,6 +211,7 @@ public void testValidateNullPasswordConfig() {
  }
 
  @Test
+ @Ignore("OAuth tests are temporary disabled")
  public void testValidateNullOAuthClientIdConfig() {
  Map<String, String> config = getCorrectConfigWithOAuth();
  config.remove(SnowflakeSinkConnectorConfig.OAUTH_CLIENT_ID);
@@ -217,6 +220,7 @@ public void testValidateNullOAuthClientIdConfig() {
  }
 
  @Test
+ @Ignore("OAuth tests are temporary disabled")
  public void testValidateNullOAuthClientSecretConfig() {
  Map<String, String> config = getCorrectConfigWithOAuth();
  config.remove(SnowflakeSinkConnectorConfig.OAUTH_CLIENT_SECRET);
@@ -226,6 +230,7 @@ public void testValidateNullOAuthClientSecretConfig() {
  }
 
  @Test
+ @Ignore("OAuth tests are temporary disabled")
  public void testValidateNullOAuthRefreshTokenConfig() {
  Map<String, String> config = getCorrectConfigWithOAuth();
  config.remove(SnowflakeSinkConnectorConfig.OAUTH_REFRESH_TOKEN);

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}")

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,7 @@ public void testGetExceptionMessage() throws Exception {
  }
 
  @Test
+ @Ignore("OAuth tests are temporary disabled")
  public void testGetSnowflakeOAuthAccessToken() {
  Map<String, String> config = TestUtils.getConfForStreamingWithOAuth();
  if (config != null) {

src/test/java/com/snowflake/kafka/connector/internal/ConnectionServiceIT.java

@@ -34,6 +34,7 @@
 import org.apache.kafka.connect.sink.SinkRecord;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
@@ -56,6 +57,7 @@ public void testEncryptedKey() {
  }
 
  @Test
+ @Disabled("OAuth tests are temporary disabled")
  public void testOAuthAZ() {
  Map<String, String> confWithOAuth = TestUtils.getConfWithOAuth();
  assert confWithOAuth.containsKey(Utils.SF_OAUTH_CLIENT_ID);

src/test/java/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));
  }
  }
 

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}")

src/test/java/com/snowflake/kafka/connector/internal/streaming/StreamingClientProviderIT.java

@@ -22,13 +22,15 @@
 import java.util.Map;
 import net.snowflake.ingest.streaming.SnowflakeStreamingIngestClient;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 
 public class StreamingClientProviderIT {
 
  @Test
+ @Disabled("CI flaky")
  public void getClient_forOptimizationEnabled_returnSameClient() {
  // given
  Map<String, String> clientConfig = getClientConfig(true);

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