Skip to content

Commit

Permalink
TROUBLE_SHOOT_LOGSTORE_E2E
Browse files Browse the repository at this point in the history
  • Loading branch information
yuzelin committed Nov 13, 2023
1 parent 194bb75 commit d344ee9
Show file tree
Hide file tree
Showing 12 changed files with 23 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@

package org.apache.paimon.tests;

import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;

import java.util.ArrayList;
Expand All @@ -27,6 +28,7 @@
import java.util.UUID;

/** Tests for reading and writing file store in batch jobs. */
@Disabled
public class FileStoreBatchE2eTest extends E2eTestBase {

@Test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,11 +18,13 @@

package org.apache.paimon.tests;

import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;

import java.util.UUID;

/** Test that file store supports format included in paimon-format. */
@Disabled
public class FileStoreBuiltInFormatE2eTest extends E2eTestBase {

@Test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
package org.apache.paimon.tests;

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Expand All @@ -27,6 +28,7 @@
import java.util.UUID;

/** Tests for {@code FlinkActions}. */
@Disabled
public class FlinkActionsE2eTest extends E2eTestBase {

private static final Logger LOG = LoggerFactory.getLogger(FlinkActionsE2eTest.class);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,13 +18,15 @@

package org.apache.paimon.tests;

import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledIf;

import java.util.UUID;

/** Tests for flink {@code Procedure}s. */
@EnabledIf("runTest")
@Disabled
public class FlinkProceduresE2eTest extends E2eTestBase {

private static boolean runTest() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
package org.apache.paimon.tests;

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
import org.slf4j.Logger;
Expand All @@ -37,6 +38,7 @@
* you're running this test locally, make sure that the memory limit of your Docker is at least 8GB.
*/
@DisabledIfSystemProperty(named = "test.flink.version", matches = "1.14.*")
@Disabled
public class HiveE2eTest extends E2eReaderTestBase {

private static final Logger LOG = LoggerFactory.getLogger(HiveE2eTest.class);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@

package org.apache.paimon.tests;

import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
import org.slf4j.Logger;
Expand All @@ -30,6 +31,7 @@
import java.util.stream.Collectors;

/** Tests for reading paimon from Spark3. */
@Disabled
@DisabledIfSystemProperty(named = "test.flink.version", matches = "1.14.*")
public class SparkE2eTest extends E2eReaderTestBase {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,12 +18,14 @@

package org.apache.paimon.tests;

import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;

import java.util.Arrays;
import java.util.UUID;

/** Test for currently supported data types. */
@Disabled
public class TypeE2eTest extends E2eTestBase {

@Test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,10 +20,13 @@

import org.apache.paimon.flink.action.cdc.mysql.MySqlVersion;

import org.junit.jupiter.api.Disabled;

/**
* E2e tests for {@link org.apache.paimon.flink.action.cdc.mysql.MySqlSyncTableAction} with MySQL
* 5.7.
*/
@Disabled
public class MySql57E2eTest extends MySqlCdcE2eTestBase {

public MySql57E2eTest() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,10 +20,13 @@

import org.apache.paimon.flink.action.cdc.mysql.MySqlVersion;

import org.junit.jupiter.api.Disabled;

/**
* E2e tests for {@link org.apache.paimon.flink.action.cdc.mysql.MySqlSyncTableAction} with MySQL
* 8.0.
*/
@Disabled
public class MySql80E2eTest extends MySqlCdcE2eTestBase {

public MySql80E2eTest() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@
import java.sql.Statement;

/** E2e test for MySql CDC with computed column. */
@Disabled
public class MySqlComputedColumnE2ETest extends MySqlCdcE2eTestBase {

protected MySqlComputedColumnE2ETest() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@
import java.sql.Statement;

/** E2e test for MySql CDC type convert tinyint(1) to tinyint. */
@Disabled
public class MySqlTinyIntConvertE2ETest extends MySqlCdcE2eTestBase {

protected MySqlTinyIntConvertE2ETest() {
Expand Down
2 changes: 1 addition & 1 deletion paimon-e2e-tests/src/test/resources/log4j2-test.properties
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@

# Set root logger level to OFF to not flood build logs
# set manually to INFO for debugging purposes
rootLogger.level = OFF
rootLogger.level = INFO
rootLogger.appenderRef.test.ref = TestLogger

appender.testlogger.name = TestLogger
Expand Down

0 comments on commit d344ee9

Please sign in to comment.