Skip to content

Commit 7e78d9c

Browse files
committed
[INLONG-9866][Sort] try fixed bug.
1 parent eaa1c85 commit 7e78d9c

File tree

3 files changed

+4
-2
lines changed

3 files changed

+4
-2
lines changed

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Postgres2StarRocksTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@
5151
*/
5252
public class Postgres2StarRocksTest extends FlinkContainerTestEnv {
5353

54+
private static final Logger PG_LOG = LoggerFactory.getLogger(PostgreSQLContainer.class);
5455
private static final Logger LOG = LoggerFactory.getLogger(Postgres2StarRocksTest.class);
5556
private static final Path postgresJar = TestUtils.getResource("sort-connector-postgres-cdc.jar");
5657
private static final Path jdbcJar = TestUtils.getResource("sort-connector-starrocks.jar");
@@ -73,7 +74,7 @@ public class Postgres2StarRocksTest extends FlinkContainerTestEnv {
7374
.withDatabaseName("test")
7475
.withNetwork(NETWORK)
7576
.withNetworkAliases("postgres")
76-
.withLogConsumer(new Slf4jLogConsumer(LOG));
77+
.withLogConsumer(new Slf4jLogConsumer(PG_LOG));
7778
@ClassRule
7879
public static final StarRocksContainer STAR_ROCKS =
7980
(StarRocksContainer) new StarRocksContainer(getNewStarRocksImageName())

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/utils/StarRocksManager.java

+1
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,7 @@ public static void initializeStarRocksTable(StarRocksContainer STAR_ROCKS) {
6666
DriverManager.getConnection(STAR_ROCKS.getJdbcUrl(), STAR_ROCKS.getUsername(),
6767
STAR_ROCKS.getPassword());
6868
Statement stat = conn.createStatement()) {
69+
System.out.println("-------------------"+STAR_ROCKS.getJdbcUrl()+"-------"+STAR_ROCKS.getUsername()+"--------"+STAR_ROCKS.getPassword());
6970
stat.execute("CREATE TABLE IF NOT EXISTS test_output1 (\n"
7071
+ " id INT NOT NULL,\n"
7172
+ " name VARCHAR(255) NOT NULL DEFAULT 'flink',\n"

inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/resources/log4j2-test.properties

+1-1
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ logger.tm.name=org.apache.flink.runtime.taskexecutor.TaskExecutor
6868
logger.tm.additivity=false
6969

7070
logger.starrocks=INFO, starrocks
71-
logger.starrocks.name=org.apache.inlong.sort.tests.StarRocksContainer
71+
logger.starrocks.name=org.apache.inlong.sort.tests.utils.StarRocksContainer
7272
logger.starrocks.additivity=false
7373

7474
logger.postgres=INFO, postgres

0 commit comments

Comments
 (0)